opcua

Documentation

Index

• Constants
• Variables
• func ErrNotConfigPointer(iface interface{}) error
• func ErrNotEnityPointer(iface interface{}) error
• func GetEnity(ctx context.Context, provider, enityName string) (interface{}, error)
• func Registrate(ctx context.Context) context.Context
• func RegistrateEnity(ctx context.Context, provider, enityName string, options interface{}) (context.Context, error)
• func RegistrateProvider(ctx context.Context, name string, p Provider) (context.Context, error)
• type Opcua
  • func Get(ctx context.Context) *Opcua
  • func NewOpcua(ctx context.Context) *Opcua
  • func (d *Opcua) GetAllAliveHandlers(out stats.MapCheckFunc) (stats.MapCheckFunc, error)
  • func (d *Opcua) GetAllMetrics(out stats.MapMetricsOptions) (stats.MapMetricsOptions, error)
  • func (d *Opcua) GetAllReadyHandlers(out stats.MapCheckFunc) (stats.MapCheckFunc, error)
  • func (d *Opcua) GetProvider(providerName string) (Provider, error)
• type Provider
  • func GetProvider(ctx context.Context, name string) (Provider, error)

Constants

const (
	ProvidersName = "opcua"
)

Variables

var (
	ErrEmptyOPCUA              = errors.New("empty opcua")
	ErrEmptyConnectionName     = errors.New("empty connection name is not allowed")
	ErrConnectionPointerIsNil  = errors.New("nil passed as connection pointer")
	ErrConnectionDoesNotExists = errors.New("connection does not exist")
	ErrOPCUAConnNotEstablished = errors.New("opcua connection not established")
)

Functions

func ErrNotConfigPointer

func ErrNotConfigPointer(iface interface{}) error

func ErrNotEnityPointer

func ErrNotEnityPointer(iface interface{}) error

func GetEnity

func GetEnity(ctx context.Context, provider, enityName string) (interface{}, error)

func Registrate

func Registrate(ctx context.Context) context.Context

func RegistrateEnity

func RegistrateEnity(ctx context.Context, provider, enityName string, options interface{}) (context.Context, error)

func RegistrateProvider

func RegistrateProvider(ctx context.Context, name string, p Provider) (context.Context, error)

Types

type Opcua

type Opcua struct {
	*providerswithmetrics.BaseProvidersWithMetrics
}

Opcua is a controlling structure for all Opcua and providers.

func Get

func Get(ctx context.Context) *Opcua

func NewOpcua

func NewOpcua(ctx context.Context) *Opcua

func (*Opcua) GetAllAliveHandlers

func (d *Opcua) GetAllAliveHandlers(out stats.MapCheckFunc) (stats.MapCheckFunc, error)

GetAllAliveHandlers collect all aliveHandlers for Opcua

func (*Opcua) GetAllMetrics

func (d *Opcua) GetAllMetrics(out stats.MapMetricsOptions) (stats.MapMetricsOptions, error)

GetAllMetrics collect all metrics for Opcua

func (*Opcua) GetAllReadyHandlers

func (d *Opcua) GetAllReadyHandlers(out stats.MapCheckFunc) (stats.MapCheckFunc, error)

GetAllReadyHandlers collect all readyHandlers for Opcua

func (*Opcua) GetProvider

func (d *Opcua) GetProvider(providerName string) (Provider, error)

GetProvider returns requested database provider. Return error if providers wasn't registered.

type Provider

type Provider interface {
	provider.IProvider
	provider.IEnityManager
	stats.IProviderMetrics
}

Provider is an interface every database provider should conform. Every provider can hold more than one connection.

func GetProvider

func GetProvider(ctx context.Context, name string) (Provider, error)