collector

Oct 5, 2022

Changes in this version

+ type HttpCollector struct

+ func NewHttpCollector(c *config.CollectorConfig, ugc []config.UrlGroupConfig) (*HttpCollector, error)

+ func (r *HttpCollector) Collect(publisher mangos.Socket)

Jul 8, 2022

Changes in this version

+ func FrameToBytes(frm can.Frame) []byte

+ type CanBusCollector struct

+ func NewCanBusCollector(c *config.CollectorConfig) (*CanBusCollector, error)

+ func (r *CanBusCollector) Collect(publisher mangos.Socket)

Mar 19, 2022

Changes in this version

+ type LineCollector struct

+ func NewLineCollector(c *config.CollectorConfig) (*LineCollector, error)

+ func (r *LineCollector) Collect(publisher mangos.Socket)

+ type ModbusCollector struct

+ func NewModbusCollector(c *config.CollectorConfig, rgcs []config.RegisterGroupConfig) (*ModbusCollector, error)

+ func (r *ModbusCollector) Collect(publisher mangos.Socket)

Feb 21, 2022

Changes in this version

+ const MaximumNumberOfCoils

+ func CoilsToBytes(rgc config.RegisterGroupConfig, values []bool) []byte

+ func RegistersToBytes(rgc config.RegisterGroupConfig, values []uint16) []byte

+ func StartBytes(slave uint8, functionCode uint16, address uint16, numberOfRegisters uint16) []byte

Feb 20, 2022

Changes in this version

+ const Coils

+ const DiscreteInputs

+ const HoldingRegisters

+ const InputRegisters

+ const MaximumNumberOfRegisters

+ type Collector interface

+ Collect func(publisher mangos.Socket)

+ type LineReader struct

+ func NewLineReader(c *config.CollectorConfig) (*LineReader, error)

+ func (l *LineReader) Collect(publisher mangos.Socket)

+ type ModbusClient struct

+ func (m *ModbusClient) Poll(stream chan<- []byte, rgc config.RegisterGroupConfig) error

+ func (m *ModbusClient) Read(slave uint8, functionCode uint16, address uint16, numberOfRegisters uint16) ([]byte, error)

+ type ModbusReader struct

+ func NewModbusReader(c *config.CollectorConfig, rgs []config.RegisterGroupConfig) (*ModbusReader, error)

+ func (m *ModbusReader) Collect(publisher mangos.Socket)

+ type UdpListenerReader struct

+ func (u UdpListenerReader) Read(p []byte) (n int, err error)