Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FrameToBytes ¶
Types ¶
type CanBusConnector ¶
type CanBusConnector struct {
// contains filtered or unexported fields
}
func NewCanBusConnector ¶
func NewCanBusConnector(c *config.ConnectorConfig) (*CanBusConnector, error)
func (*CanBusConnector) Publish ¶
func (r *CanBusConnector) Publish(publisher mangos.Socket)
func (*CanBusConnector) Subscribe ¶
func (*CanBusConnector) Subscribe(subscriber mangos.Socket)
type Connector ¶
type Connector interface {
Publish(publisher mangos.Socket)
Subscribe(subscriber mangos.Socket)
}
Connector interface
type HttpConnector ¶
type HttpConnector struct {
// contains filtered or unexported fields
}
func NewHttpConnector ¶
func NewHttpConnector(c *config.ConnectorConfig, ugc []config.UrlGroupConfig) (*HttpConnector, error)
func (*HttpConnector) Publish ¶
func (r *HttpConnector) Publish(publisher mangos.Socket)
func (*HttpConnector) Subscribe ¶
func (*HttpConnector) Subscribe(subscriber mangos.Socket)
type LineConnector ¶
type LineConnector struct {
// contains filtered or unexported fields
}
LineConnector reads lines from the connection and sends it on the mangos socket
func NewLineConnector ¶
func NewLineConnector(c *config.ConnectorConfig) (*LineConnector, error)
func (*LineConnector) Publish ¶
func (r *LineConnector) Publish(publisher mangos.Socket)
func (*LineConnector) Subscribe ¶
func (r *LineConnector) Subscribe(subscriber mangos.Socket)
type ModbusConnector ¶
type ModbusConnector struct {
// contains filtered or unexported fields
}
func NewModbusConnector ¶
func NewModbusConnector(c *config.ConnectorConfig, rgcs []config.RegisterGroupConfig) (*ModbusConnector, error)
func (*ModbusConnector) Publish ¶
func (m *ModbusConnector) Publish(publisher mangos.Socket)
func (*ModbusConnector) Subscribe ¶
func (m *ModbusConnector) Subscribe(subscriber mangos.Socket)
type UdpListenerConnection ¶
type UdpListenerConnection struct {
// contains filtered or unexported fields
}
UdpListenerConnection implements the io.ReadWriter interface
Source Files
Click to show internal directories.
Click to hide internal directories.