core

type Coder interface {
	Encode() ([]byte, error)
	Decode(input []byte) error
}

type IChannel interface {
	Init(logProf bool)
	SetTopic(topic string)
	SetGroup(group string)
	SetID(id string)
	GetID() string
	SetDir(dir int)
	GetDir() int
	SetHandler(handler IChannelConsumer)
	Commit(rawMsg []interface{}) error

	Send(topic string, partition int32, keys, bytes []byte, headers map[string]string) error
	SendAndRecv(topic string, partition int32, keys, bytes []byte, headers map[string]string) error
	SendWithRetry(topic string, partition int32, keys, bytes []byte, headers map[string]string) error
	SendAndRecvWithRetry(topic string, partition int32, keys, bytes []byte, headers map[string]string) error
	SendRecv(topic string, bytes []byte, timeout int, headers map[string]string) ([]byte, error)
	PreStart(broker string, statsInterval int)
	Start()
	Stop()
	Close()
}

type IChannelConsumer interface {
	OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})
}

type IConfig interface {
	GetDBConfig(name string) (driver string, createAddr string, addr string, persistUnderlying string, persistName string, async bool)
}

type IMsgHandler interface {
}

type IMultiplexer interface {
	AddNode(nodeName string, node interface{}) bool
	GetNode(nodeName string) (interface{}, bool)
	GetChannel(nodeName, serviceID string) (interface{}, bool)
	PreStartChannel(nodeName, serviceID string) bool
	SendNode(nodeName, serviceID string, obj interface{}) error
	SendRecvNode(nodeName, serviceID string, obj interface{}) (interface{}, error)
	Send(nodeName, serviceID string, obj interface{}) error
	SendAndRecv(nodeName, serviceID string, obj interface{}) error
	SendWithRetry(nodeName, serviceID string, obj interface{}) error
	SendAndRecvWithRetry(nodeName, serviceID string, obj interface{}) error
	PreStart()
	Start()
}

type IProcessor interface {
	OnMultiplexerMessage(serviceID string, msg interface{}) (interface{}, error) //as receiver for multiplexer
	OnMessage(topic string, partition int32, data []byte) ([]byte, error)        //as receiver for transport
	PreStart()
	Start()
}

type ISelector interface {
	GetName() string
	AddNode(node string)
	GetNode(node string) (string, error)
	DelNode(node string) bool
}

type ITransport interface {
	AddChannel(dir int, id, topic, grp string, conf interface{}) bool
	GetChannel(id string) (IChannel, bool)
	PreStartChannel(id string) bool
	StartChannel(id string)
	StopChannel(id string)
	SetID(id string)
	Init(logProf bool)
	SetBrokers(broker string)
	GetBrokers() string
	SetStatsInterval(interval int)
	GetStatsInterval() int
	PreStart()
	Start()
}

type InputMsg interface {
	InitFromBytes([]byte)
	GetMsgType() int32
}

type ProcessorMsg struct {
	MsgType  int32
	Msg      interface{}
	UserID   string
	DeviceID string
}

type TransportPubMsg struct {
	Partition int32
	Format    int8
	Topic     string
	Keys      []byte
	Obj       interface{}
	Timeout   int
	Inst      int
	Headers   map[string]string
}