worker

Documentation

Index

• Constants
• type ConnectionLogger
• type DeviceProvider
• type DeviceTypeProvider
• type HubProvider
• type Verne
• type Worker
  • func New(config configuration.Config, logger ConnectionLogger, ...) (*Worker, error)
  • func (this *Worker) RunDeviceLoop(ctx context.Context, wg *sync.WaitGroup) error
  • func (this *Worker) RunHubLoop(ctx context.Context, wg *sync.WaitGroup) error

Constants

const ConnectionStateAnnotation = "connected"

Types

type ConnectionLogger

type ConnectionLogger interface {
	LogDeviceDisconnect(id string) error
	LogDeviceConnect(id string) error
	LogHubDisconnect(id string) error
	LogHubConnect(id string) error
}

type DeviceProvider

type DeviceProvider interface {
	GetNextDevice() (device model.PermDevice, isFirstDeviceOfBatchLoopRepeat bool, err error)
	GetDevice(id string) (result model.PermDevice, err error)
}

type DeviceTypeProvider

type DeviceTypeProvider interface {
	GetDeviceType(deviceTypeId string) (dt models.DeviceType, err error)
}

type HubProvider

type HubProvider interface {
	GetNextHub() (device model.PermHub, err error)
	GetHub(id string) (result model.PermHub, err error)
}

type Verne

type Verne interface {
	CheckTopic(topic string) (result bool, err error)
	CheckClient(clientId string) (result bool, err error)
}

type Worker

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

func New

func New(config configuration.Config, logger ConnectionLogger, deviceprovider DeviceProvider, hubprovider HubProvider, deviceTypeProvider DeviceTypeProvider, verne Verne, metrics *prometheus.Metrics) (*Worker, error)

func (*Worker) RunDeviceLoop

func (this *Worker) RunDeviceLoop(ctx context.Context, wg *sync.WaitGroup) error

func (*Worker) RunHubLoop

func (this *Worker) RunHubLoop(ctx context.Context, wg *sync.WaitGroup) error