fifo

Documentation

Index

• func New(config config.Config, maxAlias uint16, clientID string) server.TopicAliasManager
• type Queue
  • func (q *Queue) Check(publish *packets.Publish) (alias uint16, exist bool)

Functions

func New

func New(config config.Config, maxAlias uint16, clientID string) server.TopicAliasManager

New is the constructor of Queue.

Types

type Queue

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

Queue is the fifo queue which store all topic alias for one client

func (*Queue) Check

func (q *Queue) Check(publish *packets.Publish) (alias uint16, exist bool)