mqtt

Documentation

Index

• func Serve(ctx context.Context, server io.Server, listener net.Listener, format Format, ...) error
• type Format
  • func NewProtobuf(ctx context.Context) Format
  • func NewProtobufV2(ctx context.Context) Format

Functions

func Serve

func Serve(ctx context.Context, server io.Server, listener net.Listener, format Format, protocol string) error

Serve serves the MQTT frontend.

Types

type Format

type Format interface {
	topics.Layout

	FromDownlink(down *ttnpb.DownlinkMessage, ids ttnpb.GatewayIdentifiers) ([]byte, error)
	ToUplink(message []byte, ids ttnpb.GatewayIdentifiers) (*ttnpb.UplinkMessage, error)
	ToStatus(message []byte, ids ttnpb.GatewayIdentifiers) (*ttnpb.GatewayStatus, error)
	ToTxAck(message []byte, ids ttnpb.GatewayIdentifiers) (*ttnpb.TxAcknowledgment, error)
}

Format formats topics, downlink, uplink and status messages.

func NewProtobuf

func NewProtobuf(ctx context.Context) Format

NewProtobuf returns a format that uses Protocol Buffers marshaling and unmarshaling.

func NewProtobufV2

func NewProtobufV2(ctx context.Context) Format

NewProtobufV2 returns a format that uses the legacy The Things Stack V2 Protocol Buffers marshaling and unmarshaling.