dmcontext

Apr 9, 2021

Changes in this version

type ModbusAccessConfig

+ IdleTimeout time.Duration

+ Timeout time.Duration

type OpcuaAccessConfig

+ Endpoint string

Apr 8, 2021

Changes in this version

type ModbusAccessConfig

+ Id byte

+ Interval time.Duration

type OpcuaAccessConfig

+ Id byte

+ Interval time.Duration

Mar 31, 2021

Changes in this version

+ const TypeBool

+ const TypeFloat32

+ const TypeFloat64

+ const TypeInt16

+ const TypeInt32

+ const TypeInt64

+ const TypeString

+ var ErrDeviceNotExist = errors.New("device not exist")

+ var ErrTypeNotSupported = errors.New("type not supported")

+ type AccessConfig struct

+ Custom *CustomAccessConfig

+ Modbus *ModbusAccessConfig

+ Opcua *OpcuaAccessConfig

+ func (a *AccessConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type CustomAccessConfig string

+ type ModbusAccessConfig struct

+ Rtu *RtuConfig

+ Tcp *TcpConfig

+ type OpcuaAccessConfig struct

+ Auth OpcuaAuth

+ Certificate OpcuaCertificate

+ ID byte

+ Security OpcuaSecurity

+ Timeout time.Duration

+ type OpcuaAuth struct

+ Password string

+ Username string

+ type OpcuaCertificate struct

+ Cert string

+ Key string

+ type OpcuaSecurity struct

+ Mode string

+ Policy string

+ type RtuConfig struct

+ BaudRate int

+ DataBit int

+ Parity string

+ Port string

+ StopBit int

+ type TcpConfig struct

+ Address string

+ Port uint16

Mar 29, 2021

Changes in this version

+ var ErrAccessConfigNotExist = errors.New("access config not exist")

+ var ErrPropsConfigNotExist = errors.New("properties config not exist")

type Context

+ GetAccessConfig func() map[string]string

+ GetDevicePropertiesConfig func(device *DeviceInfo) ([]DeviceProperty, error)

+ GetPropertiesConfig func() map[string][]DeviceProperty

type DmCtx

+ func (c *DmCtx) GetAccessConfig() map[string]string

+ func (c *DmCtx) GetDevicePropertiesConfig(device *DeviceInfo) ([]DeviceProperty, error)

+ func (c *DmCtx) GetPropertiesConfig() map[string][]DeviceProperty

Feb 1, 2021

Changes in this version

+ const KeySysExtConf

+ type CustomVisitor string

+ type DeviceProperty struct

+ Mode string

+ Name string

+ Type string

+ Visitor PropertyVisitor

+ type ModbusVisitor struct

+ Address string

+ Function byte

+ Quantity uint16

+ Scale float64

+ SwapByte bool

+ SwapRegister bool

+ Type string

+ type OpcuaVisitor struct

+ NodeID string

+ Type string

+ type PropertyVisitor struct

+ Custom *CustomVisitor

+ Modbus *ModbusVisitor

+ Opcua *OpcuaVisitor

Jan 29, 2021

Changes in this version

+ const DefaultAccessConf

+ const TypeReportEvent

type Context

+ GetDeviceAccessConfig func() (string, error)

type DeviceInfo

+ Version string

type DmCtx

+ func (c *DmCtx) GetDeviceAccessConfig() (string, error)

+ type Event struct

+ Payload interface{}

+ Type string

Dec 25, 2020

Changes in this version

+ const KeyStatus

+ const OfflineStatus

+ const OnlineStatus

+ func ParseTopic(topic string) (string, error)

Dec 24, 2020

Changes in this version

+ const ActionOffline

+ const ActionOnline

+ const ActionReport

+ const DefaultDriverConf

+ const DefaultPropsConf

+ const DeviceTopicRe

+ const KeyAction

+ const KeyDevice

+ const KindDelta

+ const KindGetResponse

+ var ErrCallbackNotRegister = errors.New("callback not registered yet")

+ var ErrInvalidCallback = errors.New("invalid device callback")

+ var ErrInvalidChannel = errors.New("invalid channel")

+ var ErrInvalidMessage = errors.New("invalid device message")

+ var ErrResponseChannelNotExist = errors.New("response channel not exist")

+ func NewObserver(msgs map[string]chan *v1.Message, log *log.Logger) mqtt.Observer

+ func Run(handle func(Context) error)

+ type Context interface

+ GetAllDevices func() []DeviceInfo

+ GetDevicePropConfigs func() (map[string]DevicePropConfigs, error)

+ GetDeviceProperties func(info *DeviceInfo) (*DeviceShadow, error)

+ GetDriverConfig func() (string, error)

+ Offline func(info *DeviceInfo) error

+ Online func(info *DeviceInfo) error

+ RegisterDeltaCallback func(info *DeviceInfo, cb DeltaCallback)

+ RegisterEventCallback func(info *DeviceInfo, cb EventCallback)

+ ReportDeviceProperties func(info *DeviceInfo, props *DeviceProperties) error

+ Start func()

+ SystemConfigExt func() *SystemConfig

+ func NewContext(confFile string) Context

+ type DeltaCallback func(*DeviceInfo, *DeviceProperties) error

+ type DeviceEvent struct

+ Event interface{}

+ Name string

+ type DeviceInfo struct

+ Name string

+ type DevicePropConfigs struct

+ Name string

+ PropConfigs map[string]string

+ type DeviceProperties struct

+ Name string

+ Props map[string]interface{}

+ type DeviceShadow struct

+ Desire v1.Desire

+ Name string

+ Report v1.Report

+ type DmCtx struct

+ func (c *DmCtx) Close() error

+ func (c *DmCtx) GetAllDevices() []DeviceInfo

+ func (c *DmCtx) GetDevicePropConfigs() (map[string]DevicePropConfigs, error)

+ func (c *DmCtx) GetDeviceProperties(info *DeviceInfo) (*DeviceShadow, error)

+ func (c *DmCtx) GetDriverConfig() (string, error)

+ func (c *DmCtx) Offline(info *DeviceInfo) error

+ func (c *DmCtx) Online(info *DeviceInfo) error

+ func (c *DmCtx) RegisterDeltaCallback(info *DeviceInfo, cb DeltaCallback)

+ func (c *DmCtx) RegisterEventCallback(info *DeviceInfo, cb EventCallback)

+ func (c *DmCtx) ReportDeviceProperties(info *DeviceInfo, props *DeviceProperties) error

+ func (c *DmCtx) Start()

+ func (c *DmCtx) SystemConfigExt() *SystemConfig

+ type EventCallback func(*DeviceInfo, *DeviceEvent) error

+ type SystemConfig struct

+ Devices []DeviceInfo

+ type Topic struct

+ Delta mqtt2.QOSTopic

+ Event mqtt2.QOSTopic

+ Get mqtt2.QOSTopic

+ GetResponse mqtt2.QOSTopic

+ Report mqtt2.QOSTopic