opcclient

Documentation

Index

• func Initialize(configurations OPCClient)
• type OPCClient
  • func (c *OPCClient) BrowseEndpoints() (*ua.GetEndpointsResponse, error)
  • func (c *OPCClient) Connect()
  • func (c *OPCClient) CreateClient() context.CancelFunc
  • func (c *OPCClient) Disconnect()
  • func (c *OPCClient) Subscribe(triggerTags []string, callback func(string, *ua.DataValue))
• type OPCConfig
• type SubGroup
• type Tag

Functions

func Initialize

func Initialize(configurations OPCClient)

Types

type OPCClient

type OPCClient struct {
	Client    *opcua.Client
	Endpoint  string        `json:"endpoint"`
	Host      string        `json:"host"`
	Name      string        `json:"name"`
	Namespace uint16        `json:"namespace"`
	CertFile  string        `json:"certFile"`
	KeyFile   string        `json:"keyFile"`
	Timeout   time.Duration `json:"timeout"`
	Nodes     map[string]*opcua.Node
	SubGroups []SubGroup `json:"subgroups"`
	// contains filtered or unexported fields
}

func (*OPCClient) BrowseEndpoints

func (c *OPCClient) BrowseEndpoints() (*ua.GetEndpointsResponse, error)

func (*OPCClient) Connect

func (c *OPCClient) Connect()

func (*OPCClient) CreateClient

func (c *OPCClient) CreateClient() context.CancelFunc

func (*OPCClient) Disconnect

func (c *OPCClient) Disconnect()

func (*OPCClient) Subscribe

func (c *OPCClient) Subscribe(triggerTags []string, callback func(string, *ua.DataValue))

type OPCConfig

type OPCConfig struct {
	OPCClients []OPCClient `json:"opcclients"`
}

type SubGroup

type SubGroup struct {
	TriggerTags []string                    `json:"triggerTags"`
	ReportTags  []string                    `json:"reportTags"`
	Trigger     func(string, *ua.DataValue) `json:"trigger"`
	Report      func(string, *ua.DataValue) `json:"report"`
}

type Tag

type Tag struct {
	Name    string
	Address string
}