container

Documentation

Index

• func BuildContainer() (container *dig.Container)
• func NewAuthenticator() plugins.Authorization
• func NewBackupConfig(cfg *models.AppConfig) *backup.Config
• func NewHttpAccessFilter() plugins.HttpAccessFilter
• func NewLoggerConfig() *logging.Config
• func NewMigrationsConfig() *migrations.Config
• func NewMqtt(authenticator mqtt.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 Authenticator
  • func (a Authenticator) AuthPlain(login, pass string) (*m.User, error)
  • func (a Authenticator) AuthREST(ctx context.Context, accessToken string, requestURI *url.URL, method string) (*m.User, bool, error)
• type FxNull
  • func (FxNull) Append(hook fx.Hook)
• type HttpAccessFilter
  • func (h HttpAccessFilter) Auth(next http.Handler) http.Handler
• type Mqtt
  • func (m Mqtt) Admin() systemMqtt.Admin
  • func (m Mqtt) Authenticator() mqtt.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 NewAuthenticator

func NewAuthenticator() plugins.Authorization

func NewBackupConfig

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

NewBackupConfig ...

func NewHttpAccessFilter

func NewHttpAccessFilter() plugins.HttpAccessFilter

func NewLoggerConfig

func NewLoggerConfig() *logging.Config

func NewMigrationsConfig

func NewMigrationsConfig() *migrations.Config

NewMigrationsConfig ...

func NewMqtt

func NewMqtt(authenticator mqtt.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 Authenticator

type Authenticator struct {
}

func (Authenticator) AuthPlain

func (a Authenticator) AuthPlain(login, pass string) (*m.User, error)

func (Authenticator) AuthREST

func (a Authenticator) AuthREST(ctx context.Context, accessToken string, requestURI *url.URL, method string) (*m.User, bool, error)

type FxNull

type FxNull struct {
}

FxNull ...

func (FxNull) Append

func (FxNull) Append(hook fx.Hook)

Append ...

type HttpAccessFilter

type HttpAccessFilter struct {
}

func (HttpAccessFilter) Auth

func (h HttpAccessFilter) Auth(next http.Handler) http.Handler

type Mqtt

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

Mqtt ...

func (Mqtt) Admin

func (m Mqtt) Admin() systemMqtt.Admin

Admin ...

func (Mqtt) Authenticator

func (m Mqtt) Authenticator() mqtt.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 ...