container

Documentation

Index

• func BuildContainer() (container *dig.Container)
• func NewBackupConfig(cfg *models.AppConfig) *backup.Config
• func NewLoggerConfig() *logging.Config
• 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
• func ReadConfig() (conf *models.AppConfig)
• 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.Config

NewBackupConfig ...

func NewLoggerConfig

func NewLoggerConfig() *logging.Config

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 ...

func ReadConfig

func ReadConfig() (conf *models.AppConfig)

Types

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 ...