state

Documentation

Index

• type State
  • func NewState(store broker.KeyValueStore) *State
  • func (s *State) CreateRetainMessageID(topic, messageID string) error
  • func (s *State) CreateTopicWillMessageID(topic, messageID, clientID string) error
  • func (s *State) DeleteRetainMessageID(topic string) error
  • func (s *State) DeleteTopicWillMessageID(topic, messageID string) error
  • func (s *State) ReadRetainMessageID(topic string) ([]string, error)
  • func (s *State) ReadTopicWillMessageID(topic string) (map[string]string, error)

Types

type State

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

func NewState

func NewState(store broker.KeyValueStore) *State

func (*State) CreateRetainMessageID

func (s *State) CreateRetainMessageID(topic, messageID string) error

func (*State) CreateTopicWillMessageID

func (s *State) CreateTopicWillMessageID(topic, messageID, clientID string) error

func (*State) DeleteRetainMessageID

func (s *State) DeleteRetainMessageID(topic string) error

func (*State) DeleteTopicWillMessageID

func (s *State) DeleteTopicWillMessageID(topic, messageID string) error

func (*State) ReadRetainMessageID

func (s *State) ReadRetainMessageID(topic string) ([]string, error)

func (*State) ReadTopicWillMessageID

func (s *State) ReadTopicWillMessageID(topic string) (map[string]string, error)