cluster

type Cluster struct {
	ICluster
	// contains filtered or unexported fields
}

type ClusterCfg struct {
	Pid  int
	Addr string
	Hub  IHub
	Mux  *http.ServeMux

	RunLeader   bool
	RunFollower bool
	LeaderAddr  string

	KafkaBrokers []string
	KafkaTopic   string
	KafkaGroupId string

	EnableClientMsg bool

	EventManager         store.IEventStore
	CleanEvents          bool
	EventTTLDays         int32
	EventPayloadMaxBytes int32

	SessionQuota int32
}

type ICluster interface {
	Run(ctx context.Context, stopNotifyCh chan<- struct{})
	SaveMsg(ctx context.Context, msg *pb.E2EMsg) error
}

type IHub interface {
	Run(context.Context, chan<- *pb.FollowerMsg, <-chan *pb.LeaderMsg, chan<- struct{})
	Kickoff(string)
	Online()
	Offline()
}

type IKafkaReader interface {
	FetchMessage(context.Context) (kafka.Message, error)
	CommitMessages(context.Context, ...kafka.Message) error
	Close() error
}

type IKafkaWriter interface {
	WriteMessages(context.Context, ...kafka.Message) error
	Close() error
}

type KafkaMsgValue struct {
	Body   string  `json:"body,omitempty"` // event body in JSON format
	ToUids []int32 `json:"uids,omitempty"`
}

type SessionStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Standalone struct {
	ICluster
	sync.RWMutex
	// contains filtered or unexported fields
}