__

package
v0.0.0-...-bc93099 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2024 License: MIT Imports: 8 Imported by: 0

README

(C) 2023 Ford Motor Company

gRPC

The gRPC implementation is payload compatible with the Websocket and MQTT implementations.

The following command builds the VISSv2.proto file:

protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative VISSv2.proto

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResponseStatus_name = map[int32]string{
		0: "SUCCESS",
		1: "ERROR",
	}
	ResponseStatus_value = map[string]int32{
		"SUCCESS": 0,
		"ERROR":   1,
	}
)

Enum value maps for ResponseStatus.

View Source 
var (
	SubscribeResponseType_name = map[int32]string{
		0: "RESPONSE",
		1: "EVENT",
	}
	SubscribeResponseType_value = map[string]int32{
		"RESPONSE": 0,
		"EVENT":    1,
	}
)

Enum value maps for SubscribeResponseType.

View Source 
var (
	FilterExpressions_FilterExpression_FilterType_name = map[int32]string{
		0: "PATHS",
		1: "TIMEBASED",
		2: "RANGE",
		3: "CHANGE",
		4: "CURVELOG",
		5: "HISTORY",
		6: "STATIC_METADATA",
		7: "DYNAMIC_METADATA",
	}
	FilterExpressions_FilterExpression_FilterType_value = map[string]int32{
		"PATHS":            0,
		"TIMEBASED":        1,
		"RANGE":            2,
		"CHANGE":           3,
		"CURVELOG":         4,
		"HISTORY":          5,
		"STATIC_METADATA":  6,
		"DYNAMIC_METADATA": 7,
	}
)

Enum value maps for FilterExpressions_FilterExpression_FilterType.

View Source 
var File_VISSv2_proto protoreflect.FileDescriptor
View Source 
var VISSv2_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcProtobufMessages.VISSv2",
	HandlerType: (*VISSv2Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRequest",
			Handler:    _VISSv2_GetRequest_Handler,
		},
		{
			MethodName: "SetRequest",
			Handler:    _VISSv2_SetRequest_Handler,
		},
		{
			MethodName: "UnsubscribeRequest",
			Handler:    _VISSv2_UnsubscribeRequest_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeRequest",
			Handler:       _VISSv2_SubscribeRequest_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "VISSv2.proto",
}

VISSv2_ServiceDesc is the grpc.ServiceDesc for VISSv2 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterVISSv2Server 

func RegisterVISSv2Server(s grpc.ServiceRegistrar, srv VISSv2Server)

Types

type DataPackages 

type DataPackages struct {
	Data []*DataPackages_DataPackage `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*DataPackages) Descriptor deprecated 

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

Deprecated: Use DataPackages.ProtoReflect.Descriptor instead.

func (*DataPackages) GetData 

func (x *DataPackages) GetData() []*DataPackages_DataPackage

func (*DataPackages) ProtoMessage 

func (*DataPackages) ProtoMessage()

func (*DataPackages) ProtoReflect 

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

func (*DataPackages) Reset 

func (x *DataPackages) Reset()

func (*DataPackages) String 

func (x *DataPackages) String() string

type DataPackages_DataPackage 

type DataPackages_DataPackage struct {
	Path  *string                               `protobuf:"bytes,1,opt,name=Path,proto3,oneof" json:"Path,omitempty"`
	PathC *int32                                `protobuf:"varint,2,opt,name=PathC,proto3,oneof" json:"PathC,omitempty"`
	Dp    []*DataPackages_DataPackage_DataPoint `protobuf:"bytes,3,rep,name=Dp,proto3" json:"Dp,omitempty"`
	// contains filtered or unexported fields
}

func (*DataPackages_DataPackage) Descriptor deprecated 

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

Deprecated: Use DataPackages_DataPackage.ProtoReflect.Descriptor instead.

func (*DataPackages_DataPackage) GetDp 

func (x *DataPackages_DataPackage) GetDp() []*DataPackages_DataPackage_DataPoint

func (*DataPackages_DataPackage) GetPath 

func (x *DataPackages_DataPackage) GetPath() string

func (*DataPackages_DataPackage) GetPathC 

func (x *DataPackages_DataPackage) GetPathC() int32

func (*DataPackages_DataPackage) ProtoMessage 

func (*DataPackages_DataPackage) ProtoMessage()

func (*DataPackages_DataPackage) ProtoReflect 

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

func (*DataPackages_DataPackage) Reset 

func (x *DataPackages_DataPackage) Reset()

func (*DataPackages_DataPackage) String 

func (x *DataPackages_DataPackage) String() string

type DataPackages_DataPackage_DataPoint 

type DataPackages_DataPackage_DataPoint struct {
	Value string  `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	Ts    *string `protobuf:"bytes,2,opt,name=Ts,proto3,oneof" json:"Ts,omitempty"`
	TsC   *int32  `protobuf:"varint,3,opt,name=TsC,proto3,oneof" json:"TsC,omitempty"`
	// contains filtered or unexported fields
}

func (*DataPackages_DataPackage_DataPoint) Descriptor deprecated 

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

Deprecated: Use DataPackages_DataPackage_DataPoint.ProtoReflect.Descriptor instead.

func (*DataPackages_DataPackage_DataPoint) GetTs 

func (x *DataPackages_DataPackage_DataPoint) GetTs() string

func (*DataPackages_DataPackage_DataPoint) GetTsC 

func (x *DataPackages_DataPackage_DataPoint) GetTsC() int32

func (*DataPackages_DataPackage_DataPoint) GetValue 

func (x *DataPackages_DataPackage_DataPoint) GetValue() string

