collector

Documentation

Index

• Constants
• func CoilsToBytes(rgc config.RegisterGroupConfig, values []bool) []byte
• func FrameToBytes(frm can.Frame) []byte
• func RegistersToBytes(rgc config.RegisterGroupConfig, values []uint16) []byte
• func StartBytes(slave uint8, functionCode uint16, address uint16, ...) []byte
• type CanBusCollector
  • func NewCanBusCollector(c *config.CollectorConfig) (*CanBusCollector, error)
  • func (r *CanBusCollector) Collect(publisher mangos.Socket)
• type Collector
• type HttpCollector
  • func NewHttpCollector(c *config.CollectorConfig, ugc []config.UrlGroupConfig) (*HttpCollector, error)
  • func (r *HttpCollector) Collect(publisher mangos.Socket)
• type LineCollector
  • func NewLineCollector(c *config.CollectorConfig) (*LineCollector, error)
  • func (r *LineCollector) Collect(publisher mangos.Socket)
• type ModbusClient
  • func (m *ModbusClient) Poll(stream chan<- []byte, rgc config.RegisterGroupConfig) error
  • func (m *ModbusClient) Read(rgc config.RegisterGroupConfig) ([]byte, error)
• type ModbusCollector
  • func NewModbusCollector(c *config.CollectorConfig, rgcs []config.RegisterGroupConfig) (*ModbusCollector, error)
  • func (r *ModbusCollector) Collect(publisher mangos.Socket)
• type UdpListenerReader
  • func (u UdpListenerReader) Read(p []byte) (n int, err error)

Constants

const MaximumNumberOfCoils = 2000

const MaximumNumberOfRegisters = 125

MaximumNumberOfRegisters is maximum number of registers that can be read in one request, a modbus message is limit to 256 bytes TODO: this should be checked when register groups are created

Functions

func CoilsToBytes

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

func FrameToBytes

func FrameToBytes(frm can.Frame) []byte

func RegistersToBytes

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

func StartBytes

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

Types

type CanBusCollector

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

func NewCanBusCollector

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

func (*CanBusCollector) Collect

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

type Collector

type Collector interface {
	Collect(publisher mangos.Socket)
}

Collector interface

type HttpCollector

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

func NewHttpCollector

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

func (*HttpCollector) Collect

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

type LineCollector

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

LineCollector reads lines from the connection and sends it on the mangos socket

func NewLineCollector

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

func (*LineCollector) Collect

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

type ModbusClient

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

func (*ModbusClient) Poll

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

func (*ModbusClient) Read

func (m *ModbusClient) Read(rgc config.RegisterGroupConfig) ([]byte, error)

type ModbusCollector

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

func NewModbusCollector

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

func (*ModbusCollector) Collect

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

type UdpListenerReader

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

UdpListenerReader implements the io.Reader interface

func (UdpListenerReader) Read

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