The highest tagged major version is v2.

bootstrap

package

v1.0.0 Latest Latest Go to latest Published: Oct 25, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var Mqtt5ClientMapName = di.TypeInstanceToName((*Mqtt5ClientMap)(nil))

Mqtt5ClientMapName contains the name of the Mqtt5ClientMap struct in the DIC.

func Mqtt5BootstrapHandler(ctx context.Context, wg *sync.WaitGroup, startupTimer startup.Timer, dic *di.Container) bool

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

func Mqtt5ClientMapFrom(get di.Get) Mqtt5ClientMap

Mqtt5ClientMapFrom helper function queries the DIC and returns the Dev and Remotes mode flags.

func (mc *Mqtt5ClientMap) ConnectAll(ctx context.Context, logger log.Logger) bool

func (mc *Mqtt5ClientMap) DisconnectAll(logger log.Logger) error

func (mc *Mqtt5ClientMap) Get(brokerName string) (mqtt5.Mqtt5Client, error)