mqtt

package

v0.4.1 Latest Latest Go to latest Published: Dec 13, 2025 License: MIT Imports: 17 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

Integration implements a MQTT Integration.

func NewIntegration(conf config.Config) (*Integration, error)

NewIntegration creates a new Integration.

func (integ *Integration) PublishBasestationEvent(bsEui common.EUI64, event string, pb *bs.BasestationUplink) error

Publish basestation messages.

func (integ *Integration) PublishEndnodeEvent(bsEui common.EUI64, event string, pb *bs.EndnodeUplink) error

Publish endnode messages.

func (integ *Integration) PublishState(ctx context.Context, bsEui common.EUI64, pb *bs.BasestationState) error

Publish basestation messages.

func (integ *Integration) SetBasestationSubscription(subscribe bool, bsEui common.EUI64) error

Updates the subscription for the given EUI.

func (integ *Integration) SetServerCommandHandler(f func(*bs.ServerCommand))

Set handler for server command messages

func (integ *Integration) SetServerResponseHandler(f func(*bs.ServerResponse))

Set handler for server command messages

func (integ *Integration) Start() error

Start the integration.

func (integ *Integration) Stop() error

Stop the integration.