device

Aug 20, 2022

Changes in this version

type Config

+ SkipCategories func() []string

+ SkipFields func() []string

Aug 1, 2022

Changes in this version

type Device

+ GetLastUpdated func() time.Time

+ GetModel func() string

+ GetRegisters func() dataflow.Registers

+ SetLastUpdatedNow func()

+ SetModel func(model string)

type DevicePool

+ func (p *DevicePool) GetDevices() map[string]Device

type DeviceStruct

+ func (c *DeviceStruct) GetLastUpdated() time.Time

+ func (c *DeviceStruct) GetModel() string

+ func (c *DeviceStruct) GetRegisters() dataflow.Registers

+ func (c *DeviceStruct) SetLastUpdatedNow()

+ func (c *DeviceStruct) SetModel(model string)

Apr 24, 2022

Changes in this version

+ func RegisterCreator(kind config.DeviceKind, creator Creator)

+ type Config interface

+ Device func() string

+ Kind func() config.DeviceKind

+ LogComDebug func() bool

+ LogDebug func() bool

+ Name func() string

+ type Creator func(deviceStruct DeviceStruct, output chan dataflow.Value) (device Device, err error)

+ func CreateRandomDeviceFactory(registers dataflow.Registers) Creator

+ type Device interface

+ Config func() Config

+ Registers func() dataflow.Registers

+ SetRegisters func(registers dataflow.Registers)

+ Shutdown func()

+ func RunDevice(cfg Config, target dataflow.Fillable) (device Device, err error)

+ type DevicePool struct

+ Devices map[string]Device

+ DevicesMutex sync.RWMutex

+ func RunPool() (pool *DevicePool)

+ func (p *DevicePool) AddDevice(device Device)

+ func (p *DevicePool) GetDevice(deviceName string) Device

+ func (p *DevicePool) RemoveDevice(device Device)

+ func (p *DevicePool) Shutdown()

+ type DeviceStruct struct

+ func (c *DeviceStruct) SetRegisters(registers dataflow.Registers)

+ func (c DeviceStruct) Config() Config

+ func (c DeviceStruct) GetClosedChan() chan struct{}

+ func (c DeviceStruct) GetShutdownChan() chan struct{}

+ func (c DeviceStruct) Registers() dataflow.Registers

+ func (c DeviceStruct) Shutdown()