Versions in this module Expand all Collapse all v0 v0.2.0 Nov 20, 2020 Changes in this version + var DefaultCallbackBufferLen = 8192 + var ErrSlowConsumer = errors.New("slow consumer. messages may be dropped") + type DataChangeMessage struct + Error error + NodeID *ua.NodeID + type ErrHandler func(*opcua.Client, *Subscription, error) + type Item struct + func (m *Item) ID() uint32 + func (m *Item) NodeID() *ua.NodeID + type MsgHandler func(*Subscription, *DataChangeMessage) + type NodeMonitor struct + func NewNodeMonitor(client *opcua.Client) (*NodeMonitor, error) + func (m *NodeMonitor) ChanSubscribe(ctx context.Context, params *opcua.SubscriptionParameters, ...) (*Subscription, error) + func (m *NodeMonitor) SetErrorHandler(cb ErrHandler) + func (m *NodeMonitor) Subscribe(ctx context.Context, params *opcua.SubscriptionParameters, cb MsgHandler, ...) (*Subscription, error) + type Request struct + MonitoringMode ua.MonitoringMode + MonitoringParameters *ua.MonitoringParameters + NodeID *ua.NodeID + type Subscription struct + func (s *Subscription) AddMonitorItems(nodes ...Request) ([]Item, error) + func (s *Subscription) AddNodeIDs(nodes ...*ua.NodeID) error + func (s *Subscription) AddNodes(nodes ...string) error + func (s *Subscription) Delivered() uint64 + func (s *Subscription) Dropped() uint64 + func (s *Subscription) RemoveMonitorItems(items ...Item) error + func (s *Subscription) RemoveNodeIDs(nodes ...*ua.NodeID) error + func (s *Subscription) RemoveNodes(nodes ...string) error + func (s *Subscription) Stats() (*ua.SubscriptionDiagnosticsDataType, error) + func (s *Subscription) Subscribed() int + func (s *Subscription) SubscriptionID() uint32 + func (s *Subscription) Unsubscribe() error