opcua

package
v0.0.0-...-c161377 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 10, 2020 License: MIT Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	BrowseDirectionEnum_name = map[int32]string{
		0: "FORWARD",
		1: "INVERSE",
		2: "BOTH",
		3: "INVALID",
	}
	BrowseDirectionEnum_value = map[string]int32{
		"FORWARD": 0,
		"INVERSE": 1,
		"BOTH":    2,
		"INVALID": 3,
	}
)

Enum value maps for BrowseDirectionEnum.

View Source
var (
	NodeClass_name = map[int32]string{
		0:   "UNSPECIFIED",
		1:   "OBJECT",
		2:   "VARIABLE",
		4:   "METHOD",
		8:   "OBJECT_TYPE",
		16:  "VARIABLE_TYPE",
		32:  "REFERENCE_TYPE",
		64:  "DATA_TYPE",
		128: "VIEW",
	}
	NodeClass_value = map[string]int32{
		"UNSPECIFIED":    0,
		"OBJECT":         1,
		"VARIABLE":       2,
		"METHOD":         4,
		"OBJECT_TYPE":    8,
		"VARIABLE_TYPE":  16,
		"REFERENCE_TYPE": 32,
		"DATA_TYPE":      64,
		"VIEW":           128,
	}
)

Enum value maps for NodeClass.

View Source
var (
	BrowseResultMask_name = map[int32]string{
		0:  "NONE",
		1:  "REFERENCE_TYPE_ID",
		2:  "IS_FORWARD",
		4:  "NODE_CLASS",
		8:  "BROWSE_NAME",
		16: "DISPLAY_NAME",
		32: "TYPE_DEFINITION",
		63: "ALL",
		3:  "REFERENCE_TYPE_INFO",
		60: "TARGET_INFO",
	}
	BrowseResultMask_value = map[string]int32{
		"NONE":                0,
		"REFERENCE_TYPE_ID":   1,
		"IS_FORWARD":          2,
		"NODE_CLASS":          4,
		"BROWSE_NAME":         8,
		"DISPLAY_NAME":        16,
		"TYPE_DEFINITION":     32,
		"ALL":                 63,
		"REFERENCE_TYPE_INFO": 3,
		"TARGET_INFO":         60,
	}
)

Enum value maps for BrowseResultMask.

View Source
var File_opcua_browse_proto protoreflect.FileDescriptor
View Source
var File_opcua_publish_proto protoreflect.FileDescriptor
View Source
var File_opcua_variant_proto protoreflect.FileDescriptor
View Source
var File_opcua_write_proto protoreflect.FileDescriptor

Functions

func RegisterBrowseServiceServer

func RegisterBrowseServiceServer(s *grpc.Server, srv BrowseServiceServer)

func RegisterWriteServiceServer

func RegisterWriteServiceServer(s *grpc.Server, srv WriteServiceServer)

func Start

func Start(config cloud.Config) (cloud.Device, error)

Start the device.

Types

type BooleanArray

type BooleanArray struct {
	Value []bool `protobuf:"varint,1,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BooleanArray) Descriptor deprecated

func (*BooleanArray) Descriptor() ([]byte, []int)

Deprecated: Use BooleanArray.ProtoReflect.Descriptor instead.

func (*BooleanArray) GetValue

func (x *BooleanArray) GetValue() []bool

func (*BooleanArray) ProtoMessage

func (*BooleanArray) ProtoMessage()

func (*BooleanArray) ProtoReflect

func (x *BooleanArray) ProtoReflect() protoreflect.Message

func (*BooleanArray) Reset

func (x *BooleanArray) Reset()

func (*BooleanArray) String

func (x *BooleanArray) String() string

type BrowseDescription

type BrowseDescription struct {
	NodeId          string              `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	BrowseDirection BrowseDirectionEnum `protobuf:"varint,2,opt,name=browseDirection,proto3,enum=opcua.BrowseDirectionEnum" json:"browseDirection,omitempty"`
	ReferenceTypeId string              `protobuf:"bytes,3,opt,name=referenceTypeId,proto3" json:"referenceTypeId,omitempty"`
	IncludeSubtypes bool                `protobuf:"varint,4,opt,name=includeSubtypes,proto3" json:"includeSubtypes,omitempty"`
	NodeClassMask   uint32              `protobuf:"varint,5,opt,name=nodeClassMask,proto3" json:"nodeClassMask,omitempty"`
	ResultMask      uint32              `protobuf:"varint,6,opt,name=resultMask,proto3" json:"resultMask,omitempty"`
	// contains filtered or unexported fields
}

BrowseDescription message

func (*BrowseDescription) Descriptor deprecated

func (*BrowseDescription) Descriptor() ([]byte, []int)

Deprecated: Use BrowseDescription.ProtoReflect.Descriptor instead.

func (*BrowseDescription) GetBrowseDirection

func (x *BrowseDescription) GetBrowseDirection() BrowseDirectionEnum

func (*BrowseDescription) GetIncludeSubtypes

func (x *BrowseDescription) GetIncludeSubtypes() bool

func (*BrowseDescription) GetNodeClassMask

func (x *BrowseDescription) GetNodeClassMask() uint32

func (*BrowseDescription) GetNodeId

func (x *BrowseDescription) GetNodeId() string

func (*BrowseDescription) GetReferenceTypeId

func (x *BrowseDescription) GetReferenceTypeId() string

func (*BrowseDescription) GetResultMask

func (x *BrowseDescription) GetResultMask() uint32

func (*BrowseDescription) ProtoMessage

func (*BrowseDescription) ProtoMessage()

func (*BrowseDescription) ProtoReflect

func (x *BrowseDescription) ProtoReflect() protoreflect.Message

func (*BrowseDescription) Reset

func (x *BrowseDescription) Reset()

func (*BrowseDescription) String

func (x *BrowseDescription) String() string

type BrowseDirectionEnum

type BrowseDirectionEnum int32
const (
	BrowseDirectionEnum_FORWARD BrowseDirectionEnum = 0
	BrowseDirectionEnum_INVERSE BrowseDirectionEnum = 1
	BrowseDirectionEnum_BOTH    BrowseDirectionEnum = 2
	BrowseDirectionEnum_INVALID BrowseDirectionEnum = 3
)

func (BrowseDirectionEnum) Descriptor

func (BrowseDirectionEnum) Enum

func (BrowseDirectionEnum) EnumDescriptor deprecated

func (BrowseDirectionEnum) EnumDescriptor() ([]byte, []int)

Deprecated: Use BrowseDirectionEnum.Descriptor instead.

func (BrowseDirectionEnum) Number

func (BrowseDirectionEnum) String

func (x BrowseDirectionEnum) String() string

func (BrowseDirectionEnum) Type

type BrowseNextRequest

type BrowseNextRequest struct {
	RequestHandle             uint32   `protobuf:"varint,1,opt,name=requestHandle,proto3" json:"requestHandle,omitempty"`
	ReleaseContinuationPoints bool     `protobuf:"varint,2,opt,name=releaseContinuationPoints,proto3" json:"releaseContinuationPoints,omitempty"`
	ContinuationPoints        [][]byte `protobuf:"bytes,3,rep,name=continuationPoints,proto3" json:"continuationPoints,omitempty"`
	// contains filtered or unexported fields
}

func (*BrowseNextRequest) Descriptor deprecated

func (*BrowseNextRequest) Descriptor() ([]byte, []int)

Deprecated: Use BrowseNextRequest.ProtoReflect.Descriptor instead.

func (*BrowseNextRequest) GetContinuationPoints

func (x *BrowseNextRequest) GetContinuationPoints() [][]byte

func (*BrowseNextRequest) GetReleaseContinuationPoints

func (x *BrowseNextRequest) GetReleaseContinuationPoints() bool

func (*BrowseNextRequest) GetRequestHandle

func (x *BrowseNextRequest) GetRequestHandle() uint32

func (*BrowseNextRequest) ProtoMessage

func (*BrowseNextRequest) ProtoMessage()

func (*BrowseNextRequest) ProtoReflect

func (x *BrowseNextRequest) ProtoReflect() protoreflect.Message

func (*BrowseNextRequest) Reset

func (x *BrowseNextRequest) Reset()

func (*BrowseNextRequest) String

func (x *BrowseNextRequest) String() string

type BrowseNextResponse

type BrowseNextResponse struct {
	RequestHandle uint32          `protobuf:"varint,1,opt,name=requestHandle,proto3" json:"requestHandle,omitempty"`
	StatusCode    uint32          `protobuf:"varint,2,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Results       []*BrowseResult `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*BrowseNextResponse) Descriptor deprecated

func (*BrowseNextResponse) Descriptor() ([]byte, []int)

Deprecated: Use BrowseNextResponse.ProtoReflect.Descriptor instead.

func (*BrowseNextResponse) GetRequestHandle

func (x *BrowseNextResponse) GetRequestHandle() uint32

func (*BrowseNextResponse) GetResults

func (x *BrowseNextResponse) GetResults() []*BrowseResult

func (*BrowseNextResponse) GetStatusCode

func (x *BrowseNextResponse) GetStatusCode() uint32

func (*BrowseNextResponse) ProtoMessage

func (*BrowseNextResponse) ProtoMessage()

func (*BrowseNextResponse) ProtoReflect

func (x *BrowseNextResponse) ProtoReflect() protoreflect.Message

func (*BrowseNextResponse) Reset

func (x *BrowseNextResponse) Reset()

func (*BrowseNextResponse) String

func (x *BrowseNextResponse) String() string

type BrowseRequest

type BrowseRequest struct {
	RequestHandle                 uint32               `protobuf:"varint,1,opt,name=requestHandle,proto3" json:"requestHandle,omitempty"`
	RequestedMaxReferencesPerNode uint32               `protobuf:"varint,2,opt,name=requestedMaxReferencesPerNode,proto3" json:"requestedMaxReferencesPerNode,omitempty"`
	NodesToBrowse                 []*BrowseDescription `protobuf:"bytes,3,rep,name=nodesToBrowse,proto3" json:"nodesToBrowse,omitempty"`
	// contains filtered or unexported fields
}

BrowseRequest message

func (*BrowseRequest) Descriptor deprecated

func (*BrowseRequest) Descriptor() ([]byte, []int)

Deprecated: Use BrowseRequest.ProtoReflect.Descriptor instead.

func (*BrowseRequest) GetNodesToBrowse

func (x *BrowseRequest) GetNodesToBrowse() []*BrowseDescription

func (*BrowseRequest) GetRequestHandle

func (x *BrowseRequest) GetRequestHandle() uint32

func (*BrowseRequest) GetRequestedMaxReferencesPerNode

