store

type Error int

type InflightStore interface {
	//以ClientId&MsgId作key
	SaveByClientIdMsgId(msg *Msg) error
	//以Topic作为key
	SaveRetainMsg(topic string, body []byte, qos byte) error

	GetMsgByClientIdMsgId(clientId string, msgId uint16) (msg *Msg, err error)
	//根据消息Id删除消息
	RemoveMsgById(id int) error
}

type Msg struct {
	//Store里唯一的消息标识
	Id       int
	ClientId string
	//消息作者定义的id
	MsgId uint16
	Topic string
	Qos   byte
	Body  []byte
}

type ProviderFactory func() StoreMgr

type RetainStore interface {
	//Retain消息
	//获取所有离线消息
	GetAllRetainMsgs() (msgs []*Msg, err error)

	//删除topic的离线消息
	RemoveMsgByTopic(topic string) error
}

type StoreMgr interface {
	InflightStore
	RetainStore
}