func (*DataPackages_DataPackage_DataPoint) ProtoMessage 

func (*DataPackages_DataPackage_DataPoint) ProtoMessage()

func (*DataPackages_DataPackage_DataPoint) ProtoReflect 

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

func (*DataPackages_DataPackage_DataPoint) Reset 

func (x *DataPackages_DataPackage_DataPoint) Reset()

func (*DataPackages_DataPackage_DataPoint) String 

func (x *DataPackages_DataPackage_DataPoint) String() string

type ErrorResponseMessage 

type ErrorResponseMessage struct {
	Number  string  `protobuf:"bytes,1,opt,name=Number,proto3" json:"Number,omitempty"`
	Reason  *string `protobuf:"bytes,2,opt,name=Reason,proto3,oneof" json:"Reason,omitempty"`
	Message *string `protobuf:"bytes,3,opt,name=Message,proto3,oneof" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorResponseMessage) Descriptor deprecated 

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

Deprecated: Use ErrorResponseMessage.ProtoReflect.Descriptor instead.

func (*ErrorResponseMessage) GetMessage 

func (x *ErrorResponseMessage) GetMessage() string

func (*ErrorResponseMessage) GetNumber 

func (x *ErrorResponseMessage) GetNumber() string

func (*ErrorResponseMessage) GetReason 

func (x *ErrorResponseMessage) GetReason() string

func (*ErrorResponseMessage) ProtoMessage 

func (*ErrorResponseMessage) ProtoMessage()

func (*ErrorResponseMessage) ProtoReflect 

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

func (*ErrorResponseMessage) Reset 

func (x *ErrorResponseMessage) Reset()

func (*ErrorResponseMessage) String 

func (x *ErrorResponseMessage) String() string

type FilterExpressions 

type FilterExpressions struct {
	FilterExp []*FilterExpressions_FilterExpression `protobuf:"bytes,1,rep,name=FilterExp,proto3" json:"FilterExp,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions) Descriptor deprecated 

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

Deprecated: Use FilterExpressions.ProtoReflect.Descriptor instead.

func (*FilterExpressions) GetFilterExp 

func (x *FilterExpressions) GetFilterExp() []*FilterExpressions_FilterExpression

func (*FilterExpressions) ProtoMessage 

func (*FilterExpressions) ProtoMessage()

func (*FilterExpressions) ProtoReflect 

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

func (*FilterExpressions) Reset 

func (x *FilterExpressions) Reset()

func (*FilterExpressions) String 

func (x *FilterExpressions) String() string

type FilterExpressions_FilterExpression 

type FilterExpressions_FilterExpression struct {
	FType FilterExpressions_FilterExpression_FilterType   `` /* 136-byte string literal not displayed */
	Value *FilterExpressions_FilterExpression_FilterValue `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression) GetFType 

func (x *FilterExpressions_FilterExpression) GetFType() FilterExpressions_FilterExpression_FilterType

func (*FilterExpressions_FilterExpression) GetValue 

func (x *FilterExpressions_FilterExpression) GetValue() *FilterExpressions_FilterExpression_FilterValue

func (*FilterExpressions_FilterExpression) ProtoMessage 

func (*FilterExpressions_FilterExpression) ProtoMessage()

func (*FilterExpressions_FilterExpression) ProtoReflect 

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

func (*FilterExpressions_FilterExpression) Reset 

func (x *FilterExpressions_FilterExpression) Reset()

func (*FilterExpressions_FilterExpression) String 

func (x *FilterExpressions_FilterExpression) String() string

type FilterExpressions_FilterExpression_FilterType 

type FilterExpressions_FilterExpression_FilterType int32
const (
	FilterExpressions_FilterExpression_PATHS            FilterExpressions_FilterExpression_FilterType = 0
	FilterExpressions_FilterExpression_TIMEBASED        FilterExpressions_FilterExpression_FilterType = 1
	FilterExpressions_FilterExpression_RANGE            FilterExpressions_FilterExpression_FilterType = 2
	FilterExpressions_FilterExpression_CHANGE           FilterExpressions_FilterExpression_FilterType = 3
	FilterExpressions_FilterExpression_CURVELOG         FilterExpressions_FilterExpression_FilterType = 4
	FilterExpressions_FilterExpression_HISTORY          FilterExpressions_FilterExpression_FilterType = 5
	FilterExpressions_FilterExpression_STATIC_METADATA  FilterExpressions_FilterExpression_FilterType = 6
	FilterExpressions_FilterExpression_DYNAMIC_METADATA FilterExpressions_FilterExpression_FilterType = 7
)

func (FilterExpressions_FilterExpression_FilterType) Descriptor 

func (FilterExpressions_FilterExpression_FilterType) Descriptor() protoreflect.EnumDescriptor

func (FilterExpressions_FilterExpression_FilterType) Enum 

func (x FilterExpressions_FilterExpression_FilterType) Enum() *FilterExpressions_FilterExpression_FilterType

func (FilterExpressions_FilterExpression_FilterType) EnumDescriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterType.Descriptor instead.

func (FilterExpressions_FilterExpression_FilterType) Number 

func (x FilterExpressions_FilterExpression_FilterType) Number() protoreflect.EnumNumber

func (FilterExpressions_FilterExpression_FilterType) String 

func (x FilterExpressions_FilterExpression_FilterType) String() string

func (FilterExpressions_FilterExpression_FilterType) Type 

func (FilterExpressions_FilterExpression_FilterType) Type() protoreflect.EnumType

type FilterExpressions_FilterExpression_FilterValue 

type FilterExpressions_FilterExpression_FilterValue struct {
	ValuePaths           *FilterExpressions_FilterExpression_FilterValue_PathsValue           `protobuf:"bytes,1,opt,name=ValuePaths,proto3,oneof" json:"ValuePaths,omitempty"`
	ValueTimebased       *FilterExpressions_FilterExpression_FilterValue_TimebasedValue       `protobuf:"bytes,2,opt,name=ValueTimebased,proto3,oneof" json:"ValueTimebased,omitempty"`
	ValueRange           []*FilterExpressions_FilterExpression_FilterValue_RangeValue         `protobuf:"bytes,3,rep,name=ValueRange,proto3" json:"ValueRange,omitempty"`
	ValueChange          *FilterExpressions_FilterExpression_FilterValue_ChangeValue          `protobuf:"bytes,4,opt,name=ValueChange,proto3,oneof" json:"ValueChange,omitempty"`
	ValueCurvelog        *FilterExpressions_FilterExpression_FilterValue_CurvelogValue        `protobuf:"bytes,5,opt,name=ValueCurvelog,proto3,oneof" json:"ValueCurvelog,omitempty"`
	ValueHistory         *FilterExpressions_FilterExpression_FilterValue_HistoryValue         `protobuf:"bytes,6,opt,name=ValueHistory,proto3,oneof" json:"ValueHistory,omitempty"`
	ValueStaticMetadata  *FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue  `protobuf:"bytes,7,opt,name=ValueStaticMetadata,proto3,oneof" json:"ValueStaticMetadata,omitempty"`
	ValueDynamicMetadata *FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue `protobuf:"bytes,8,opt,name=ValueDynamicMetadata,proto3,oneof" json:"ValueDynamicMetadata,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue) GetValueChange 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValueChange() *FilterExpressions_FilterExpression_FilterValue_ChangeValue

func (*FilterExpressions_FilterExpression_FilterValue) GetValueCurvelog 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValueCurvelog() *FilterExpressions_FilterExpression_FilterValue_CurvelogValue

func (*FilterExpressions_FilterExpression_FilterValue) GetValueDynamicMetadata 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValueDynamicMetadata() *FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue

func (*FilterExpressions_FilterExpression_FilterValue) GetValueHistory 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValueHistory() *FilterExpressions_FilterExpression_FilterValue_HistoryValue

func (*FilterExpressions_FilterExpression_FilterValue) GetValuePaths 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValuePaths() *FilterExpressions_FilterExpression_FilterValue_PathsValue

func (*FilterExpressions_FilterExpression_FilterValue) GetValueRange 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValueRange() []*FilterExpressions_FilterExpression_FilterValue_RangeValue

func (*FilterExpressions_FilterExpression_FilterValue) GetValueStaticMetadata 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValueStaticMetadata() *FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue

func (*FilterExpressions_FilterExpression_FilterValue) GetValueTimebased 

func (x *FilterExpressions_FilterExpression_FilterValue) GetValueTimebased() *FilterExpressions_FilterExpression_FilterValue_TimebasedValue

func (*FilterExpressions_FilterExpression_FilterValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue) String() string

type FilterExpressions_FilterExpression_FilterValue_ChangeValue 

type FilterExpressions_FilterExpression_FilterValue_ChangeValue struct {
	LogicOperator string `protobuf:"bytes,1,opt,name=LogicOperator,proto3" json:"LogicOperator,omitempty"`
	Diff          string `protobuf:"bytes,2,opt,name=Diff,proto3" json:"Diff,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_ChangeValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) GetDiff 

func (x *FilterExpressions_FilterExpression_FilterValue_ChangeValue) GetDiff() string

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) GetLogicOperator 

func (x *FilterExpressions_FilterExpression_FilterValue_ChangeValue) GetLogicOperator() string

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_ChangeValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_ChangeValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_ChangeValue) String() string

type FilterExpressions_FilterExpression_FilterValue_CurvelogValue 

type FilterExpressions_FilterExpression_FilterValue_CurvelogValue struct {
	MaxErr  string `protobuf:"bytes,1,opt,name=MaxErr,proto3" json:"MaxErr,omitempty"`
	BufSize string `protobuf:"bytes,2,opt,name=BufSize,proto3" json:"BufSize,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_CurvelogValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) GetBufSize 

func (x *FilterExpressions_FilterExpression_FilterValue_CurvelogValue) GetBufSize() string

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) GetMaxErr 

func (x *FilterExpressions_FilterExpression_FilterValue_CurvelogValue) GetMaxErr() string

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_CurvelogValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_CurvelogValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_CurvelogValue) String() string

type FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue 

type FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue struct {
	MetadataDomain string `protobuf:"bytes,1,opt,name=MetadataDomain,proto3" json:"MetadataDomain,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) GetMetadataDomain 

func (x *FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) GetMetadataDomain() string

func (*FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_DynamicMetadataValue) String() string

type FilterExpressions_FilterExpression_FilterValue_HistoryValue 

type FilterExpressions_FilterExpression_FilterValue_HistoryValue struct {
	TimePeriod string `protobuf:"bytes,1,opt,name=TimePeriod,proto3" json:"TimePeriod,omitempty"` //ISO8601 period expression
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue_HistoryValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_HistoryValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_HistoryValue) GetTimePeriod 

func (x *FilterExpressions_FilterExpression_FilterValue_HistoryValue) GetTimePeriod() string

func (*FilterExpressions_FilterExpression_FilterValue_HistoryValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_HistoryValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_HistoryValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_HistoryValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_HistoryValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_HistoryValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_HistoryValue) String() string

type FilterExpressions_FilterExpression_FilterValue_PathsValue 

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

func (*FilterExpressions_FilterExpression_FilterValue_PathsValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_PathsValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_PathsValue) GetRelativePath 

func (x *FilterExpressions_FilterExpression_FilterValue_PathsValue) GetRelativePath() []string

func (*FilterExpressions_FilterExpression_FilterValue_PathsValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_PathsValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_PathsValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_PathsValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_PathsValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_PathsValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_PathsValue) String() string

type FilterExpressions_FilterExpression_FilterValue_RangeValue 

type FilterExpressions_FilterExpression_FilterValue_RangeValue struct {
	LogicOperator string `protobuf:"bytes,1,opt,name=LogicOperator,proto3" json:"LogicOperator,omitempty"`
	Boundary      string `protobuf:"bytes,2,opt,name=Boundary,proto3" json:"Boundary,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_RangeValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) GetBoundary 

func (x *FilterExpressions_FilterExpression_FilterValue_RangeValue) GetBoundary() string

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) GetLogicOperator 

func (x *FilterExpressions_FilterExpression_FilterValue_RangeValue) GetLogicOperator() string

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_RangeValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_RangeValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_RangeValue) String() string

type FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue 

type FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue struct {
	Tree string `protobuf:"bytes,1,opt,name=Tree,proto3" json:"Tree,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) GetTree 

func (x *FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) GetTree() string

func (*FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_StaticMetadataValue) String() string

type FilterExpressions_FilterExpression_FilterValue_TimebasedValue 

type FilterExpressions_FilterExpression_FilterValue_TimebasedValue struct {
	Period string `protobuf:"bytes,1,opt,name=Period,proto3" json:"Period,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpressions_FilterExpression_FilterValue_TimebasedValue) Descriptor deprecated 

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

Deprecated: Use FilterExpressions_FilterExpression_FilterValue_TimebasedValue.ProtoReflect.Descriptor instead.

func (*FilterExpressions_FilterExpression_FilterValue_TimebasedValue) GetPeriod 

func (x *FilterExpressions_FilterExpression_FilterValue_TimebasedValue) GetPeriod() string

func (*FilterExpressions_FilterExpression_FilterValue_TimebasedValue) ProtoMessage 

func (*FilterExpressions_FilterExpression_FilterValue_TimebasedValue) ProtoMessage()

func (*FilterExpressions_FilterExpression_FilterValue_TimebasedValue) ProtoReflect 

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

func (*FilterExpressions_FilterExpression_FilterValue_TimebasedValue) Reset 

func (x *FilterExpressions_FilterExpression_FilterValue_TimebasedValue) Reset()

func (*FilterExpressions_FilterExpression_FilterValue_TimebasedValue) String 

func (x *FilterExpressions_FilterExpression_FilterValue_TimebasedValue) String() string

type GetRequestMessage 

type GetRequestMessage struct {
	Path          string             `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Filter        *FilterExpressions `protobuf:"bytes,2,opt,name=Filter,proto3,oneof" json:"Filter,omitempty"`
	Authorization *string            `protobuf:"bytes,3,opt,name=Authorization,proto3,oneof" json:"Authorization,omitempty"`
	RequestId     *string            `protobuf:"bytes,4,opt,name=RequestId,proto3,oneof" json:"RequestId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequestMessage) Descriptor deprecated 

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

Deprecated: Use GetRequestMessage.ProtoReflect.Descriptor instead.

func (*GetRequestMessage) GetAuthorization 

func (x *GetRequestMessage) GetAuthorization() string

func (*GetRequestMessage) GetFilter 

func (x *GetRequestMessage) GetFilter() *FilterExpressions

func (*GetRequestMessage) GetPath 

func (x *GetRequestMessage) GetPath() string

func (*GetRequestMessage) GetRequestId 

func (x *GetRequestMessage) GetRequestId() string

func (*GetRequestMessage) ProtoMessage 

func (*GetRequestMessage) ProtoMessage()

func (*GetRequestMessage) ProtoReflect 

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

func (*GetRequestMessage) Reset 

func (x *GetRequestMessage) Reset()

func (*GetRequestMessage) String 

func (x *GetRequestMessage) String() string

type GetResponseMessage 

type GetResponseMessage struct {
	Status          ResponseStatus                             `protobuf:"varint,1,opt,name=Status,proto3,enum=grpcProtobufMessages.ResponseStatus" json:"Status,omitempty"`
	SuccessResponse *GetResponseMessage_SuccessResponseMessage `protobuf:"bytes,2,opt,name=SuccessResponse,proto3,oneof" json:"SuccessResponse,omitempty"`
	ErrorResponse   *ErrorResponseMessage                      `protobuf:"bytes,3,opt,name=ErrorResponse,proto3,oneof" json:"ErrorResponse,omitempty"`
	RequestId       *string                                    `protobuf:"bytes,4,opt,name=RequestId,proto3,oneof" json:"RequestId,omitempty"`
	Ts              *string                                    `protobuf:"bytes,5,opt,name=Ts,proto3,oneof" json:"Ts,omitempty"`
	TsC             *int32                                     `protobuf:"varint,6,opt,name=TsC,proto3,oneof" json:"TsC,omitempty"`
	Authorization   *string                                    `protobuf:"bytes,7,opt,name=Authorization,proto3,oneof" json:"Authorization,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponseMessage) Descriptor deprecated 

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

Deprecated: Use GetResponseMessage.ProtoReflect.Descriptor instead.

func (*GetResponseMessage) GetAuthorization 

func (x *GetResponseMessage) GetAuthorization() string

func (*GetResponseMessage) GetErrorResponse 

func (x *GetResponseMessage) GetErrorResponse() *ErrorResponseMessage

func (*GetResponseMessage) GetRequestId 

func (x *GetResponseMessage) GetRequestId() string

func (*GetResponseMessage) GetStatus 

func (x *GetResponseMessage) GetStatus() ResponseStatus

func (*GetResponseMessage) GetSuccessResponse 

func (x *GetResponseMessage) GetSuccessResponse() *GetResponseMessage_SuccessResponseMessage

func (*GetResponseMessage) GetTs 

func (x *GetResponseMessage) GetTs() string

func (*GetResponseMessage) GetTsC 

func (x *GetResponseMessage) GetTsC() int32

func (*GetResponseMessage) ProtoMessage 

func (*GetResponseMessage) ProtoMessage()

func (*GetResponseMessage) ProtoReflect 

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

func (*GetResponseMessage) Reset 

func (x *GetResponseMessage) Reset()

func (*GetResponseMessage) String 

func (x *GetResponseMessage) String() string

type GetResponseMessage_SuccessResponseMessage 

type GetResponseMessage_SuccessResponseMessage struct {
	DataPack *DataPackages `protobuf:"bytes,1,opt,name=DataPack,proto3,oneof" json:"DataPack,omitempty"`
	Metadata *string       `protobuf:"bytes,2,opt,name=Metadata,proto3,oneof" json:"Metadata,omitempty"` // replaces DataPack in static metadata and one dynamic metadata variant
	// contains filtered or unexported fields
}

func (*GetResponseMessage_SuccessResponseMessage) Descriptor deprecated 

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

Deprecated: Use GetResponseMessage_SuccessResponseMessage.ProtoReflect.Descriptor instead.

func (*GetResponseMessage_SuccessResponseMessage) GetDataPack 

func (x *GetResponseMessage_SuccessResponseMessage) GetDataPack() *DataPackages

func (*GetResponseMessage_SuccessResponseMessage) GetMetadata 

func (x *GetResponseMessage_SuccessResponseMessage) GetMetadata() string

func (*GetResponseMessage_SuccessResponseMessage) ProtoMessage 

func (*GetResponseMessage_SuccessResponseMessage) ProtoMessage()

func (*GetResponseMessage_SuccessResponseMessage) ProtoReflect 

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

func (*GetResponseMessage_SuccessResponseMessage) Reset 

func (x *GetResponseMessage_SuccessResponseMessage) Reset()

func (*GetResponseMessage_SuccessResponseMessage) String 

func (x *GetResponseMessage_SuccessResponseMessage) String() string

type ResponseStatus 

type ResponseStatus int32
const (
	ResponseStatus_SUCCESS ResponseStatus = 0
	ResponseStatus_ERROR   ResponseStatus = 1
)

func (ResponseStatus) Descriptor 

func (ResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (ResponseStatus) Enum 

func (x ResponseStatus) Enum() *ResponseStatus

func (ResponseStatus) EnumDescriptor deprecated 

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

Deprecated: Use ResponseStatus.Descriptor instead.

func (ResponseStatus) Number 

func (x ResponseStatus) Number() protoreflect.EnumNumber

func (ResponseStatus) String 

func (x ResponseStatus) String() string

func (ResponseStatus) Type 

func (ResponseStatus) Type() protoreflect.EnumType

type SetRequestMessage 

type SetRequestMessage struct {
	Path          string  `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Value         string  `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	Authorization *string `protobuf:"bytes,3,opt,name=Authorization,proto3,oneof" json:"Authorization,omitempty"`
	RequestId     *string `protobuf:"bytes,4,opt,name=RequestId,proto3,oneof" json:"RequestId,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequestMessage) Descriptor deprecated 

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

Deprecated: Use SetRequestMessage.ProtoReflect.Descriptor instead.

func (*SetRequestMessage) GetAuthorization 

func (x *SetRequestMessage) GetAuthorization() string

func (*SetRequestMessage) GetPath 

func (x *SetRequestMessage) GetPath() string

func (*SetRequestMessage) GetRequestId 

func (x *SetRequestMessage) GetRequestId() string

func (*SetRequestMessage) GetValue 

func (x *SetRequestMessage) GetValue() string

func (*SetRequestMessage) ProtoMessage 

func (*SetRequestMessage) ProtoMessage()

func (*SetRequestMessage) ProtoReflect 

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

func (*SetRequestMessage) Reset 

func (x *SetRequestMessage) Reset()

func (*SetRequestMessage) String 

func (x *SetRequestMessage) String() string

type SetResponseMessage 

type SetResponseMessage struct {
	Status        ResponseStatus        `protobuf:"varint,1,opt,name=Status,proto3,enum=grpcProtobufMessages.ResponseStatus" json:"Status,omitempty"`
	ErrorResponse *ErrorResponseMessage `protobuf:"bytes,2,opt,name=ErrorResponse,proto3,oneof" json:"ErrorResponse,omitempty"`
	RequestId     *string               `protobuf:"bytes,3,opt,name=RequestId,proto3,oneof" json:"RequestId,omitempty"`
	Ts            string                `protobuf:"bytes,4,opt,name=Ts,proto3" json:"Ts,omitempty"`
	Authorization *string               `protobuf:"bytes,5,opt,name=Authorization,proto3,oneof" json:"Authorization,omitempty"`
	// contains filtered or unexported fields
}

func (*SetResponseMessage) Descriptor deprecated 

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

Deprecated: Use SetResponseMessage.ProtoReflect.Descriptor instead.

func (*SetResponseMessage) GetAuthorization 

func (x *SetResponseMessage) GetAuthorization() string

func (*SetResponseMessage) GetErrorResponse 

func (x *SetResponseMessage) GetErrorResponse() *ErrorResponseMessage

func (*SetResponseMessage) GetRequestId 

func (x *SetResponseMessage) GetRequestId() string

func (*SetResponseMessage) GetStatus 

func (x *SetResponseMessage) GetStatus() ResponseStatus

func (*SetResponseMessage) GetTs 

func (x *SetResponseMessage) GetTs() string

func (*SetResponseMessage) ProtoMessage 

func (*SetResponseMessage) ProtoMessage()

func (*SetResponseMessage) ProtoReflect 

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

func (*SetResponseMessage) Reset 

func (x *SetResponseMessage) Reset()

func (*SetResponseMessage) String 

func (x *SetResponseMessage) String() string

type SubscribeRequestMessage 

type SubscribeRequestMessage struct {
	Path          string             `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Filter        *FilterExpressions `protobuf:"bytes,2,opt,name=Filter,proto3,oneof" json:"Filter,omitempty"`
	Authorization *string            `protobuf:"bytes,3,opt,name=Authorization,proto3,oneof" json:"Authorization,omitempty"`
	RequestId     string             `protobuf:"bytes,4,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestMessage.ProtoReflect.Descriptor instead.

func (*SubscribeRequestMessage) GetAuthorization 

func (x *SubscribeRequestMessage) GetAuthorization() string

func (*SubscribeRequestMessage) GetFilter 

func (x *SubscribeRequestMessage) GetFilter() *FilterExpressions

func (*SubscribeRequestMessage) GetPath 

func (x *SubscribeRequestMessage) GetPath() string

func (*SubscribeRequestMessage) GetRequestId 

func (x *SubscribeRequestMessage) GetRequestId() string

func (*SubscribeRequestMessage) ProtoMessage 

func (*SubscribeRequestMessage) ProtoMessage()

func (*SubscribeRequestMessage) ProtoReflect 

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

func (*SubscribeRequestMessage) Reset 

func (x *SubscribeRequestMessage) Reset()

func (*SubscribeRequestMessage) String 

func (x *SubscribeRequestMessage) String() string

type SubscribeResponseType 

type SubscribeResponseType int32
const (
	SubscribeResponseType_RESPONSE SubscribeResponseType = 0
	SubscribeResponseType_EVENT    SubscribeResponseType = 1
)

func (SubscribeResponseType) Descriptor 

func (SubscribeResponseType) Descriptor() protoreflect.EnumDescriptor

func (SubscribeResponseType) Enum 

func (x SubscribeResponseType) Enum() *SubscribeResponseType

func (SubscribeResponseType) EnumDescriptor deprecated 

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

Deprecated: Use SubscribeResponseType.Descriptor instead.

func (SubscribeResponseType) Number 

func (x SubscribeResponseType) Number() protoreflect.EnumNumber

func (SubscribeResponseType) String 

func (x SubscribeResponseType) String() string

func (SubscribeResponseType) Type 

func (SubscribeResponseType) Type() protoreflect.EnumType

type SubscribeStreamMessage 

type SubscribeStreamMessage struct {
	MType    SubscribeResponseType                            `protobuf:"varint,1,opt,name=MType,proto3,enum=grpcProtobufMessages.SubscribeResponseType" json:"MType,omitempty"`
	Status   ResponseStatus                                   `protobuf:"varint,2,opt,name=Status,proto3,enum=grpcProtobufMessages.ResponseStatus" json:"Status,omitempty"`
	Response *SubscribeStreamMessage_SubscribeResponseMessage `protobuf:"bytes,3,opt,name=Response,proto3,oneof" json:"Response,omitempty"`
	Event    *SubscribeStreamMessage_SubscribeEventMessage    `protobuf:"bytes,4,opt,name=Event,proto3,oneof" json:"Event,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamMessage.ProtoReflect.Descriptor instead.

func (*SubscribeStreamMessage) GetEvent 

func (x *SubscribeStreamMessage) GetEvent() *SubscribeStreamMessage_SubscribeEventMessage

func (*SubscribeStreamMessage) GetMType 

func (x *SubscribeStreamMessage) GetMType() SubscribeResponseType

func (*SubscribeStreamMessage) GetResponse 

func (x *SubscribeStreamMessage) GetResponse() *SubscribeStreamMessage_SubscribeResponseMessage

func (*SubscribeStreamMessage) GetStatus 

func (x *SubscribeStreamMessage) GetStatus() ResponseStatus

func (*SubscribeStreamMessage) ProtoMessage 

func (*SubscribeStreamMessage) ProtoMessage()

func (*SubscribeStreamMessage) ProtoReflect 

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

func (*SubscribeStreamMessage) Reset 

func (x *SubscribeStreamMessage) Reset()

func (*SubscribeStreamMessage) String 

func (x *SubscribeStreamMessage) String() string

type SubscribeStreamMessage_SubscribeEventMessage 

type SubscribeStreamMessage_SubscribeEventMessage struct {
	SubscriptionId  string                                                               `protobuf:"bytes,1,opt,name=SubscriptionId,proto3" json:"SubscriptionId,omitempty"`
	SuccessResponse *SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage `protobuf:"bytes,2,opt,name=SuccessResponse,proto3,oneof" json:"SuccessResponse,omitempty"`
	ErrorResponse   *ErrorResponseMessage                                                `protobuf:"bytes,3,opt,name=ErrorResponse,proto3,oneof" json:"ErrorResponse,omitempty"`
	Ts              *string                                                              `protobuf:"bytes,4,opt,name=Ts,proto3,oneof" json:"Ts,omitempty"`
	TsC             *int32                                                               `protobuf:"varint,5,opt,name=TsC,proto3,oneof" json:"TsC,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamMessage_SubscribeEventMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamMessage_SubscribeEventMessage.ProtoReflect.Descriptor instead.

func (*SubscribeStreamMessage_SubscribeEventMessage) GetErrorResponse 

func (x *SubscribeStreamMessage_SubscribeEventMessage) GetErrorResponse() *ErrorResponseMessage

func (*SubscribeStreamMessage_SubscribeEventMessage) GetSubscriptionId 

func (x *SubscribeStreamMessage_SubscribeEventMessage) GetSubscriptionId() string

func (*SubscribeStreamMessage_SubscribeEventMessage) GetSuccessResponse 

func (x *SubscribeStreamMessage_SubscribeEventMessage) GetSuccessResponse() *SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage

func (*SubscribeStreamMessage_SubscribeEventMessage) GetTs 

func (x *SubscribeStreamMessage_SubscribeEventMessage) GetTs() string

func (*SubscribeStreamMessage_SubscribeEventMessage) GetTsC 

func (x *SubscribeStreamMessage_SubscribeEventMessage) GetTsC() int32

func (*SubscribeStreamMessage_SubscribeEventMessage) ProtoMessage 

func (*SubscribeStreamMessage_SubscribeEventMessage) ProtoMessage()

func (*SubscribeStreamMessage_SubscribeEventMessage) ProtoReflect 

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

func (*SubscribeStreamMessage_SubscribeEventMessage) Reset 

func (x *SubscribeStreamMessage_SubscribeEventMessage) Reset()

func (*SubscribeStreamMessage_SubscribeEventMessage) String 

func (x *SubscribeStreamMessage_SubscribeEventMessage) String() string

type SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage 

type SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage struct {
	DataPack *DataPackages `protobuf:"bytes,1,opt,name=DataPack,proto3" json:"DataPack,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage.ProtoReflect.Descriptor instead.

func (*SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) GetDataPack 

func (x *SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) GetDataPack() *DataPackages

func (*SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) ProtoMessage 

func (*SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) ProtoMessage()

func (*SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) ProtoReflect 

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

func (*SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) Reset 

func (x *SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) Reset()

func (*SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) String 

func (x *SubscribeStreamMessage_SubscribeEventMessage_SuccessResponseMessage) String() string

type SubscribeStreamMessage_SubscribeResponseMessage 

type SubscribeStreamMessage_SubscribeResponseMessage struct {
	ErrorResponse  *ErrorResponseMessage `protobuf:"bytes,1,opt,name=ErrorResponse,proto3,oneof" json:"ErrorResponse,omitempty"`
	SubscriptionId *string               `protobuf:"bytes,2,opt,name=SubscriptionId,proto3,oneof" json:"SubscriptionId,omitempty"`
	RequestId      string                `protobuf:"bytes,3,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	Ts             string                `protobuf:"bytes,4,opt,name=Ts,proto3" json:"Ts,omitempty"`
	Authorization  *string               `protobuf:"bytes,5,opt,name=Authorization,proto3,oneof" json:"Authorization,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamMessage_SubscribeResponseMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamMessage_SubscribeResponseMessage.ProtoReflect.Descriptor instead.

func (*SubscribeStreamMessage_SubscribeResponseMessage) GetAuthorization 

func (x *SubscribeStreamMessage_SubscribeResponseMessage) GetAuthorization() string

func (*SubscribeStreamMessage_SubscribeResponseMessage) GetErrorResponse 

func (x *SubscribeStreamMessage_SubscribeResponseMessage) GetErrorResponse() *ErrorResponseMessage

func (*SubscribeStreamMessage_SubscribeResponseMessage) GetRequestId 

func (x *SubscribeStreamMessage_SubscribeResponseMessage) GetRequestId() string

func (*SubscribeStreamMessage_SubscribeResponseMessage) GetSubscriptionId 

func (x *SubscribeStreamMessage_SubscribeResponseMessage) GetSubscriptionId() string

func (*SubscribeStreamMessage_SubscribeResponseMessage) GetTs 

func (x *SubscribeStreamMessage_SubscribeResponseMessage) GetTs() string

func (*SubscribeStreamMessage_SubscribeResponseMessage) ProtoMessage 

func (*SubscribeStreamMessage_SubscribeResponseMessage) ProtoMessage()

func (*SubscribeStreamMessage_SubscribeResponseMessage) ProtoReflect 

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

func (*SubscribeStreamMessage_SubscribeResponseMessage) Reset 

func (x *SubscribeStreamMessage_SubscribeResponseMessage) Reset()

func (*SubscribeStreamMessage_SubscribeResponseMessage) String 

func (x *SubscribeStreamMessage_SubscribeResponseMessage) String() string

type UnimplementedVISSv2Server 

type UnimplementedVISSv2Server struct {
}

UnimplementedVISSv2Server must be embedded to have forward compatible implementations.

func (UnimplementedVISSv2Server) GetRequest 

func (UnimplementedVISSv2Server) GetRequest(context.Context, *GetRequestMessage) (*GetResponseMessage, error)

func (UnimplementedVISSv2Server) SetRequest 

func (UnimplementedVISSv2Server) SetRequest(context.Context, *SetRequestMessage) (*SetResponseMessage, error)

func (UnimplementedVISSv2Server) SubscribeRequest 

func (UnimplementedVISSv2Server) SubscribeRequest(*SubscribeRequestMessage, VISSv2_SubscribeRequestServer) error

func (UnimplementedVISSv2Server) UnsubscribeRequest 

func (UnimplementedVISSv2Server) UnsubscribeRequest(context.Context, *UnsubscribeRequestMessage) (*UnsubscribeResponseMessage, error)

type UnsafeVISSv2Server 

type UnsafeVISSv2Server interface {
	// contains filtered or unexported methods
}

UnsafeVISSv2Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VISSv2Server will result in compilation errors.

type UnsubscribeRequestMessage 

type UnsubscribeRequestMessage struct {
	SubscriptionId string  `protobuf:"bytes,1,opt,name=SubscriptionId,proto3" json:"SubscriptionId,omitempty"`
	RequestId      *string `protobuf:"bytes,2,opt,name=RequestId,proto3,oneof" json:"RequestId,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeRequestMessage) Descriptor deprecated 

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

Deprecated: Use UnsubscribeRequestMessage.ProtoReflect.Descriptor instead.

func (*UnsubscribeRequestMessage) GetRequestId 

func (x *UnsubscribeRequestMessage) GetRequestId() string

func (*UnsubscribeRequestMessage) GetSubscriptionId 

func (x *UnsubscribeRequestMessage) GetSubscriptionId() string

func (*UnsubscribeRequestMessage) ProtoMessage 

func (*UnsubscribeRequestMessage) ProtoMessage()

func (*UnsubscribeRequestMessage) ProtoReflect 

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

func (*UnsubscribeRequestMessage) Reset 

func (x *UnsubscribeRequestMessage) Reset()

func (*UnsubscribeRequestMessage) String 

func (x *UnsubscribeRequestMessage) String() string

type UnsubscribeResponseMessage 

type UnsubscribeResponseMessage struct {
	SubscriptionId string                `protobuf:"bytes,1,opt,name=SubscriptionId,proto3" json:"SubscriptionId,omitempty"`
	Status         ResponseStatus        `protobuf:"varint,2,opt,name=Status,proto3,enum=grpcProtobufMessages.ResponseStatus" json:"Status,omitempty"`
	ErrorResponse  *ErrorResponseMessage `protobuf:"bytes,3,opt,name=ErrorResponse,proto3,oneof" json:"ErrorResponse,omitempty"`
	RequestId      *string               `protobuf:"bytes,4,opt,name=RequestId,proto3,oneof" json:"RequestId,omitempty"`
	Ts             string                `protobuf:"bytes,5,opt,name=Ts,proto3" json:"Ts,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeResponseMessage) Descriptor deprecated 

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

Deprecated: Use UnsubscribeResponseMessage.ProtoReflect.Descriptor instead.

func (*UnsubscribeResponseMessage) GetErrorResponse 

func (x *UnsubscribeResponseMessage) GetErrorResponse() *ErrorResponseMessage

func (*UnsubscribeResponseMessage) GetRequestId 

func (x *UnsubscribeResponseMessage) GetRequestId() string

func (*UnsubscribeResponseMessage) GetStatus 

func (x *UnsubscribeResponseMessage) GetStatus() ResponseStatus

func (*UnsubscribeResponseMessage) GetSubscriptionId 

func (x *UnsubscribeResponseMessage) GetSubscriptionId() string

func (*UnsubscribeResponseMessage) GetTs 

func (x *UnsubscribeResponseMessage) GetTs() string

func (*UnsubscribeResponseMessage) ProtoMessage 

func (*UnsubscribeResponseMessage) ProtoMessage()

func (*UnsubscribeResponseMessage) ProtoReflect 

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

func (*UnsubscribeResponseMessage) Reset 

func (x *UnsubscribeResponseMessage) Reset()

func (*UnsubscribeResponseMessage) String 

func (x *UnsubscribeResponseMessage) String() string

type VISSv2Client 

type VISSv2Client interface {
	GetRequest(ctx context.Context, in *GetRequestMessage, opts ...grpc.CallOption) (*GetResponseMessage, error)
	SetRequest(ctx context.Context, in *SetRequestMessage, opts ...grpc.CallOption) (*SetResponseMessage, error)
	SubscribeRequest(ctx context.Context, in *SubscribeRequestMessage, opts ...grpc.CallOption) (VISSv2_SubscribeRequestClient, error)
	UnsubscribeRequest(ctx context.Context, in *UnsubscribeRequestMessage, opts ...grpc.CallOption) (*UnsubscribeResponseMessage, error)
}

VISSv2Client is the client API for VISSv2 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewVISSv2Client 

func NewVISSv2Client(cc grpc.ClientConnInterface) VISSv2Client

type VISSv2Server 

type VISSv2Server interface {
	GetRequest(context.Context, *GetRequestMessage) (*GetResponseMessage, error)
	SetRequest(context.Context, *SetRequestMessage) (*SetResponseMessage, error)
	SubscribeRequest(*SubscribeRequestMessage, VISSv2_SubscribeRequestServer) error
	UnsubscribeRequest(context.Context, *UnsubscribeRequestMessage) (*UnsubscribeResponseMessage, error)
	// contains filtered or unexported methods
}

VISSv2Server is the server API for VISSv2 service. All implementations must embed UnimplementedVISSv2Server for forward compatibility

type VISSv2_SubscribeRequestClient 

type VISSv2_SubscribeRequestClient interface {
	Recv() (*SubscribeStreamMessage, error)
	grpc.ClientStream
}

type VISSv2_SubscribeRequestServer 

type VISSv2_SubscribeRequestServer interface {
	Send(*SubscribeStreamMessage) error
	grpc.ServerStream
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.