container

package
Version: v0.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 7, 2022 License: GPL-3.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildContainer

func BuildContainer() (container *dig.Container)

BuildContainer ...

func NewBackupConfig

func NewBackupConfig(cfg *models.AppConfig) *backup.BackupConfig

NewBackupConfig ...

func NewMetricConfig

func NewMetricConfig(cfg *models.AppConfig) *metrics.MetricConfig

NewMetricConfig ...

func NewMigrationsConfig

func NewMigrationsConfig() *migrations.Config

NewMigrationsConfig ...

func NewMqtt added in v0.5.2

func NewMqtt(authenticator mqtt_authenticator.MqttAuthenticator) mqtt.MqttServ

NewMqtt ...

func NewMqttCli added in v0.5.2

func NewMqttCli() mqtt.MqttCli

NewMqttCli ...

func NewOrmConfig

func NewOrmConfig(cfg *models.AppConfig) *orm.Config

NewOrmConfig ...

func NewZigbee2mqttConfig

func NewZigbee2mqttConfig(cfg *models.AppConfig) *zigbee2mqtt.Config

NewZigbee2mqttConfig ...

Types

type Dialer

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

Dialer ...

func NewDialer

func NewDialer(controllers *controllers.Controllers) *Dialer

NewDialer ...

func (*Dialer) Call

func (d *Dialer) Call() func(context.Context, string) (net.Conn, error)

Call ...

type FxNull

type FxNull struct {
}

FxNull ...

func (FxNull) Append

func (FxNull) Append(hook fx.Hook)

Append ...

type Mqtt added in v0.5.2

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

Mqtt ...

func (Mqtt) Admin added in v0.5.2

func (m Mqtt) Admin() mqtt.Admin

Admin ...

func (Mqtt) Authenticator added in v0.5.2

func (m Mqtt) Authenticator() mqtt_authenticator.MqttAuthenticator

Authenticator ...

func (Mqtt) NewClient added in v0.5.2

func (m Mqtt) NewClient(name string) mqtt.MqttCli

NewClient ...

func (Mqtt) Publish added in v0.5.2

func (m Mqtt) Publish(topic string, payload []byte, qos uint8, retain bool) error

Publish ...

func (Mqtt) RemoveClient added in v0.5.2

func (m Mqtt) RemoveClient(name string)

RemoveClient ...

func (Mqtt) Shutdown added in v0.5.2

func (m Mqtt) Shutdown() error

Shutdown ...

func (Mqtt) Start added in v0.5.2

func (m Mqtt) Start()

Start ...

type MqttCli added in v0.5.2

type MqttCli struct {
}

MqttCli ...

func (MqttCli) OnMsgArrived added in v0.5.2

func (m MqttCli) OnMsgArrived(ctx context.Context, client server.Client, req *server.MsgArrivedRequest)

OnMsgArrived ...

func (MqttCli) Publish added in v0.5.2

func (m MqttCli) Publish(topic string, payload []byte) error

Publish ...

func (MqttCli) Subscribe added in v0.5.2

func (m MqttCli) Subscribe(topic string, handler mqtt.MessageHandler) error

Subscribe ...

func (MqttCli) Unsubscribe added in v0.5.2

func (m MqttCli) Unsubscribe(topic string)

Unsubscribe ...

func (MqttCli) UnsubscribeAll added in v0.5.2

func (m MqttCli) UnsubscribeAll()

UnsubscribeAll ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL