mqtt

Documentation

Index

• Constants
• type Server
  • func NewServer(opts ...ServerOption) *Server
  • func (s *Server) Endpoint() (*url.URL, error)
  • func (s *Server) Name() string
  • func (s *Server) RegisterSubscriber(ctx context.Context, topic string, h broker.Handler, ...) error
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(_ context.Context) error
• type ServerOption
  • func Subscribe(ctx context.Context, topic string, h broker.Handler, ...) ServerOption
  • func WithAddress(addrs []string) ServerOption
  • func WithAuth(username string, password string) ServerOption
  • func WithCleanSession(enable bool) ServerOption
  • func WithClientId(clientId string) ServerOption
  • func WithLogger(logger log.Logger) ServerOption
  • func WithTLSConfig(c *tls.Config) ServerOption
• type SubscribeOption
• type SubscribeOptionMap
• type SubscriberMap
• type Transport
  • func (tr *Transport) Endpoint() string
  • func (tr *Transport) Kind() transport.Kind
  • func (tr *Transport) Operation() string
  • func (tr *Transport) ReplyHeader() transport.Header
  • func (tr *Transport) RequestHeader() transport.Header
  • func (tr *Transport) SelectFilters() []selector.Filter

Constants

const (
	KindMQTT transport.Kind = "mqtt"
)

Types

type Server

type Server struct {
	broker.Broker

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(opts ...ServerOption) *Server

func (*Server) Endpoint

func (s *Server) Endpoint() (*url.URL, error)

func (*Server) Name

func (s *Server) Name() string

func (*Server) RegisterSubscriber

func (s *Server) RegisterSubscriber(ctx context.Context, topic string, h broker.Handler, opts ...broker.SubscribeOption) error

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop

func (s *Server) Stop(_ context.Context) error

type ServerOption

type ServerOption func(o *Server)

func Subscribe

func Subscribe(ctx context.Context, topic string, h broker.Handler, opts ...broker.SubscribeOption) ServerOption

func WithAddress

func WithAddress(addrs []string) ServerOption

func WithAuth

func WithAuth(username string, password string) ServerOption

func WithCleanSession

func WithCleanSession(enable bool) ServerOption

func WithClientId

func WithClientId(clientId string) ServerOption

func WithLogger

func WithLogger(logger log.Logger) ServerOption

func WithTLSConfig

func WithTLSConfig(c *tls.Config) ServerOption

type SubscribeOption

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

type SubscribeOptionMap

type SubscribeOptionMap map[string]*SubscribeOption

type SubscriberMap

type SubscriberMap map[string]broker.Subscriber

type Transport

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

Transport is a MQTT transport.

func (*Transport) Endpoint

func (tr *Transport) Endpoint() string

Endpoint returns the transport endpoint.

func (*Transport) Kind

func (tr *Transport) Kind() transport.Kind

Kind returns the transport kind.

func (*Transport) Operation

func (tr *Transport) Operation() string

Operation returns the transport operation.

func (*Transport) ReplyHeader

func (tr *Transport) ReplyHeader() transport.Header

ReplyHeader returns the reply header.

func (*Transport) RequestHeader

func (tr *Transport) RequestHeader() transport.Header

RequestHeader returns the request header.

func (*Transport) SelectFilters

func (tr *Transport) SelectFilters() []selector.Filter

SelectFilters returns the client select filters.