Versions in this module Expand all Collapse all v0 v0.5.0 Mar 11, 2021 Changes in this version + func Get(ctx context.Context) (opcua.Provider, error) + func GetEnity(ctx context.Context, enityName string) (interface{}, error) + func Registrate(ctx context.Context) (context.Context, error) + func RegistrateEnity(ctx context.Context, enityName string, options interface{}) (context.Context, error) + func VariantToFloat64(value *ua.Variant) float64 + type Config struct + CertificateFile string + DSN string + Handle uint32 + Interval time.Duration + PrivateKeyFile string + QueueSize int + SecurityMode string + SecurityPolicy string + StartWatcher bool + Timeout time.Duration + func (c *Config) SetDefault() *Config + type CosumeHandler func(*monitor.DataChangeMessage) error + type Enity struct + Conn *opcua.Client + Subscription *monitor.Subscription + func GetEnityTypeCast(ctx context.Context, enityName string) (*Enity, error) + func NewEnity(ctx context.Context, name string, cfg interface{}) (*Enity, error) + func (c *Enity) GetMetrics(prefix string) stats.MapMetricsOptions + func (c *Enity) GetReadyHandlers(prefix string) stats.MapCheckFunc + func (c *Enity) Shutdown() error + func (c *Enity) Start() error + func (c *Enity) Subscribe(options *SubscribeOptions) error + func (c *Enity) SubscribeNodeID(nodeID string) error + func (c *Enity) WaitForEstablishing() + type Provider struct + func NewProvider(ctx context.Context) *Provider + func (p *Provider) CreateEnity(enityName string, options interface{}) error + func (p *Provider) GetEnity(connectionName string) (interface{}, error) + type SubscribeOptions struct + ConsumeHndl CosumeHandler
Go to main page