mqtt

Documentation

Index

• Constants
• func LogDebug(args ...interface{})
• func LogDebugf(format string, args ...interface{})
• func LogError(args ...interface{})
• func LogErrorf(format string, args ...interface{})
• func LogFatal(args ...interface{})
• func LogFatalf(format string, args ...interface{})
• func LogInfo(args ...interface{})
• func LogInfof(format string, args ...interface{})
• func LogWarn(args ...interface{})
• func LogWarnf(format string, args ...interface{})
• func RegisterSubscriber[T any](srv *Server, ctx context.Context, topic string, ...) error
• 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, handler broker.Handler, ...) error
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(_ context.Context) error
• type ServerOption
  • func WithAddress(addrs []string) ServerOption
  • func WithAuth(username string, password string) ServerOption
  • func WithBrokerOptions(opts ...broker.Option) ServerOption
  • func WithCleanSession(enable bool) ServerOption
  • func WithClientId(clientId string) ServerOption
  • func WithCodec(c string) ServerOption
  • func WithEnableKeepAlive(enable bool) 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) NodeFilters() []selector.NodeFilter
  • func (tr *Transport) Operation() string
  • func (tr *Transport) ReplyHeader() transport.Header
  • func (tr *Transport) RequestHeader() transport.Header

Constants

const (
	KindMQTT transport.Kind = "mqtt"
)

Functions

func LogDebug

func LogDebug(args ...interface{})

func LogDebugf

func LogDebugf(format string, args ...interface{})

func LogError

func LogError(args ...interface{})

func LogErrorf

func LogErrorf(format string, args ...interface{})

func LogFatal

func LogFatal(args ...interface{})

func LogFatalf

func LogFatalf(format string, args ...interface{})

func LogInfo

func LogInfo(args ...interface{})

func LogInfof

func LogInfof(format string, args ...interface{})

func LogWarn

func LogWarn(args ...interface{})

func LogWarnf

func LogWarnf(format string, args ...interface{})

func RegisterSubscriber

func RegisterSubscriber[T any](srv *Server, ctx context.Context, topic string, handler func(context.Context, string, broker.Headers, *T) error, opts ...broker.SubscribeOption) error

RegisterSubscriber .

Types

type Server

type Server struct {
	broker.Broker

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(opts ...ServerOption) *Server

NewServer news server instance with options

func (*Server) Endpoint

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

Endpoint .

func (*Server) Name

func (s *Server) Name() string

Name .

func (*Server) RegisterSubscriber

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

RegisterSubscriber .

func (*Server) Start

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

Start .

func (*Server) Stop

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

Stop .

type ServerOption

type ServerOption func(o *Server)

func WithAddress

func WithAddress(addrs []string) ServerOption

WithAddress .

func WithAuth

func WithAuth(username string, password string) ServerOption

WithAuth .

func WithBrokerOptions

func WithBrokerOptions(opts ...broker.Option) ServerOption

WithBrokerOptions MQ options

func WithCleanSession

func WithCleanSession(enable bool) ServerOption

WithCleanSession .

func WithClientId

func WithClientId(clientId string) ServerOption

WithClientId .

func WithCodec

func WithCodec(c string) ServerOption

WithCodec .

func WithEnableKeepAlive

func WithEnableKeepAlive(enable bool) ServerOption

WithEnableKeepAlive enable keep alive

func WithTLSConfig

func WithTLSConfig(c *tls.Config) ServerOption

WithTLSConfig .

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) NodeFilters

func (tr *Transport) NodeFilters() []selector.NodeFilter

NodeFilters returns the client select filters.

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.