Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(q *QoS1)
func WithPublishWriter ¶
func WithPublishWriter(writer broker.PublishWriter) Option
func WithSession ¶
func WithSubOption ¶
type PublishQueue ¶
type PublishQueue struct {
// contains filtered or unexported fields
}
func NewPublishQueue ¶
func NewPublishQueue(writer broker.PublishWriter) *PublishQueue
func (*PublishQueue) HandlePublishAck ¶
func (q *PublishQueue) HandlePublishAck(publishAck *packets.Puback) bool
HandlePublishAck handles the publishing ack packet. match the packet id of the ack packet with the packet id in the queue. packet id means the identifier of the packet. If the packet id of the ack packet is in the queue, it will be removed from the queue. and the retry task will be deleted. return true if the packet id is in the queue, otherwise return false.
func (*PublishQueue) WritePacket ¶
func (q *PublishQueue) WritePacket(packet *packet.PublishMessage)
WritePacket writes the publishing packet to the publishing queue.
type QoS1 ¶
type QoS1 struct {
// contains filtered or unexported fields
}
func (*QoS1) HandlePublishAck ¶
type Session ¶
type Session interface { broker.SessionTopicLatestPushedMessage broker.SessionTopicUnFinishedMessage }
type StoreEvent ¶
Click to show internal directories.
Click to hide internal directories.