Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CentrifugoChannelParser ¶
type CentrifugoChannelParser interface {
ParseChannel(s, namespace string) (opcua.ChannelProvider, error)
}
CentrifugoChannelParser is a consumer contract modelling a Centrifugo channel parser.
type CentrifugoInfoProvider ¶
CentrifugoInfoProvider is a consumer contract modelling a Centrifugo server informations provider.
type DefaultCentrifugoChannelParser ¶
type DefaultCentrifugoChannelParser struct{}
DefaultCentrifugoChannelParser is the default implementation of CentrifugoChannelParser.
func (DefaultCentrifugoChannelParser) ParseChannel ¶
func (DefaultCentrifugoChannelParser) ParseChannel(s, namespace string) (opcua.ChannelProvider, error)
ParseChannel implements CentrifugoChannelParser.
type MonitorProvider ¶
type MonitorProvider interface { Read(ctx context.Context) (*opcua.ReadValues, error) State() gopcua.ConnState Subscribe(ctx context.Context, nsURI string, ch opcua.ChannelProvider, nodes []opcua.NodeIDProvider) error }
MonitorProvider is a consumer contract modelling an OPC-UA monitor.
type Proxy ¶
Proxy handles requests for the service.
func NewProxy ¶
func NewProxy(l log.Logger, m MonitorProvider, cp CentrifugoChannelParser, ci CentrifugoInfoProvider, ns string) *Proxy
NewProxy creates and returns a ready to use proxy.
Click to show internal directories.
Click to hide internal directories.