func (x *BrowseRequest) GetRequestedMaxReferencesPerNode() uint32

func (*BrowseRequest) ProtoMessage

func (*BrowseRequest) ProtoMessage()

func (*BrowseRequest) ProtoReflect

func (x *BrowseRequest) ProtoReflect() protoreflect.Message

func (*BrowseRequest) Reset

func (x *BrowseRequest) Reset()

func (*BrowseRequest) String

func (x *BrowseRequest) String() string

type BrowseResponse

type BrowseResponse struct {
	RequestHandle uint32          `protobuf:"varint,1,opt,name=requestHandle,proto3" json:"requestHandle,omitempty"`
	StatusCode    uint32          `protobuf:"varint,2,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Results       []*BrowseResult `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

BrowseResponse message.

func (*BrowseResponse) Descriptor deprecated

func (*BrowseResponse) Descriptor() ([]byte, []int)

Deprecated: Use BrowseResponse.ProtoReflect.Descriptor instead.

func (*BrowseResponse) GetRequestHandle

func (x *BrowseResponse) GetRequestHandle() uint32

func (*BrowseResponse) GetResults

func (x *BrowseResponse) GetResults() []*BrowseResult

func (*BrowseResponse) GetStatusCode

func (x *BrowseResponse) GetStatusCode() uint32

func (*BrowseResponse) ProtoMessage

func (*BrowseResponse) ProtoMessage()

func (*BrowseResponse) ProtoReflect

func (x *BrowseResponse) ProtoReflect() protoreflect.Message

func (*BrowseResponse) Reset

func (x *BrowseResponse) Reset()

func (*BrowseResponse) String

func (x *BrowseResponse) String() string

type BrowseResult

type BrowseResult struct {
	StatusCode        uint32                  `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	ContinuationPoint []byte                  `protobuf:"bytes,2,opt,name=continuationPoint,proto3" json:"continuationPoint,omitempty"`
	References        []*ReferenceDescription `protobuf:"bytes,3,rep,name=references,proto3" json:"references,omitempty"`
	// contains filtered or unexported fields
}

BrowseResult message.

func (*BrowseResult) Descriptor deprecated

func (*BrowseResult) Descriptor() ([]byte, []int)

Deprecated: Use BrowseResult.ProtoReflect.Descriptor instead.

func (*BrowseResult) GetContinuationPoint

func (x *BrowseResult) GetContinuationPoint() []byte

func (*BrowseResult) GetReferences

func (x *BrowseResult) GetReferences() []*ReferenceDescription

func (*BrowseResult) GetStatusCode

func (x *BrowseResult) GetStatusCode() uint32

func (*BrowseResult) ProtoMessage

func (*BrowseResult) ProtoMessage()

func (*BrowseResult) ProtoReflect

func (x *BrowseResult) ProtoReflect() protoreflect.Message

func (*BrowseResult) Reset

func (x *BrowseResult) Reset()

func (*BrowseResult) String

func (x *BrowseResult) String() string

type BrowseResultMask

type BrowseResultMask int32
const (
	BrowseResultMask_NONE                BrowseResultMask = 0
	BrowseResultMask_REFERENCE_TYPE_ID   BrowseResultMask = 1
	BrowseResultMask_IS_FORWARD          BrowseResultMask = 2
	BrowseResultMask_NODE_CLASS          BrowseResultMask = 4
	BrowseResultMask_BROWSE_NAME         BrowseResultMask = 8
	BrowseResultMask_DISPLAY_NAME        BrowseResultMask = 16
	BrowseResultMask_TYPE_DEFINITION     BrowseResultMask = 32
	BrowseResultMask_ALL                 BrowseResultMask = 63
	BrowseResultMask_REFERENCE_TYPE_INFO BrowseResultMask = 3
	BrowseResultMask_TARGET_INFO         BrowseResultMask = 60
)

func (BrowseResultMask) Descriptor

func (BrowseResultMask) Enum

func (BrowseResultMask) EnumDescriptor deprecated

func (BrowseResultMask) EnumDescriptor() ([]byte, []int)

Deprecated: Use BrowseResultMask.Descriptor instead.

func (BrowseResultMask) Number

func (BrowseResultMask) String

func (x BrowseResultMask) String() string

func (BrowseResultMask) Type

type BrowseServiceClient

type BrowseServiceClient interface {
	Browse(ctx context.Context, in *BrowseRequest, opts ...grpc.CallOption) (*BrowseResponse, error)
	BrowseNext(ctx context.Context, in *BrowseNextRequest, opts ...grpc.CallOption) (*BrowseNextResponse, error)
}

BrowseServiceClient is the client API for BrowseService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type BrowseServiceServer

type BrowseServiceServer interface {
	Browse(context.Context, *BrowseRequest) (*BrowseResponse, error)
	BrowseNext(context.Context, *BrowseNextRequest) (*BrowseNextResponse, error)
}

BrowseServiceServer is the server API for BrowseService service.

type BytesArray

type BytesArray struct {
	Value [][]byte `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BytesArray) Descriptor deprecated

func (*BytesArray) Descriptor() ([]byte, []int)

Deprecated: Use BytesArray.ProtoReflect.Descriptor instead.

func (*BytesArray) GetValue

func (x *BytesArray) GetValue() [][]byte

func (*BytesArray) ProtoMessage

func (*BytesArray) ProtoMessage()

func (*BytesArray) ProtoReflect

func (x *BytesArray) ProtoReflect() protoreflect.Message

func (*BytesArray) Reset

func (x *BytesArray) Reset()

func (*BytesArray) String

func (x *BytesArray) String() string

type Config

type Config struct {
	Name             string        `yaml:"name"`
	Location         string        `yaml:"location,omitempty"`
	EndpointURL      string        `yaml:"endpointURL"`
	SecurityPolicy   string        `yaml:"securityPolicy,omitempty"`
	Username         string        `yaml:"username,omitempty"`
	Password         string        `yaml:"password,omitempty"`
	PublishInterval  float64       `yaml:"publishInterval"`
	SamplingInterval float64       `yaml:"samplingInterval"`
	QueueSize        uint32        `yaml:"queueSize"`
	PublishTTL       time.Duration `yaml:"publishTTL"`
	Metrics          []*Metric     `yaml:"metrics"`
}

Config ...

type DoubleArray

type DoubleArray struct {
	Value []float64 `protobuf:"fixed64,1,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*DoubleArray) Descriptor deprecated

func (*DoubleArray) Descriptor() ([]byte, []int)

Deprecated: Use DoubleArray.ProtoReflect.Descriptor instead.

func (*DoubleArray) GetValue

func (x *DoubleArray) GetValue() []float64

func (*DoubleArray) ProtoMessage

func (*DoubleArray) ProtoMessage()

func (*DoubleArray) ProtoReflect

func (x *DoubleArray) ProtoReflect() protoreflect.Message

func (*DoubleArray) Reset

func (x *DoubleArray) Reset()

func (*DoubleArray) String

func (x *DoubleArray) String() string

type FloatArray

type FloatArray struct {
	Value []float32 `protobuf:"fixed32,1,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FloatArray) Descriptor deprecated

func (*FloatArray) Descriptor() ([]byte, []int)

Deprecated: Use FloatArray.ProtoReflect.Descriptor instead.

func (*FloatArray) GetValue

func (x *FloatArray) GetValue() []float32

func (*FloatArray) ProtoMessage

func (*FloatArray) ProtoMessage()

func (*FloatArray) ProtoReflect

func (x *FloatArray) ProtoReflect() protoreflect.Message

func (*FloatArray) Reset

func (x *FloatArray) Reset()

func (*FloatArray) String

func (x *FloatArray) String() string

type Int32Array

type Int32Array struct {
	Value []int32 `protobuf:"zigzag32,1,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Int32Array) Descriptor deprecated

func (*Int32Array) Descriptor() ([]byte, []int)

Deprecated: Use Int32Array.ProtoReflect.Descriptor instead.

func (*Int32Array) GetValue

func (x *Int32Array) GetValue() []int32

func (*Int32Array) ProtoMessage

func (*Int32Array) ProtoMessage()

func (*Int32Array) ProtoReflect

func (x *Int32Array) ProtoReflect() protoreflect.Message

func (*Int32Array) Reset

func (x *Int32Array) Reset()

func (*Int32Array) String

func (x *Int32Array) String() string

type Int64Array

type Int64Array struct {
	Value []int64 `protobuf:"zigzag64,1,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Int64Array) Descriptor deprecated

func (*Int64Array) Descriptor() ([]byte, []int)

Deprecated: Use Int64Array.ProtoReflect.Descriptor instead.

func (*Int64Array) GetValue

func (x *Int64Array) GetValue() []int64

func (*Int64Array) ProtoMessage

func (*Int64Array) ProtoMessage()

func (*Int64Array) ProtoReflect

func (x *Int64Array) ProtoReflect() protoreflect.Message

func (*Int64Array) Reset

func (x *Int64Array) Reset()

func (*Int64Array) String

func (x *Int64Array) String() string

type Metric

type Metric struct {
	MetricID         string  `yaml:"metricID"`
	NodeID           string  `yaml:"nodeID"`
	AttributeID      uint32  `yaml:"attributeID,omitempty"`
	IndexRange       string  `yaml:"indexRange,omitempty"`
	SamplingInterval float64 `yaml:"samplingInterval,omitempty"`
	QueueSize        uint32  `yaml:"queueSize,omitempty"`
}

Metric ...

type MetricValue

type MetricValue struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value      *Variant `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	StatusCode uint32   `protobuf:"varint,3,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Timestamp  int64    `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

MetricValue message

func (*MetricValue) Descriptor deprecated

func (*MetricValue) Descriptor() ([]byte, []int)

Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.

func (*MetricValue) GetName

func (x *MetricValue) GetName() string

func (*MetricValue) GetStatusCode

func (x *MetricValue) GetStatusCode() uint32

func (*MetricValue) GetTimestamp

func (x *MetricValue) GetTimestamp() int64

func (*MetricValue) GetValue

func (x *MetricValue) GetValue() *Variant

func (*MetricValue) ProtoMessage

func (*MetricValue) ProtoMessage()

func (*MetricValue) ProtoReflect

func (x *MetricValue) ProtoReflect() protoreflect.Message

func (*MetricValue) Reset

func (x *MetricValue) Reset()

func (*MetricValue) String

func (x *MetricValue) String() string

type MonitoredItem

type MonitoredItem struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

MonitoredItem specifies the node that is monitored for data changes or events.

func NewMonitoredItem

func NewMonitoredItem(metricID string, monitoringMode ua.MonitoringMode, samplingInterval float64, queueSize uint32, ts time.Time) *MonitoredItem

NewMonitoredItem constructs a new MonitoredItem.

func (*MonitoredItem) Enqueue

func (mi *MonitoredItem) Enqueue(value *ua.DataValue)

Enqueue stores the current value of the item.

func (*MonitoredItem) Notifications

func (mi *MonitoredItem) Notifications(tn time.Time, max int) (notifications []*ua.DataValue, more bool)

Notifications returns the data values from the queue, up to given time and max count.

type NodeClass

type NodeClass int32
const (
	NodeClass_UNSPECIFIED    NodeClass = 0
	NodeClass_OBJECT         NodeClass = 1
	NodeClass_VARIABLE       NodeClass = 2
	NodeClass_METHOD         NodeClass = 4
	NodeClass_OBJECT_TYPE    NodeClass = 8
	NodeClass_VARIABLE_TYPE  NodeClass = 16
	NodeClass_REFERENCE_TYPE NodeClass = 32
	NodeClass_DATA_TYPE      NodeClass = 64
	NodeClass_VIEW           NodeClass = 128
)

func (NodeClass) Descriptor

func (NodeClass) Descriptor() protoreflect.EnumDescriptor

func (NodeClass) Enum

func (x NodeClass) Enum() *NodeClass

func (NodeClass) EnumDescriptor deprecated

func (NodeClass) EnumDescriptor() ([]byte, []int)

Deprecated: Use NodeClass.Descriptor instead.

func (NodeClass) Number

func (x NodeClass) Number() protoreflect.EnumNumber

func (NodeClass) String

func (x NodeClass) String() string

func (NodeClass) Type

type Null

type Null struct {
	// contains filtered or unexported fields
}

func (*Null) Descriptor deprecated

func (*Null) Descriptor() ([]byte, []int)

Deprecated: Use Null.ProtoReflect.Descriptor instead.

func (*Null) ProtoMessage

func (*Null) ProtoMessage()

func (*Null) ProtoReflect

func (x *Null) ProtoReflect() protoreflect.Message

func (*Null) Reset

func (x *Null) Reset()

func (*Null) String

func (x *Null) String() string

type PublishResponse

type PublishResponse struct {
	Timestamp int64          `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metrics   []*MetricValue `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

PublishResponse message

func (*PublishResponse) Descriptor deprecated

func (*PublishResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetMetrics

func (x *PublishResponse) GetMetrics() []*MetricValue

func (*PublishResponse) GetTimestamp

func (x *PublishResponse) GetTimestamp() int64

func (*PublishResponse) ProtoMessage

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect

func (x *PublishResponse) ProtoReflect() protoreflect.Message

func (*PublishResponse) Reset

func (x *PublishResponse) Reset()

func (*PublishResponse) String

func (x *PublishResponse) String() string

type ReferenceDescription

type ReferenceDescription struct {
	ReferenceTypeId string `protobuf:"bytes,1,opt,name=referenceTypeId,proto3" json:"referenceTypeId,omitempty"`
	IsForward       bool   `protobuf:"varint,2,opt,name=isForward,proto3" json:"isForward,omitempty"`
	NodeId          string `protobuf:"bytes,3,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	BrowseName      string `protobuf:"bytes,4,opt,name=browseName,proto3" json:"browseName,omitempty"`
	DisplayName     string `protobuf:"bytes,5,opt,name=displayName,proto3" json:"displayName,omitempty"`
	NodeClass       uint32 `protobuf:"varint,6,opt,name=nodeClass,proto3" json:"nodeClass,omitempty"`
	TypeDefinition  string `protobuf:"bytes,7,opt,name=typeDefinition,proto3" json:"typeDefinition,omitempty"`
	// contains filtered or unexported fields
}

ReferenceDescription message.

func (*ReferenceDescription) Descriptor deprecated

func (*ReferenceDescription) Descriptor() ([]byte, []int)

Deprecated: Use ReferenceDescription.ProtoReflect.Descriptor instead.

func (*ReferenceDescription) GetBrowseName

func (x *ReferenceDescription) GetBrowseName() string

func (*ReferenceDescription) GetDisplayName

func (x *ReferenceDescription) GetDisplayName() string

func (*ReferenceDescription) GetIsForward

func (x *ReferenceDescription) GetIsForward() bool

func (*ReferenceDescription) GetNodeClass

func (x *ReferenceDescription) GetNodeClass() uint32

func (*ReferenceDescription) GetNodeId

func (x *ReferenceDescription) GetNodeId() string

func (*ReferenceDescription) GetReferenceTypeId

func (x *ReferenceDescription) GetReferenceTypeId() string

func (*ReferenceDescription) GetTypeDefinition

func (x *ReferenceDescription) GetTypeDefinition() string

func (*ReferenceDescription) ProtoMessage

func (*ReferenceDescription) ProtoMessage()

func (*ReferenceDescription) ProtoReflect

func (x *ReferenceDescription) ProtoReflect() protoreflect.Message

func (*ReferenceDescription) Reset

func (x *ReferenceDescription) Reset()

func (*ReferenceDescription) String

func (x *ReferenceDescription) String() string

type StringArray

type StringArray struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringArray) Descriptor deprecated

func (*StringArray) Descriptor() ([]byte, []int)

Deprecated: Use StringArray.ProtoReflect.Descriptor instead.

func (*StringArray) GetValue

func (x *StringArray) GetValue() []string

func (*StringArray) ProtoMessage

func (*StringArray) ProtoMessage()

func (*StringArray) ProtoReflect

func (x *StringArray) ProtoReflect() protoreflect.Message

func (*StringArray) Reset

func (x *StringArray) Reset()

func (*StringArray) String

func (x *StringArray) String() string

type TimestampArray

type TimestampArray struct {
	Value []*timestamp.Timestamp `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampArray) Descriptor deprecated

func (*TimestampArray) Descriptor() ([]byte, []int)

Deprecated: Use TimestampArray.ProtoReflect.Descriptor instead.

func (*TimestampArray) GetValue

func (x *TimestampArray) GetValue() []*timestamp.Timestamp

func (*TimestampArray) ProtoMessage

func (*TimestampArray) ProtoMessage()

func (*TimestampArray) ProtoReflect

func (x *TimestampArray) ProtoReflect() protoreflect.Message

func (*TimestampArray) Reset

func (x *TimestampArray) Reset()

func (*TimestampArray) String

func (x *TimestampArray) String() string

type UInt32Array

type UInt32Array struct {
	Value []uint32 `protobuf:"varint,1,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UInt32Array) Descriptor deprecated

func (*UInt32Array) Descriptor() ([]byte, []int)

Deprecated: Use UInt32Array.ProtoReflect.Descriptor instead.

func (*UInt32Array) GetValue

func (x *UInt32Array) GetValue() []uint32

func (*UInt32Array) ProtoMessage

func (*UInt32Array) ProtoMessage()

func (*UInt32Array) ProtoReflect

func (x *UInt32Array) ProtoReflect() protoreflect.Message

func (*UInt32Array) Reset

func (x *UInt32Array) Reset()

func (*UInt32Array) String

func (x *UInt32Array) String() string

type UInt64Array

type UInt64Array struct {
	Value []uint64 `protobuf:"varint,1,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UInt64Array) Descriptor deprecated

func (*UInt64Array) Descriptor() ([]byte, []int)

Deprecated: Use UInt64Array.ProtoReflect.Descriptor instead.

func (*UInt64Array) GetValue

func (x *UInt64Array) GetValue() []uint64

func (*UInt64Array) ProtoMessage

func (*UInt64Array) ProtoMessage()

func (*UInt64Array) ProtoReflect

func (x *UInt64Array) ProtoReflect() protoreflect.Message

func (*UInt64Array) Reset

func (x *UInt64Array) Reset()

func (*UInt64Array) String

func (x *UInt64Array) String() string

type UnimplementedBrowseServiceServer

type UnimplementedBrowseServiceServer struct {
}

UnimplementedBrowseServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBrowseServiceServer) Browse

func (*UnimplementedBrowseServiceServer) BrowseNext

type UnimplementedWriteServiceServer

type UnimplementedWriteServiceServer struct {
}

UnimplementedWriteServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWriteServiceServer) Write

type Variant

type Variant struct {

	// Types that are assignable to Value:
	//	*Variant_Null
	//	*Variant_Boolean
	//	*Variant_SByte
	//	*Variant_Byte
	//	*Variant_Int16
	//	*Variant_UInt16
	//	*Variant_Int32
	//	*Variant_UInt32
	//	*Variant_Int64
	//	*Variant_UInt64
	//	*Variant_Float
	//	*Variant_Double
	//	*Variant_String_
	//	*Variant_DateTime
	//	*Variant_Guid
	//	*Variant_ByteString
	//	*Variant_BooleanArray
	//	*Variant_SByteArray
	//	*Variant_ByteArray
	//	*Variant_Int16Array
	//	*Variant_UInt16Array
	//	*Variant_Int32Array
	//	*Variant_UInt32Array
	//	*Variant_Int64Array
	//	*Variant_UInt64Array
	//	*Variant_FloatArray
	//	*Variant_DoubleArray
	//	*Variant_StringArray
	//	*Variant_DateTimeArray
	//	*Variant_GuidArray
	//	*Variant_ByteStringArray
	Value isVariant_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Variant message.

func (*Variant) Descriptor deprecated

func (*Variant) Descriptor() ([]byte, []int)

Deprecated: Use Variant.ProtoReflect.Descriptor instead.

func (*Variant) GetBoolean

func (x *Variant) GetBoolean() bool

func (*Variant) GetBooleanArray

func (x *Variant) GetBooleanArray() *BooleanArray

func (*Variant) GetByte

func (x *Variant) GetByte() uint32

func (*Variant) GetByteArray

func (x *Variant) GetByteArray() *UInt32Array

func (*Variant) GetByteString

func (x *Variant) GetByteString() []byte

func (*Variant) GetByteStringArray

func (x *Variant) GetByteStringArray() *BytesArray

func (*Variant) GetDateTime

func (x *Variant) GetDateTime() *timestamp.Timestamp

func (*Variant) GetDateTimeArray

func (x *Variant) GetDateTimeArray() *TimestampArray

func (*Variant) GetDouble

func (x *Variant) GetDouble() float64

func (*Variant) GetDoubleArray

func (x *Variant) GetDoubleArray() *DoubleArray

func (*Variant) GetFloat

func (x *Variant) GetFloat() float32

func (*Variant) GetFloatArray

func (x *Variant) GetFloatArray() *FloatArray

func (*Variant) GetGuid

func (x *Variant) GetGuid() []byte

func (*Variant) GetGuidArray

func (x *Variant) GetGuidArray() *BytesArray

func (*Variant) GetInt16

func (x *Variant) GetInt16() int32

func (*Variant) GetInt16Array

func (x *Variant) GetInt16Array() *Int32Array

func (*Variant) GetInt32

func (x *Variant) GetInt32() int32

func (*Variant) GetInt32Array

func (x *Variant) GetInt32Array() *Int32Array

func (*Variant) GetInt64

func (x *Variant) GetInt64() int64

func (*Variant) GetInt64Array

func (x *Variant) GetInt64Array() *Int64Array

func (*Variant) GetNull

func (x *Variant) GetNull() *Null

func (*Variant) GetSByte

func (x *Variant) GetSByte() int32

func (*Variant) GetSByteArray

func (x *Variant) GetSByteArray() *Int32Array

func (*Variant) GetStringArray

func (x *Variant) GetStringArray() *StringArray

func (*Variant) GetString_

func (x *Variant) GetString_() string

func (*Variant) GetUInt16

func (x *Variant) GetUInt16() uint32

func (*Variant) GetUInt16Array

func (x *Variant) GetUInt16Array() *UInt32Array

func (*Variant) GetUInt32

func (x *Variant) GetUInt32() uint32

func (*Variant) GetUInt32Array

func (x *Variant) GetUInt32Array() *UInt32Array

func (*Variant) GetUInt64

func (x *Variant) GetUInt64() uint64

func (*Variant) GetUInt64Array

func (x *Variant) GetUInt64Array() *UInt64Array

func (*Variant) GetValue

func (m *Variant) GetValue() isVariant_Value

func (*Variant) ProtoMessage

func (*Variant) ProtoMessage()

func (*Variant) ProtoReflect

func (x *Variant) ProtoReflect() protoreflect.Message

func (*Variant) Reset

func (x *Variant) Reset()

func (*Variant) String

func (x *Variant) String() string

type Variant_Boolean

type Variant_Boolean struct {
	Boolean bool `protobuf:"varint,1,opt,name=Boolean,proto3,oneof"`
}

type Variant_BooleanArray

type Variant_BooleanArray struct {
	BooleanArray *BooleanArray `protobuf:"bytes,51,opt,name=BooleanArray,proto3,oneof"`
}

type Variant_Byte

type Variant_Byte struct {
	Byte uint32 `protobuf:"varint,3,opt,name=Byte,proto3,oneof"`
}

type Variant_ByteArray

type Variant_ByteArray struct {
	ByteArray *UInt32Array `protobuf:"bytes,53,opt,name=ByteArray,proto3,oneof"`
}

type Variant_ByteString

type Variant_ByteString struct {
	ByteString []byte `protobuf:"bytes,15,opt,name=ByteString,proto3,oneof"`
}

type Variant_ByteStringArray

type Variant_ByteStringArray struct {
	ByteStringArray *BytesArray `protobuf:"bytes,65,opt,name=ByteStringArray,proto3,oneof"`
}

type Variant_DateTime

type Variant_DateTime struct {
	DateTime *timestamp.Timestamp `protobuf:"bytes,13,opt,name=DateTime,proto3,oneof"`
}

type Variant_DateTimeArray

type Variant_DateTimeArray struct {
	DateTimeArray *TimestampArray `protobuf:"bytes,63,opt,name=DateTimeArray,proto3,oneof"`
}

type Variant_Double

type Variant_Double struct {
	Double float64 `protobuf:"fixed64,11,opt,name=Double,proto3,oneof"`
}

type Variant_DoubleArray

type Variant_DoubleArray struct {
	DoubleArray *DoubleArray `protobuf:"bytes,61,opt,name=DoubleArray,proto3,oneof"`
}

type Variant_Float

type Variant_Float struct {
	Float float32 `protobuf:"fixed32,10,opt,name=Float,proto3,oneof"`
}

type Variant_FloatArray

type Variant_FloatArray struct {
	FloatArray *FloatArray `protobuf:"bytes,60,opt,name=FloatArray,proto3,oneof"`
}

type Variant_Guid

type Variant_Guid struct {
	Guid []byte `protobuf:"bytes,14,opt,name=Guid,proto3,oneof"`
}

type Variant_GuidArray

type Variant_GuidArray struct {
	GuidArray *BytesArray `protobuf:"bytes,64,opt,name=GuidArray,proto3,oneof"`
}

type Variant_Int16

type Variant_Int16 struct {
	Int16 int32 `protobuf:"zigzag32,4,opt,name=Int16,proto3,oneof"`
}

type Variant_Int16Array

type Variant_Int16Array struct {
	Int16Array *Int32Array `protobuf:"bytes,54,opt,name=Int16Array,proto3,oneof"`
}

type Variant_Int32

type Variant_Int32 struct {
	Int32 int32 `protobuf:"zigzag32,6,opt,name=Int32,proto3,oneof"`
}

type Variant_Int32Array

type Variant_Int32Array struct {
	Int32Array *Int32Array `protobuf:"bytes,56,opt,name=Int32Array,proto3,oneof"`
}

type Variant_Int64

type Variant_Int64 struct {
	Int64 int64 `protobuf:"zigzag64,8,opt,name=Int64,proto3,oneof"`
}

type Variant_Int64Array

type Variant_Int64Array struct {
	Int64Array *Int64Array `protobuf:"bytes,58,opt,name=Int64Array,proto3,oneof"`
}

type Variant_Null

type Variant_Null struct {
	Null *Null `protobuf:"bytes,127,opt,name=Null,proto3,oneof"`
}

type Variant_SByte

type Variant_SByte struct {
	SByte int32 `protobuf:"zigzag32,2,opt,name=SByte,proto3,oneof"`
}

type Variant_SByteArray

type Variant_SByteArray struct {
	SByteArray *Int32Array `protobuf:"bytes,52,opt,name=SByteArray,proto3,oneof"`
}

type Variant_StringArray

type Variant_StringArray struct {
	StringArray *StringArray `protobuf:"bytes,62,opt,name=StringArray,proto3,oneof"`
}

type Variant_String_

type Variant_String_ struct {
	String_ string `protobuf:"bytes,12,opt,name=String,proto3,oneof"`
}

type Variant_UInt16

type Variant_UInt16 struct {
	UInt16 uint32 `protobuf:"varint,5,opt,name=UInt16,proto3,oneof"`
}

type Variant_UInt16Array

type Variant_UInt16Array struct {
	UInt16Array *UInt32Array `protobuf:"bytes,55,opt,name=UInt16Array,proto3,oneof"`
}

type Variant_UInt32

type Variant_UInt32 struct {
	UInt32 uint32 `protobuf:"varint,7,opt,name=UInt32,proto3,oneof"`
}

type Variant_UInt32Array

type Variant_UInt32Array struct {
	UInt32Array *UInt32Array `protobuf:"bytes,57,opt,name=UInt32Array,proto3,oneof"`
}

type Variant_UInt64

type Variant_UInt64 struct {
	UInt64 uint64 `protobuf:"varint,9,opt,name=UInt64,proto3,oneof"`
}

type Variant_UInt64Array

type Variant_UInt64Array struct {
	UInt64Array *UInt64Array `protobuf:"bytes,59,opt,name=UInt64Array,proto3,oneof"`
}

type WriteRequest

type WriteRequest struct {
	RequestHandle uint32        `protobuf:"varint,1,opt,name=requestHandle,proto3" json:"requestHandle,omitempty"`
	NodesToWrite  []*WriteValue `protobuf:"bytes,2,rep,name=nodesToWrite,proto3" json:"nodesToWrite,omitempty"`
	// contains filtered or unexported fields
}

WriteRequest message

func (*WriteRequest) Descriptor deprecated

func (*WriteRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetNodesToWrite

func (x *WriteRequest) GetNodesToWrite() []*WriteValue

func (*WriteRequest) GetRequestHandle

func (x *WriteRequest) GetRequestHandle() uint32

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect

func (x *WriteRequest) ProtoReflect() protoreflect.Message

func (*WriteRequest) Reset

func (x *WriteRequest) Reset()

func (*WriteRequest) String

func (x *WriteRequest) String() string

type WriteResponse

type WriteResponse struct {
	RequestHandle uint32   `protobuf:"varint,1,opt,name=requestHandle,proto3" json:"requestHandle,omitempty"`
	StatusCode    uint32   `protobuf:"varint,2,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Results       []uint32 `protobuf:"varint,3,rep,packed,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

WriteResponse message.

func (*WriteResponse) Descriptor deprecated

func (*WriteResponse) Descriptor() ([]byte, []int)

Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.

func (*WriteResponse) GetRequestHandle

func (x *WriteResponse) GetRequestHandle() uint32

func (*WriteResponse) GetResults

func (x *WriteResponse) GetResults() []uint32

func (*WriteResponse) GetStatusCode

func (x *WriteResponse) GetStatusCode() uint32

func (*WriteResponse) ProtoMessage

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) ProtoReflect

func (x *WriteResponse) ProtoReflect() protoreflect.Message

func (*WriteResponse) Reset

func (x *WriteResponse) Reset()

func (*WriteResponse) String

func (x *WriteResponse) String() string

type WriteServiceClient

type WriteServiceClient interface {
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
}

WriteServiceClient is the client API for WriteService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type WriteServiceServer

type WriteServiceServer interface {
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
}

WriteServiceServer is the server API for WriteService service.

type WriteValue

type WriteValue struct {
	NodeId      string   `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	AttributeId uint32   `protobuf:"varint,2,opt,name=attributeId,proto3" json:"attributeId,omitempty"`
	IndexRange  string   `protobuf:"bytes,3,opt,name=indexRange,proto3" json:"indexRange,omitempty"`
	Value       *Variant `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

WriteValue message.

func (*WriteValue) Descriptor deprecated

func (*WriteValue) Descriptor() ([]byte, []int)

Deprecated: Use WriteValue.ProtoReflect.Descriptor instead.

func (*WriteValue) GetAttributeId

func (x *WriteValue) GetAttributeId() uint32

func (*WriteValue) GetIndexRange

func (x *WriteValue) GetIndexRange() string

func (*WriteValue) GetNodeId

func (x *WriteValue) GetNodeId() string

func (*WriteValue) GetValue

func (x *WriteValue) GetValue() *Variant

func (*WriteValue) ProtoMessage

func (*WriteValue) ProtoMessage()

func (*WriteValue) ProtoReflect

func (x *WriteValue) ProtoReflect() protoreflect.Message

func (*WriteValue) Reset

func (x *WriteValue) Reset()

func (*WriteValue) String

func (x *WriteValue) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL