subscription

Documentation

Overview

Package subscription implements MQTT topic subscriptions

Index

• type List
  • func (s *List) Add(filter string, qos byte) (added bool)
  • func (s *List) Clear()
  • func (s *List) Count() (count int)
  • func (s *List) Match(t ...string) (qos byte, found bool)
  • func (s *List) Matches(t ...string) (matches []string)
  • func (s *List) Remove(filter string) (removed bool)
  • func (s *List) Subscriptions() map[string]byte

Types

type List

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

List of MQTT topic subscriptions

func (*List) Add

func (s *List) Add(filter string, qos byte) (added bool)

Add a subscription to the list

func (*List) Clear

func (s *List) Clear()

Clear the subscription list

func (*List) Count

func (s *List) Count() (count int)

Count the subscriptions

func (*List) Match

func (s *List) Match(t ...string) (qos byte, found bool)

Match the topic to the subscriptions and return the maximum QoS

func (*List) Matches

func (s *List) Matches(t ...string) (matches []string)

Matches for the topic

func (*List) Remove

func (s *List) Remove(filter string) (removed bool)

Remove a subscription from the list

func (*List) Subscriptions

func (s *List) Subscriptions() map[string]byte

Subscriptions returns the subscriptions in the list