gproto

type FProcessor = func(interface{}, interface{}, interface{}) interface{}

type ICoder interface {
	Code(data interface{}) interface{}
}

type IDecoder interface {
	Decode(data interface{}) interface{}
}

type IEncoder interface {
	Encode(data interface{}) interface{}
}

type IMesageQueueName interface {
	Name() string
}

type IMessageQueue interface {
	IMesageQueueName
	IMessageQueueReader
	IMessageQueueWriter
}

type IMessageQueueBundle interface {
	Push(id interface{}, msg interface{}) bool
	Pop(id interface{}, num int) []interface{}
}

type IMessageQueueFactory interface {
	gioc.IPriority
	GetMessageQueue(group, id string) IMessageQueue
}

type IMessageQueueReader interface {
	Pop(num int) []string
}

type IMessageQueueWriter interface {
	Push(msg string) bool
}

type IMsgProcessor interface {
	ProcessMsg(msg interface{}) bool
}

type INetChannel interface {
	IMsgProcessor
	// 设置编码器
	SetEncoder(encoder IEncoder)
	// 发送一个数据
	Send(data interface{})
	// 关闭
	Close() error
	IsActive() bool
	RemoteAddr() net.Addr
	LocalAddr() net.Addr
}

type INetConnector interface {
	Connect(host string) INetChannel
	ConnectBind(localhost string, host string) INetChannel
}

type INetListener interface {
	SetEncoder(encoder IEncoder)
	SetDecoder(decoder IDecoder)
	SetRoute(route IRoute)
	Listen(host string) error
}

type IRoute interface {
	Connect(key interface{}, processor FProcessor)
	GetRoute(key interface{}) []FProcessor
	GetRouteKeys() []interface{}
	Trigger(from interface{}, key interface{}, value interface{}) interface{}
}

type IRouteDelegate interface {
	IRoute
	SetDelegate(raw IRoute)
}