app

Documentation

Index

• Variables
• type App
  • func New(config *v1config.CliConfig) *App
  • func (a *App) DoReconcile()
  • func (a *App) Start(ctx context.Context) error
  • func (a *App) StartMQTTServer(ctx context.Context) error
  • func (a *App) Wait()

Variables

var ErrQueueFull = errors.New("queue full")

Types

type App

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

func New

func New(config *v1config.CliConfig) *App

func (*App) DoReconcile

func (a *App) DoReconcile()

func (*App) Start

func (a *App) Start(ctx context.Context) error

func (*App) StartMQTTServer

func (a *App) StartMQTTServer(ctx context.Context) error

TODO start mqtt server if any mqtt config. then have separate function to do the Subscriptions based on whith meter (p1ib etc...)

func (*App) Wait

func (a *App) Wait()