container

Documentation

Index

• func BuildContainer() (container *dig.Container)
• func NewBackupConfig(cfg *models.AppConfig) *backup.BackupConfig
• func NewMetricConfig(cfg *models.AppConfig) *metrics.MetricConfig
• func NewMigrationsConfig() *migrations.Config
• func NewMqtt(authenticator mqtt_authenticator.MqttAuthenticator) mqtt.MqttServ
• func NewMqttCli() mqtt.MqttCli
• func NewOrmConfig(cfg *models.AppConfig) *orm.Config
• func NewZigbee2mqttConfig(cfg *models.AppConfig) *zigbee2mqtt.Config
• type Dialer
  • func NewDialer(controllers *controllers.Controllers) *Dialer
  • func (d *Dialer) Call() func(context.Context, string) (net.Conn, error)
• type FxNull
  • func (FxNull) Append(hook fx.Hook)
• type Mqtt
  • func (m Mqtt) Admin() mqtt.Admin
  • func (m Mqtt) Authenticator() mqtt_authenticator.MqttAuthenticator
  • func (m Mqtt) NewClient(name string) mqtt.MqttCli
  • func (m Mqtt) Publish(topic string, payload []byte, qos uint8, retain bool) error
  • func (m Mqtt) RemoveClient(name string)
  • func (m Mqtt) Shutdown() error
  • func (m Mqtt) Start()
• type MqttCli
  • func (m MqttCli) OnMsgArrived(ctx context.Context, client server.Client, req *server.MsgArrivedRequest)
  • func (m MqttCli) Publish(topic string, payload []byte) error
  • func (m MqttCli) Subscribe(topic string, handler mqtt.MessageHandler) error
  • func (m MqttCli) Unsubscribe(topic string)
  • func (m MqttCli) UnsubscribeAll()

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

func NewMqtt(authenticator mqtt_authenticator.MqttAuthenticator) mqtt.MqttServ

NewMqtt ...

func NewMqttCli

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

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

Mqtt ...

func (Mqtt) Admin

func (m Mqtt) Admin() mqtt.Admin

Admin ...

func (Mqtt) Authenticator

func (m Mqtt) Authenticator() mqtt_authenticator.MqttAuthenticator

Authenticator ...

func (Mqtt) NewClient

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

NewClient ...

func (Mqtt) Publish

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

Publish ...

func (Mqtt) RemoveClient

func (m Mqtt) RemoveClient(name string)

RemoveClient ...

func (Mqtt) Shutdown

func (m Mqtt) Shutdown() error

Shutdown ...

func (Mqtt) Start

func (m Mqtt) Start()

Start ...

type MqttCli

type MqttCli struct {
}

MqttCli ...

func (MqttCli) OnMsgArrived

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

OnMsgArrived ...

func (MqttCli) Publish

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

Publish ...

func (MqttCli) Subscribe

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

Subscribe ...

func (MqttCli) Unsubscribe

func (m MqttCli) Unsubscribe(topic string)

Unsubscribe ...

func (MqttCli) UnsubscribeAll

func (m MqttCli) UnsubscribeAll()

UnsubscribeAll ...