natsdevice

Documentation

Index

• type NatsDevice
  • func NewNatsDevice(name string, nc *nats.Conn, ec *nats.EncodedConn, pvs []modbuspv.ModbusPV, ...) (*NatsDevice, error)
  • func NewNatsDeviceFromConfig(config programconfig.Config, nc *nats.Conn, ec *nats.EncodedConn, ...) (*NatsDevice, error)
  • func (d *NatsDevice) ClearSubs()
  • func (d *NatsDevice) Handle(ctx context.Context)
• type NatsMessage

Types

type NatsDevice

type NatsDevice struct {
	Name string
	// contains filtered or unexported fields
}

NatsDevice is a device that communicates over nats

func NewNatsDevice

func NewNatsDevice(name string, nc *nats.Conn, ec *nats.EncodedConn, pvs []modbuspv.ModbusPV, logger log.Logger) (*NatsDevice, error)

NewNatsDevice returns a NatsDevice

func NewNatsDeviceFromConfig

func NewNatsDeviceFromConfig(config programconfig.Config, nc *nats.Conn, ec *nats.EncodedConn, handler modbus.ClientHandler, logger log.Logger) (*NatsDevice, error)

NewNatsDeviceFromConfig initiates NatsDevice from config

func (*NatsDevice) ClearSubs

func (d *NatsDevice) ClearSubs()

ClearSubs clear all subscriptions

func (*NatsDevice) Handle

func (d *NatsDevice) Handle(ctx context.Context)

Handle goes monitor

type NatsMessage

type NatsMessage struct {
	Result interface{} `json:"res"`
	Err    error       `json:"err,omitempty"`
}

NatsMessage is a