ktmt

type ApplicationLayer interface {
	Open(ctx context.Context) error
	Close() error

	Publish(ctx context.Context, topic string, data interface{}) error
	PublishTimeout(ctx context.Context, topic string, data interface{}, timeout time.Duration) error

	PublishWithID(ctx context.Context, sid string, topic string, data interface{}) Token

	Sessions() []string

	AddRoute(topic string, callback MessageHandler)
	DeleteRoute(topic string)
	SetDefaultHandler(handler MessageHandler)

	Remove(id string)
}

type ConnConfig struct {
	Version      byte
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	CID          string
	Keepalive    uint16 // s
	CleanSession bool
	CloseCB      OnCloseCallback
}

type ConnectToken struct {
	// contains filtered or unexported fields
}

type ConnectionLayer interface {
	ID() string
	Write(ctx context.Context, pkt *PacketAndToken) error
	WriteP(ctx context.Context, msg packets.ControlPacket) error
	Read() chan packets.ControlPacket
	Close()
}

type Customer interface {
	GetAckFunc(msg *packets.PublishPacket) func()
}

type DisconnectToken struct {
	// contains filtered or unexported fields
}

type DummyToken struct {
	// contains filtered or unexported fields
}

type ErrorToken struct {
	// contains filtered or unexported fields
}

type Logger interface {
	Println(v ...interface{})
	Printf(format string, v ...interface{})
}

type MConn interface {
	net.Conn
	ID() string
	Heartbeat() time.Duration
	CleanSession() bool
}

type MId uint16

type Message interface {
	Topic() string
	ClientID() string
	MessageID() MId
	Qos() byte
	Duplicate() bool
	Retained() bool
	Payload() []byte
	Ack()
}

type MessageHandler func(Message) bool

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

type NOOPLogger struct{}

type OnCloseCallback func(id string)

type PacketAndToken struct {
	P packets.ControlPacket
	T TokenCompleter
}

type PresentationLayer interface {
	Decode(src []byte, dst interface{}) (err error)
	Encode(src interface{}) (dst []byte, err error)
}

type PublishToken struct {
	// contains filtered or unexported fields
}

type Router interface {
	// AddRoute 添加路由
	AddRoute(topic string, callback MessageHandler)
	// DeleteRoute 删除路由
	DeleteRoute(topic string)
	// SetDefaultHandler 设置默认handler.
	SetDefaultHandler(handler MessageHandler)
	// MatchAndDispatch 分发消息，并处理. order 顺序执行.
	MatchAndDispatch(messages <-chan Message, order bool)
}

type SessionLayer interface {
	Close()
	Send(ctx context.Context, topic string, qos int, msg []byte) Token
	UpdateConnectLayer(ctx context.Context, cl ConnectionLayer) error
	In() <-chan Message
}

type Token interface {
	Wait() bool
	WaitTimeout(time.Duration) bool
	Error() error
}

type TokenCompleter interface {
	Token
	TokenErrorSetter
	FlowComplete()
}

type TokenErrorSetter interface {
	SetError(error)
}