influx/telegraf
1
0
Fork 0
Code Issues Activity
telegraf/plugins/inputs/jti_openconfig_telemetry/oc/oc.pb.go

1975 lines
66 KiB
Go
Raw Permalink Normal View History

Adding upstream version 1.34.4. Signed-off-by: Daniel Baumann <daniel@debian.org>
2025-05-24 07:26:29 +02:00
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.27.1
// protoc v3.17.3
// source: oc/oc.proto
package telemetry
import (
reflect "reflect"
sync "sync"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
// Result of the operation
type ReturnCode int32
const (
ReturnCode_SUCCESS ReturnCode = 0
ReturnCode_NO_SUBSCRIPTION_ENTRY ReturnCode = 1
ReturnCode_UNKNOWN_ERROR ReturnCode = 2
)
// Enum value maps for ReturnCode.
var (
ReturnCode_name = map[int32]string{
0: "SUCCESS",
1: "NO_SUBSCRIPTION_ENTRY",
2: "UNKNOWN_ERROR",
}
ReturnCode_value = map[string]int32{
"SUCCESS": 0,
"NO_SUBSCRIPTION_ENTRY": 1,
"UNKNOWN_ERROR": 2,
}
)
func (x ReturnCode) Enum() *ReturnCode {
p := new(ReturnCode)
*p = x
return p
}
func (x ReturnCode) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (ReturnCode) Descriptor() protoreflect.EnumDescriptor {
return file_oc_oc_proto_enumTypes[0].Descriptor()
}
func (ReturnCode) Type() protoreflect.EnumType {
return &file_oc_oc_proto_enumTypes[0]
}
func (x ReturnCode) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use ReturnCode.Descriptor instead.
func (ReturnCode) EnumDescriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{0}
}
// Verbosity Level
type VerbosityLevel int32
const (
VerbosityLevel_DETAIL VerbosityLevel = 0
VerbosityLevel_TERSE VerbosityLevel = 1
VerbosityLevel_BRIEF VerbosityLevel = 2
)
// Enum value maps for VerbosityLevel.
var (
VerbosityLevel_name = map[int32]string{
0: "DETAIL",
1: "TERSE",
2: "BRIEF",
}
VerbosityLevel_value = map[string]int32{
"DETAIL": 0,
"TERSE": 1,
"BRIEF": 2,
}
)
func (x VerbosityLevel) Enum() *VerbosityLevel {
p := new(VerbosityLevel)
*p = x
return p
}
func (x VerbosityLevel) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (VerbosityLevel) Descriptor() protoreflect.EnumDescriptor {
return file_oc_oc_proto_enumTypes[1].Descriptor()
}
func (VerbosityLevel) Type() protoreflect.EnumType {
return &file_oc_oc_proto_enumTypes[1]
}
func (x VerbosityLevel) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use VerbosityLevel.Descriptor instead.
func (VerbosityLevel) EnumDescriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{1}
}
// Encoding Type Supported
type EncodingType int32
const (
EncodingType_UNDEFINED EncodingType = 0
EncodingType_XML EncodingType = 1
EncodingType_JSON_IETF EncodingType = 2
EncodingType_PROTO3 EncodingType = 3
)
// Enum value maps for EncodingType.
var (
EncodingType_name = map[int32]string{
0: "UNDEFINED",
1: "XML",
2: "JSON_IETF",
3: "PROTO3",
}
EncodingType_value = map[string]int32{
"UNDEFINED": 0,
"XML": 1,
"JSON_IETF": 2,
"PROTO3": 3,
}
)
func (x EncodingType) Enum() *EncodingType {
p := new(EncodingType)
*p = x
return p
}
func (x EncodingType) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (EncodingType) Descriptor() protoreflect.EnumDescriptor {
return file_oc_oc_proto_enumTypes[2].Descriptor()
}
func (EncodingType) Type() protoreflect.EnumType {
return &file_oc_oc_proto_enumTypes[2]
}
func (x EncodingType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use EncodingType.Descriptor instead.
func (EncodingType) EnumDescriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{2}
}
// Message sent for a telemetry subscription request
type SubscriptionRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Data associated with a telemetry subscription
Input *SubscriptionInput `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
// List of data models paths and filters
// which are used in a telemetry operation.
PathList []*Path `protobuf:"bytes,2,rep,name=path_list,json=pathList,proto3" json:"path_list,omitempty"`
// The below configuration is not defined in Openconfig RPC.
// It is a proposed extension to configure additional
// subscription request features.
AdditionalConfig *SubscriptionAdditionalConfig `protobuf:"bytes,3,opt,name=additional_config,json=additionalConfig,proto3" json:"additional_config,omitempty"`
}
func (x *SubscriptionRequest) Reset() {
*x = SubscriptionRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SubscriptionRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SubscriptionRequest) ProtoMessage() {}
func (x *SubscriptionRequest) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.
func (*SubscriptionRequest) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{0}
}
func (x *SubscriptionRequest) GetInput() *SubscriptionInput {
if x != nil {
return x.Input
}
return nil
}
func (x *SubscriptionRequest) GetPathList() []*Path {
if x != nil {
return x.PathList
}
return nil
}
func (x *SubscriptionRequest) GetAdditionalConfig() *SubscriptionAdditionalConfig {
if x != nil {
return x.AdditionalConfig
}
return nil
}
// Data associated with a telemetry subscription
type SubscriptionInput struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// List of optional collector endpoints to send data for
// this subscription.
// If no collector destinations are specified, the collector
// destination is assumed to be the requester on the rpc channel.
CollectorList []*Collector `protobuf:"bytes,1,rep,name=collector_list,json=collectorList,proto3" json:"collector_list,omitempty"`
}
func (x *SubscriptionInput) Reset() {
*x = SubscriptionInput{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SubscriptionInput) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SubscriptionInput) ProtoMessage() {}
func (x *SubscriptionInput) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SubscriptionInput.ProtoReflect.Descriptor instead.
func (*SubscriptionInput) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{1}
}
func (x *SubscriptionInput) GetCollectorList() []*Collector {
if x != nil {
return x.CollectorList
}
return nil
}
// Collector endpoints to send data specified as an ip+port combination.
type Collector struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// IP address of collector endpoint
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
// Transport protocol port number for the collector destination.
Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
}
func (x *Collector) Reset() {
*x = Collector{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Collector) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Collector) ProtoMessage() {}
func (x *Collector) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Collector.ProtoReflect.Descriptor instead.
func (*Collector) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{2}
}
func (x *Collector) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *Collector) GetPort() uint32 {
if x != nil {
return x.Port
}
return 0
}
// Data model path
type Path struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Data model path of interest
// Path specification for elements of OpenConfig data models
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// Regular expression to be used in filtering state leaves
Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
// If this is set to true, the target device will only send
// updates to the collector upon a change in data value
SuppressUnchanged bool `protobuf:"varint,3,opt,name=suppress_unchanged,json=suppressUnchanged,proto3" json:"suppress_unchanged,omitempty"`
// Maximum time in ms the target device may go without sending
// a message to the collector. If this time expires with
// suppress-unchanged set, the target device must send an update
// message regardless if the data values have changed.
MaxSilentInterval uint32 `protobuf:"varint,4,opt,name=max_silent_interval,json=maxSilentInterval,proto3" json:"max_silent_interval,omitempty"`
// Time in ms between collection and transmission of the
// specified data to the collector platform. The target device
// will sample the corresponding data (e.g,. a counter) and
// immediately send to the collector destination.
//
// If sample-frequency is set to 0, then the network device
// must emit an update upon every datum change.
SampleFrequency uint32 `protobuf:"varint,5,opt,name=sample_frequency,json=sampleFrequency,proto3" json:"sample_frequency,omitempty"`
// EOM needed for each walk cycle of this path?
// For periodic sensor, applicable for each complete reap
// For event sensor, applicable when initial dump is over
// (same as EOS)
// This feature is not implemented currently.
NeedEom bool `protobuf:"varint,6,opt,name=need_eom,json=needEom,proto3" json:"need_eom,omitempty"`
}
func (x *Path) Reset() {
*x = Path{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Path) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Path) ProtoMessage() {}
func (x *Path) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Path.ProtoReflect.Descriptor instead.
func (*Path) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{3}
}
func (x *Path) GetPath() string {
if x != nil {
return x.Path
}
return ""
}
func (x *Path) GetFilter() string {
if x != nil {
return x.Filter
}
return ""
}
func (x *Path) GetSuppressUnchanged() bool {
if x != nil {
return x.SuppressUnchanged
}
return false
}
func (x *Path) GetMaxSilentInterval() uint32 {
if x != nil {
return x.MaxSilentInterval
}
return 0
}
func (x *Path) GetSampleFrequency() uint32 {
if x != nil {
return x.SampleFrequency
}
return 0
}
func (x *Path) GetNeedEom() bool {
if x != nil {
return x.NeedEom
}
return false
}
// Configure subscription request additional features.
type SubscriptionAdditionalConfig struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// limit the number of records sent in the stream
LimitRecords int32 `protobuf:"varint,1,opt,name=limit_records,json=limitRecords,proto3" json:"limit_records,omitempty"`
// limit the time the stream remains open
LimitTimeSeconds int32 `protobuf:"varint,2,opt,name=limit_time_seconds,json=limitTimeSeconds,proto3" json:"limit_time_seconds,omitempty"`
// EOS needed for this subscription?
NeedEos bool `protobuf:"varint,3,opt,name=need_eos,json=needEos,proto3" json:"need_eos,omitempty"`
}
func (x *SubscriptionAdditionalConfig) Reset() {
*x = SubscriptionAdditionalConfig{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SubscriptionAdditionalConfig) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SubscriptionAdditionalConfig) ProtoMessage() {}
func (x *SubscriptionAdditionalConfig) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SubscriptionAdditionalConfig.ProtoReflect.Descriptor instead.
func (*SubscriptionAdditionalConfig) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{4}
}
func (x *SubscriptionAdditionalConfig) GetLimitRecords() int32 {
if x != nil {
return x.LimitRecords
}
return 0
}
func (x *SubscriptionAdditionalConfig) GetLimitTimeSeconds() int32 {
if x != nil {
return x.LimitTimeSeconds
}
return 0
}
func (x *SubscriptionAdditionalConfig) GetNeedEos() bool {
if x != nil {
return x.NeedEos
}
return false
}
// 1. Reply data message sent out using out-of-band channel.
type SubscriptionReply struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Response message to a telemetry subscription creation or
// get request.
Response *SubscriptionResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
// List of data models paths and filters
// which are used in a telemetry operation.
PathList []*Path `protobuf:"bytes,2,rep,name=path_list,json=pathList,proto3" json:"path_list,omitempty"`
}
func (x *SubscriptionReply) Reset() {
*x = SubscriptionReply{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SubscriptionReply) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SubscriptionReply) ProtoMessage() {}
func (x *SubscriptionReply) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SubscriptionReply.ProtoReflect.Descriptor instead.
func (*SubscriptionReply) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{5}
}
func (x *SubscriptionReply) GetResponse() *SubscriptionResponse {
if x != nil {
return x.Response
}
return nil
}
func (x *SubscriptionReply) GetPathList() []*Path {
if x != nil {
return x.PathList
}
return nil
}
// Response message to a telemetry subscription creation or get request.
type SubscriptionResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Unique id for the subscription on the device. This is
// generated by the device and returned in a subscription
// request or when listing existing subscriptions
SubscriptionId uint32 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
}
func (x *SubscriptionResponse) Reset() {
*x = SubscriptionResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SubscriptionResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SubscriptionResponse) ProtoMessage() {}
func (x *SubscriptionResponse) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SubscriptionResponse.ProtoReflect.Descriptor instead.
func (*SubscriptionResponse) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{6}
}
func (x *SubscriptionResponse) GetSubscriptionId() uint32 {
if x != nil {
return x.SubscriptionId
}
return 0
}
// 2. Telemetry data send back on the same connection as the
// subscription request.
type OpenConfigData struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// router name:export IP address
SystemId string `protobuf:"bytes,1,opt,name=system_id,json=systemId,proto3" json:"system_id,omitempty"`
// line card / RE (slot number)
ComponentId uint32 `protobuf:"varint,2,opt,name=component_id,json=componentId,proto3" json:"component_id,omitempty"`
// PFE (if applicable)
SubComponentId uint32 `protobuf:"varint,3,opt,name=sub_component_id,json=subComponentId,proto3" json:"sub_component_id,omitempty"`
// Path specification for elements of OpenConfig data models
Path string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
// Sequence number, monotonically increasing for each
// system_id, component_id, sub_component_id + path.
SequenceNumber uint64 `protobuf:"varint,5,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
// timestamp (milliseconds since epoch)
Timestamp uint64 `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// List of key-value pairs
Kv []*KeyValue `protobuf:"bytes,7,rep,name=kv,proto3" json:"kv,omitempty"`
// For delete. If filled, it indicates delete
Delete []*Delete `protobuf:"bytes,8,rep,name=delete,proto3" json:"delete,omitempty"`
// If filled, it indicates end of marker for the
// respective path in the list.
Eom []*Eom `protobuf:"bytes,9,rep,name=eom,proto3" json:"eom,omitempty"`
// If filled, it indicates end of sync for complete subscription
SyncResponse bool `protobuf:"varint,10,opt,name=sync_response,json=syncResponse,proto3" json:"sync_response,omitempty"`
}
func (x *OpenConfigData) Reset() {
*x = OpenConfigData{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *OpenConfigData) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*OpenConfigData) ProtoMessage() {}
func (x *OpenConfigData) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use OpenConfigData.ProtoReflect.Descriptor instead.
func (*OpenConfigData) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{7}
}
func (x *OpenConfigData) GetSystemId() string {
if x != nil {
return x.SystemId
}
return ""
}
func (x *OpenConfigData) GetComponentId() uint32 {
if x != nil {
return x.ComponentId
}
return 0
}
func (x *OpenConfigData) GetSubComponentId() uint32 {
if x != nil {
return x.SubComponentId
}
return 0
}
func (x *OpenConfigData) GetPath() string {
if x != nil {
return x.Path
}
return ""
}
func (x *OpenConfigData) GetSequenceNumber() uint64 {
if x != nil {
return x.SequenceNumber
}
return 0
}
func (x *OpenConfigData) GetTimestamp() uint64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *OpenConfigData) GetKv() []*KeyValue {
if x != nil {
return x.Kv
}
return nil
}
func (x *OpenConfigData) GetDelete() []*Delete {
if x != nil {
return x.Delete
}
return nil
}
func (x *OpenConfigData) GetEom() []*Eom {
if x != nil {
return x.Eom
}
return nil
}
func (x *OpenConfigData) GetSyncResponse() bool {
if x != nil {
return x.SyncResponse
}
return false
}
// Simple Key-value, where value could be one of scalar types
type KeyValue struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Key
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// One of possible values
//
// Types that are assignable to Value:
// *KeyValue_DoubleValue
// *KeyValue_IntValue
// *KeyValue_UintValue
// *KeyValue_SintValue
// *KeyValue_BoolValue
// *KeyValue_StrValue
// *KeyValue_BytesValue
Value isKeyValue_Value `protobuf_oneof:"value"`
}
func (x *KeyValue) Reset() {
*x = KeyValue{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *KeyValue) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*KeyValue) ProtoMessage() {}
func (x *KeyValue) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.
func (*KeyValue) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{8}
}
func (x *KeyValue) GetKey() string {
if x != nil {
return x.Key
}
return ""
}
func (m *KeyValue) GetValue() isKeyValue_Value {
if m != nil {
return m.Value
}
return nil
}
func (x *KeyValue) GetDoubleValue() float64 {
if x, ok := x.GetValue().(*KeyValue_DoubleValue); ok {
return x.DoubleValue
}
return 0
}
func (x *KeyValue) GetIntValue() int64 {
if x, ok := x.GetValue().(*KeyValue_IntValue); ok {
return x.IntValue
}
return 0
}
func (x *KeyValue) GetUintValue() uint64 {
if x, ok := x.GetValue().(*KeyValue_UintValue); ok {
return x.UintValue
}
return 0
}
func (x *KeyValue) GetSintValue() int64 {
if x, ok := x.GetValue().(*KeyValue_SintValue); ok {
return x.SintValue
}
return 0
}
func (x *KeyValue) GetBoolValue() bool {
if x, ok := x.GetValue().(*KeyValue_BoolValue); ok {
return x.BoolValue
}
return false
}
func (x *KeyValue) GetStrValue() string {
if x, ok := x.GetValue().(*KeyValue_StrValue); ok {
return x.StrValue
}
return ""
}
func (x *KeyValue) GetBytesValue() []byte {
if x, ok := x.GetValue().(*KeyValue_BytesValue); ok {
return x.BytesValue
}
return nil
}
type isKeyValue_Value interface {
isKeyValue_Value()
}
type KeyValue_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,5,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type KeyValue_IntValue struct {
IntValue int64 `protobuf:"varint,6,opt,name=int_value,json=intValue,proto3,oneof"`
}
type KeyValue_UintValue struct {
UintValue uint64 `protobuf:"varint,7,opt,name=uint_value,json=uintValue,proto3,oneof"`
}
type KeyValue_SintValue struct {
SintValue int64 `protobuf:"zigzag64,8,opt,name=sint_value,json=sintValue,proto3,oneof"`
}
type KeyValue_BoolValue struct {
BoolValue bool `protobuf:"varint,9,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
type KeyValue_StrValue struct {
StrValue string `protobuf:"bytes,10,opt,name=str_value,json=strValue,proto3,oneof"`
}
type KeyValue_BytesValue struct {
BytesValue []byte `protobuf:"bytes,11,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}
func (*KeyValue_DoubleValue) isKeyValue_Value() {}
func (*KeyValue_IntValue) isKeyValue_Value() {}
func (*KeyValue_UintValue) isKeyValue_Value() {}
func (*KeyValue_SintValue) isKeyValue_Value() {}
func (*KeyValue_BoolValue) isKeyValue_Value() {}
func (*KeyValue_StrValue) isKeyValue_Value() {}
func (*KeyValue_BytesValue) isKeyValue_Value() {}
// Message indicating delete for a particular path
type Delete struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
}
func (x *Delete) Reset() {
*x = Delete{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Delete) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Delete) ProtoMessage() {}
func (x *Delete) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Delete.ProtoReflect.Descriptor instead.
func (*Delete) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{9}
}
func (x *Delete) GetPath() string {
if x != nil {
return x.Path
}
return ""
}
// Message indicating EOM for a particular path
type Eom struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
}
func (x *Eom) Reset() {
*x = Eom{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Eom) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Eom) ProtoMessage() {}
func (x *Eom) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[10]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Eom.ProtoReflect.Descriptor instead.
func (*Eom) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{10}
}
func (x *Eom) GetPath() string {
if x != nil {
return x.Path
}
return ""
}
// Message sent for a telemetry subscription cancellation request
type CancelSubscriptionRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Subscription identifier as returned by the device when
// subscription was requested
SubscriptionId uint32 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
}
func (x *CancelSubscriptionRequest) Reset() {
*x = CancelSubscriptionRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CancelSubscriptionRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CancelSubscriptionRequest) ProtoMessage() {}
func (x *CancelSubscriptionRequest) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[11]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CancelSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*CancelSubscriptionRequest) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{11}
}
func (x *CancelSubscriptionRequest) GetSubscriptionId() uint32 {
if x != nil {
return x.SubscriptionId
}
return 0
}
// Reply to telemetry subscription cancellation request
type CancelSubscriptionReply struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Return code
Code ReturnCode `protobuf:"varint,1,opt,name=code,proto3,enum=telemetry.ReturnCode" json:"code,omitempty"`
// Return code string
CodeStr string `protobuf:"bytes,2,opt,name=code_str,json=codeStr,proto3" json:"code_str,omitempty"`
}
func (x *CancelSubscriptionReply) Reset() {
*x = CancelSubscriptionReply{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CancelSubscriptionReply) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CancelSubscriptionReply) ProtoMessage() {}
func (x *CancelSubscriptionReply) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[12]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CancelSubscriptionReply.ProtoReflect.Descriptor instead.
func (*CancelSubscriptionReply) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{12}
}
func (x *CancelSubscriptionReply) GetCode() ReturnCode {
if x != nil {
return x.Code
}
return ReturnCode_SUCCESS
}
func (x *CancelSubscriptionReply) GetCodeStr() string {
if x != nil {
return x.CodeStr
}
return ""
}
// Message sent for a telemetry get request
type GetSubscriptionsRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Subscription identifier as returned by the device when
// subscription was requested
// --- or ---
// 0xFFFFFFFF for all subscription identifiers
SubscriptionId uint32 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
}
func (x *GetSubscriptionsRequest) Reset() {
*x = GetSubscriptionsRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetSubscriptionsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetSubscriptionsRequest) ProtoMessage() {}
func (x *GetSubscriptionsRequest) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[13]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetSubscriptionsRequest.ProtoReflect.Descriptor instead.
func (*GetSubscriptionsRequest) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{13}
}
func (x *GetSubscriptionsRequest) GetSubscriptionId() uint32 {
if x != nil {
return x.SubscriptionId
}
return 0
}
// Reply to telemetry subscription get request
type GetSubscriptionsReply struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// List of current telemetry subscriptions
SubscriptionList []*SubscriptionReply `protobuf:"bytes,1,rep,name=subscription_list,json=subscriptionList,proto3" json:"subscription_list,omitempty"`
}
func (x *GetSubscriptionsReply) Reset() {
*x = GetSubscriptionsReply{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetSubscriptionsReply) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetSubscriptionsReply) ProtoMessage() {}
func (x *GetSubscriptionsReply) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[14]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetSubscriptionsReply.ProtoReflect.Descriptor instead.
func (*GetSubscriptionsReply) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{14}
}
func (x *GetSubscriptionsReply) GetSubscriptionList() []*SubscriptionReply {
if x != nil {
return x.SubscriptionList
}
return nil
}
// Message sent for telemetry agent operational states request
type GetOperationalStateRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Per-subscription_id level operational state can be requested.
//
// Subscription identifier as returned by the device when
// subscription was requested
// --- or ---
// 0xFFFFFFFF for all subscription identifiers including agent-level
// operational stats
// --- or ---
// If subscription_id is not present then sent only agent-level
// operational stats
SubscriptionId uint32 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
// Control verbosity of the output
Verbosity VerbosityLevel `protobuf:"varint,2,opt,name=verbosity,proto3,enum=telemetry.VerbosityLevel" json:"verbosity,omitempty"`
}
func (x *GetOperationalStateRequest) Reset() {
*x = GetOperationalStateRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetOperationalStateRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetOperationalStateRequest) ProtoMessage() {}
func (x *GetOperationalStateRequest) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[15]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetOperationalStateRequest.ProtoReflect.Descriptor instead.
func (*GetOperationalStateRequest) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{15}
}
func (x *GetOperationalStateRequest) GetSubscriptionId() uint32 {
if x != nil {
return x.SubscriptionId
}
return 0
}
func (x *GetOperationalStateRequest) GetVerbosity() VerbosityLevel {
if x != nil {
return x.Verbosity
}
return VerbosityLevel_DETAIL
}
// Reply to telemetry agent operational states request
type GetOperationalStateReply struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// List of key-value pairs where
// key = operational state definition
// value = operational state value
Kv []*KeyValue `protobuf:"bytes,1,rep,name=kv,proto3" json:"kv,omitempty"`
}
func (x *GetOperationalStateReply) Reset() {
*x = GetOperationalStateReply{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetOperationalStateReply) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetOperationalStateReply) ProtoMessage() {}
func (x *GetOperationalStateReply) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[16]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetOperationalStateReply.ProtoReflect.Descriptor instead.
func (*GetOperationalStateReply) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{16}
}
func (x *GetOperationalStateReply) GetKv() []*KeyValue {
if x != nil {
return x.Kv
}
return nil
}
// Message sent for a data encoding request
type DataEncodingRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
}
func (x *DataEncodingRequest) Reset() {
*x = DataEncodingRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *DataEncodingRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DataEncodingRequest) ProtoMessage() {}
func (x *DataEncodingRequest) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[17]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DataEncodingRequest.ProtoReflect.Descriptor instead.
func (*DataEncodingRequest) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{17}
}
// Reply to data encodings supported request
type DataEncodingReply struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
EncodingList []EncodingType `protobuf:"varint,1,rep,packed,name=encoding_list,json=encodingList,proto3,enum=telemetry.EncodingType" json:"encoding_list,omitempty"`
}
func (x *DataEncodingReply) Reset() {
*x = DataEncodingReply{}
if protoimpl.UnsafeEnabled {
mi := &file_oc_oc_proto_msgTypes[18]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *DataEncodingReply) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DataEncodingReply) ProtoMessage() {}
func (x *DataEncodingReply) ProtoReflect() protoreflect.Message {
mi := &file_oc_oc_proto_msgTypes[18]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DataEncodingReply.ProtoReflect.Descriptor instead.
func (*DataEncodingReply) Descriptor() ([]byte, []int) {
return file_oc_oc_proto_rawDescGZIP(), []int{18}
}
func (x *DataEncodingReply) GetEncodingList() []EncodingType {
if x != nil {
return x.EncodingList
}
return nil
}
var File_oc_oc_proto protoreflect.FileDescriptor
var file_oc_oc_proto_rawDesc = []byte{
0x0a, 0x0b, 0x6f, 0x63, 0x2f, 0x6f, 0x63, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x09, 0x74,
0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x22, 0xcd, 0x01, 0x0a, 0x13, 0x53, 0x75, 0x62,
0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x12, 0x32, 0x0a, 0x05, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
0x1c, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x53, 0x75, 0x62, 0x73,
0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x52, 0x05, 0x69,
0x6e, 0x70, 0x75, 0x74, 0x12, 0x2c, 0x0a, 0x09, 0x70, 0x61, 0x74, 0x68, 0x5f, 0x6c, 0x69, 0x73,
0x74, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65,
0x74, 0x72, 0x79, 0x2e, 0x50, 0x61, 0x74, 0x68, 0x52, 0x08, 0x70, 0x61, 0x74, 0x68, 0x4c, 0x69,
0x73, 0x74, 0x12, 0x54, 0x0a, 0x11, 0x61, 0x64, 0x64, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c,
0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e,
0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72,
0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x41, 0x64, 0x64, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c,
0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x10, 0x61, 0x64, 0x64, 0x69, 0x74, 0x69, 0x6f, 0x6e,
0x61, 0x6c, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x50, 0x0a, 0x11, 0x53, 0x75, 0x62, 0x73,
0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x12, 0x3b, 0x0a,
0x0e, 0x63, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x5f, 0x6c, 0x69, 0x73, 0x74, 0x18,
0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72,
0x79, 0x2e, 0x43, 0x6f, 0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x52, 0x0d, 0x63, 0x6f, 0x6c,
0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x4c, 0x69, 0x73, 0x74, 0x22, 0x39, 0x0a, 0x09, 0x43, 0x6f,
0x6c, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65,
0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73,
0x73, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52,
0x04, 0x70, 0x6f, 0x72, 0x74, 0x22, 0xd7, 0x01, 0x0a, 0x04, 0x50, 0x61, 0x74, 0x68, 0x12, 0x12,
0x0a, 0x04, 0x70, 0x61, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, 0x61,
0x74, 0x68, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01,
0x28, 0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x2d, 0x0a, 0x12, 0x73, 0x75,
0x70, 0x70, 0x72, 0x65, 0x73, 0x73, 0x5f, 0x75, 0x6e, 0x63, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x64,
0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x11, 0x73, 0x75, 0x70, 0x70, 0x72, 0x65, 0x73, 0x73,
0x55, 0x6e, 0x63, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x64, 0x12, 0x2e, 0x0a, 0x13, 0x6d, 0x61, 0x78,
0x5f, 0x73, 0x69, 0x6c, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c,
0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x11, 0x6d, 0x61, 0x78, 0x53, 0x69, 0x6c, 0x65, 0x6e,
0x74, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x12, 0x29, 0x0a, 0x10, 0x73, 0x61, 0x6d,
0x70, 0x6c, 0x65, 0x5f, 0x66, 0x72, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x79, 0x18, 0x05, 0x20,
0x01, 0x28, 0x0d, 0x52, 0x0f, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x46, 0x72, 0x65, 0x71, 0x75,
0x65, 0x6e, 0x63, 0x79, 0x12, 0x19, 0x0a, 0x08, 0x6e, 0x65, 0x65, 0x64, 0x5f, 0x65, 0x6f, 0x6d,
0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x6e, 0x65, 0x65, 0x64, 0x45, 0x6f, 0x6d, 0x22,
0x8c, 0x01, 0x0a, 0x1c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e,
0x41, 0x64, 0x64, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67,
0x12, 0x23, 0x0a, 0x0d, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x5f, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64,
0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0c, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x52, 0x65,
0x63, 0x6f, 0x72, 0x64, 0x73, 0x12, 0x2c, 0x0a, 0x12, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x5f, 0x74,
0x69, 0x6d, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28,
0x05, 0x52, 0x10, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x65, 0x63, 0x6f,
0x6e, 0x64, 0x73, 0x12, 0x19, 0x0a, 0x08, 0x6e, 0x65, 0x65, 0x64, 0x5f, 0x65, 0x6f, 0x73, 0x18,
0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x6e, 0x65, 0x65, 0x64, 0x45, 0x6f, 0x73, 0x22, 0x7e,
0x0a, 0x11, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65,
0x70, 0x6c, 0x79, 0x12, 0x3b, 0x0a, 0x08, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x18,
0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72,
0x79, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65,
0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x52, 0x08, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x12, 0x2c, 0x0a, 0x09, 0x70, 0x61, 0x74, 0x68, 0x5f, 0x6c, 0x69, 0x73, 0x74, 0x18, 0x02, 0x20,
0x03, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e,
0x50, 0x61, 0x74, 0x68, 0x52, 0x08, 0x70, 0x61, 0x74, 0x68, 0x4c, 0x69, 0x73, 0x74, 0x22, 0x3f,
0x0a, 0x14, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65,
0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72,
0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
0x0e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22,
0xec, 0x02, 0x0a, 0x0e, 0x4f, 0x70, 0x65, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x61,
0x74, 0x61, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x5f, 0x69, 0x64, 0x18,
0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x49, 0x64, 0x12,
0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6d, 0x70, 0x6f, 0x6e, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18,
0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x63, 0x6f, 0x6d, 0x70, 0x6f, 0x6e, 0x65, 0x6e, 0x74,
0x49, 0x64, 0x12, 0x28, 0x0a, 0x10, 0x73, 0x75, 0x62, 0x5f, 0x63, 0x6f, 0x6d, 0x70, 0x6f, 0x6e,
0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0e, 0x73, 0x75,
0x62, 0x43, 0x6f, 0x6d, 0x70, 0x6f, 0x6e, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04,
0x70, 0x61, 0x74, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68,
0x12, 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x5f, 0x6e, 0x75, 0x6d,
0x62, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0e, 0x73, 0x65, 0x71, 0x75, 0x65,
0x6e, 0x63, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d,
0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x06, 0x20, 0x01, 0x28, 0x04, 0x52, 0x09, 0x74, 0x69,
0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x23, 0x0a, 0x02, 0x6b, 0x76, 0x18, 0x07, 0x20,
0x03, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e,
0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x02, 0x6b, 0x76, 0x12, 0x29, 0x0a, 0x06,
0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x18, 0x08, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x74,
0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x52,
0x06, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x20, 0x0a, 0x03, 0x65, 0x6f, 0x6d, 0x18, 0x09,
0x20, 0x03, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79,
0x2e, 0x45, 0x6f, 0x6d, 0x52, 0x03, 0x65, 0x6f, 0x6d, 0x12, 0x23, 0x0a, 0x0d, 0x73, 0x79, 0x6e,
0x63, 0x5f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x08,
0x52, 0x0c, 0x73, 0x79, 0x6e, 0x63, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x8e,
0x02, 0x0a, 0x08, 0x4b, 0x65, 0x79, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6b,
0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x23, 0x0a,
0x0c, 0x64, 0x6f, 0x75, 0x62, 0x6c, 0x65, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x05, 0x20,
0x01, 0x28, 0x01, 0x48, 0x00, 0x52, 0x0b, 0x64, 0x6f, 0x75, 0x62, 0x6c, 0x65, 0x56, 0x61, 0x6c,
0x75, 0x65, 0x12, 0x1d, 0x0a, 0x09, 0x69, 0x6e, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
0x06, 0x20, 0x01, 0x28, 0x03, 0x48, 0x00, 0x52, 0x08, 0x69, 0x6e, 0x74, 0x56, 0x61, 0x6c, 0x75,
0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x75, 0x69, 0x6e, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
0x07, 0x20, 0x01, 0x28, 0x04, 0x48, 0x00, 0x52, 0x09, 0x75, 0x69, 0x6e, 0x74, 0x56, 0x61, 0x6c,
0x75, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x73, 0x69, 0x6e, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65,
0x18, 0x08, 0x20, 0x01, 0x28, 0x12, 0x48, 0x00, 0x52, 0x09, 0x73, 0x69, 0x6e, 0x74, 0x56, 0x61,
0x6c, 0x75, 0x65, 0x12, 0x1f, 0x0a, 0x0a, 0x62, 0x6f, 0x6f, 0x6c, 0x5f, 0x76, 0x61, 0x6c, 0x75,
0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x09, 0x62, 0x6f, 0x6f, 0x6c, 0x56,
0x61, 0x6c, 0x75, 0x65, 0x12, 0x1d, 0x0a, 0x09, 0x73, 0x74, 0x72, 0x5f, 0x76, 0x61, 0x6c, 0x75,
0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x08, 0x73, 0x74, 0x72, 0x56, 0x61,
0x6c, 0x75, 0x65, 0x12, 0x21, 0x0a, 0x0b, 0x62, 0x79, 0x74, 0x65, 0x73, 0x5f, 0x76, 0x61, 0x6c,
0x75, 0x65, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0a, 0x62, 0x79, 0x74, 0x65,
0x73, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x07, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22,
0x1c, 0x0a, 0x06, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x61, 0x74,
0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68, 0x22, 0x19, 0x0a,
0x03, 0x45, 0x6f, 0x6d, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x61, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01,
0x28, 0x09, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68, 0x22, 0x44, 0x0a, 0x19, 0x43, 0x61, 0x6e, 0x63,
0x65, 0x6c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65,
0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69,
0x70, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0e,
0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22, 0x5f,
0x0a, 0x17, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70,
0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x29, 0x0a, 0x04, 0x63, 0x6f, 0x64,
0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x15, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65,
0x74, 0x72, 0x79, 0x2e, 0x52, 0x65, 0x74, 0x75, 0x72, 0x6e, 0x43, 0x6f, 0x64, 0x65, 0x52, 0x04,
0x63, 0x6f, 0x64, 0x65, 0x12, 0x19, 0x0a, 0x08, 0x63, 0x6f, 0x64, 0x65, 0x5f, 0x73, 0x74, 0x72,
0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x64, 0x65, 0x53, 0x74, 0x72, 0x22,
0x42, 0x0a, 0x17, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69,
0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x75,
0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20,
0x01, 0x28, 0x0d, 0x52, 0x0e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f,
0x6e, 0x49, 0x64, 0x22, 0x62, 0x0a, 0x15, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72,
0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x49, 0x0a, 0x11,
0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6c, 0x69, 0x73,
0x74, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65,
0x74, 0x72, 0x79, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e,
0x52, 0x65, 0x70, 0x6c, 0x79, 0x52, 0x10, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74,
0x69, 0x6f, 0x6e, 0x4c, 0x69, 0x73, 0x74, 0x22, 0x7e, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x4f, 0x70,
0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x65,
0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69,
0x70, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0e,
0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x37,
0x0a, 0x09, 0x76, 0x65, 0x72, 0x62, 0x6f, 0x73, 0x69, 0x74, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28,
0x0e, 0x32, 0x19, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x56, 0x65,
0x72, 0x62, 0x6f, 0x73, 0x69, 0x74, 0x79, 0x4c, 0x65, 0x76, 0x65, 0x6c, 0x52, 0x09, 0x76, 0x65,
0x72, 0x62, 0x6f, 0x73, 0x69, 0x74, 0x79, 0x22, 0x3f, 0x0a, 0x18, 0x47, 0x65, 0x74, 0x4f, 0x70,
0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x65,
0x70, 0x6c, 0x79, 0x12, 0x23, 0x0a, 0x02, 0x6b, 0x76, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
0x13, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x4b, 0x65, 0x79, 0x56,
0x61, 0x6c, 0x75, 0x65, 0x52, 0x02, 0x6b, 0x76, 0x22, 0x15, 0x0a, 0x13, 0x44, 0x61, 0x74, 0x61,
0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22,
0x51, 0x0a, 0x11, 0x44, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x52,
0x65, 0x70, 0x6c, 0x79, 0x12, 0x3c, 0x0a, 0x0d, 0x65, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67,
0x5f, 0x6c, 0x69, 0x73, 0x74, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0e, 0x32, 0x17, 0x2e, 0x74, 0x65,
0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67,
0x54, 0x79, 0x70, 0x65, 0x52, 0x0c, 0x65, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x4c, 0x69,
0x73, 0x74, 0x2a, 0x47, 0x0a, 0x0a, 0x52, 0x65, 0x74, 0x75, 0x72, 0x6e, 0x43, 0x6f, 0x64, 0x65,
0x12, 0x0b, 0x0a, 0x07, 0x53, 0x55, 0x43, 0x43, 0x45, 0x53, 0x53, 0x10, 0x00, 0x12, 0x19, 0x0a,
0x15, 0x4e, 0x4f, 0x5f, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x50, 0x54, 0x49, 0x4f, 0x4e,
0x5f, 0x45, 0x4e, 0x54, 0x52, 0x59, 0x10, 0x01, 0x12, 0x11, 0x0a, 0x0d, 0x55, 0x4e, 0x4b, 0x4e,
0x4f, 0x57, 0x4e, 0x5f, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x10, 0x02, 0x2a, 0x32, 0x0a, 0x0e, 0x56,
0x65, 0x72, 0x62, 0x6f, 0x73, 0x69, 0x74, 0x79, 0x4c, 0x65, 0x76, 0x65, 0x6c, 0x12, 0x0a, 0x0a,
0x06, 0x44, 0x45, 0x54, 0x41, 0x49, 0x4c, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x54, 0x45, 0x52,
0x53, 0x45, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x42, 0x52, 0x49, 0x45, 0x46, 0x10, 0x02, 0x2a,
0x41, 0x0a, 0x0c, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x54, 0x79, 0x70, 0x65, 0x12,
0x0d, 0x0a, 0x09, 0x55, 0x4e, 0x44, 0x45, 0x46, 0x49, 0x4e, 0x45, 0x44, 0x10, 0x00, 0x12, 0x07,
0x0a, 0x03, 0x58, 0x4d, 0x4c, 0x10, 0x01, 0x12, 0x0d, 0x0a, 0x09, 0x4a, 0x53, 0x4f, 0x4e, 0x5f,
0x49, 0x45, 0x54, 0x46, 0x10, 0x02, 0x12, 0x0a, 0x0a, 0x06, 0x50, 0x52, 0x4f, 0x54, 0x4f, 0x33,
0x10, 0x03, 0x32, 0xfc, 0x03, 0x0a, 0x13, 0x4f, 0x70, 0x65, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69,
0x67, 0x54, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x12, 0x53, 0x0a, 0x12, 0x74, 0x65,
0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65,
0x12, 0x1e, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x53, 0x75, 0x62,
0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x1a, 0x19, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x4f, 0x70, 0x65,
0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x61, 0x74, 0x61, 0x22, 0x00, 0x30, 0x01, 0x12,
0x69, 0x0a, 0x1b, 0x63, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x54, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74,
0x72, 0x79, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x24,
0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x43, 0x61, 0x6e, 0x63, 0x65,
0x6c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71,
0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79,
0x2e, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74,
0x69, 0x6f, 0x6e, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x63, 0x0a, 0x19, 0x67, 0x65,
0x74, 0x54, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72,
0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x22, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65,
0x74, 0x72, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74,
0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x74, 0x65,
0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63,
0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12,
0x6c, 0x0a, 0x1c, 0x67, 0x65, 0x74, 0x54, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x4f,
0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12,
0x25, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x4f,
0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74,
0x72, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x61,
0x6c, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x52, 0x0a,
0x10, 0x67, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67,
0x73, 0x12, 0x1e, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x44, 0x61,
0x74, 0x61, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
0x74, 0x1a, 0x1c, 0x2e, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79, 0x2e, 0x44, 0x61,
0x74, 0x61, 0x45, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22,
0x00, 0x42, 0x0d, 0x5a, 0x0b, 0x2e, 0x3b, 0x74, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x74, 0x72, 0x79,
0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_oc_oc_proto_rawDescOnce sync.Once
file_oc_oc_proto_rawDescData = file_oc_oc_proto_rawDesc
)
func file_oc_oc_proto_rawDescGZIP() []byte {
file_oc_oc_proto_rawDescOnce.Do(func() {
file_oc_oc_proto_rawDescData = protoimpl.X.CompressGZIP(file_oc_oc_proto_rawDescData)
})
return file_oc_oc_proto_rawDescData
}
var file_oc_oc_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
var file_oc_oc_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
var file_oc_oc_proto_goTypes = []interface{}{
(ReturnCode)(0), // 0: telemetry.ReturnCode
(VerbosityLevel)(0), // 1: telemetry.VerbosityLevel
(EncodingType)(0), // 2: telemetry.EncodingType
(*SubscriptionRequest)(nil), // 3: telemetry.SubscriptionRequest
(*SubscriptionInput)(nil), // 4: telemetry.SubscriptionInput
(*Collector)(nil), // 5: telemetry.Collector
(*Path)(nil), // 6: telemetry.Path
(*SubscriptionAdditionalConfig)(nil), // 7: telemetry.SubscriptionAdditionalConfig
(*SubscriptionReply)(nil), // 8: telemetry.SubscriptionReply
(*SubscriptionResponse)(nil), // 9: telemetry.SubscriptionResponse
(*OpenConfigData)(nil), // 10: telemetry.OpenConfigData
(*KeyValue)(nil), // 11: telemetry.KeyValue
(*Delete)(nil), // 12: telemetry.Delete
(*Eom)(nil), // 13: telemetry.Eom
(*CancelSubscriptionRequest)(nil), // 14: telemetry.CancelSubscriptionRequest
(*CancelSubscriptionReply)(nil), // 15: telemetry.CancelSubscriptionReply
(*GetSubscriptionsRequest)(nil), // 16: telemetry.GetSubscriptionsRequest
(*GetSubscriptionsReply)(nil), // 17: telemetry.GetSubscriptionsReply
(*GetOperationalStateRequest)(nil), // 18: telemetry.GetOperationalStateRequest
(*GetOperationalStateReply)(nil), // 19: telemetry.GetOperationalStateReply
(*DataEncodingRequest)(nil), // 20: telemetry.DataEncodingRequest
(*DataEncodingReply)(nil), // 21: telemetry.DataEncodingReply
}
var file_oc_oc_proto_depIdxs = []int32{
4, // 0: telemetry.SubscriptionRequest.input:type_name -> telemetry.SubscriptionInput
6, // 1: telemetry.SubscriptionRequest.path_list:type_name -> telemetry.Path
7, // 2: telemetry.SubscriptionRequest.additional_config:type_name -> telemetry.SubscriptionAdditionalConfig
5, // 3: telemetry.SubscriptionInput.collector_list:type_name -> telemetry.Collector
9, // 4: telemetry.SubscriptionReply.response:type_name -> telemetry.SubscriptionResponse
6, // 5: telemetry.SubscriptionReply.path_list:type_name -> telemetry.Path
11, // 6: telemetry.OpenConfigData.kv:type_name -> telemetry.KeyValue
12, // 7: telemetry.OpenConfigData.delete:type_name -> telemetry.Delete
13, // 8: telemetry.OpenConfigData.eom:type_name -> telemetry.Eom
0, // 9: telemetry.CancelSubscriptionReply.code:type_name -> telemetry.ReturnCode
8, // 10: telemetry.GetSubscriptionsReply.subscription_list:type_name -> telemetry.SubscriptionReply
1, // 11: telemetry.GetOperationalStateRequest.verbosity:type_name -> telemetry.VerbosityLevel
11, // 12: telemetry.GetOperationalStateReply.kv:type_name -> telemetry.KeyValue
2, // 13: telemetry.DataEncodingReply.encoding_list:type_name -> telemetry.EncodingType
3, // 14: telemetry.OpenConfigTelemetry.telemetrySubscribe:input_type -> telemetry.SubscriptionRequest
14, // 15: telemetry.OpenConfigTelemetry.cancelTelemetrySubscription:input_type -> telemetry.CancelSubscriptionRequest
16, // 16: telemetry.OpenConfigTelemetry.getTelemetrySubscriptions:input_type -> telemetry.GetSubscriptionsRequest
18, // 17: telemetry.OpenConfigTelemetry.getTelemetryOperationalState:input_type -> telemetry.GetOperationalStateRequest
20, // 18: telemetry.OpenConfigTelemetry.getDataEncodings:input_type -> telemetry.DataEncodingRequest
10, // 19: telemetry.OpenConfigTelemetry.telemetrySubscribe:output_type -> telemetry.OpenConfigData
15, // 20: telemetry.OpenConfigTelemetry.cancelTelemetrySubscription:output_type -> telemetry.CancelSubscriptionReply
17, // 21: telemetry.OpenConfigTelemetry.getTelemetrySubscriptions:output_type -> telemetry.GetSubscriptionsReply
19, // 22: telemetry.OpenConfigTelemetry.getTelemetryOperationalState:output_type -> telemetry.GetOperationalStateReply
21, // 23: telemetry.OpenConfigTelemetry.getDataEncodings:output_type -> telemetry.DataEncodingReply
19, // [19:24] is the sub-list for method output_type
14, // [14:19] is the sub-list for method input_type
14, // [14:14] is the sub-list for extension type_name
14, // [14:14] is the sub-list for extension extendee
0, // [0:14] is the sub-list for field type_name
}
func init() { file_oc_oc_proto_init() }
func file_oc_oc_proto_init() {
if File_oc_oc_proto != nil {
return
}
if !protoimpl.UnsafeEnabled {
file_oc_oc_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SubscriptionRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SubscriptionInput); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Collector); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Path); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SubscriptionAdditionalConfig); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SubscriptionReply); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SubscriptionResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*OpenConfigData); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*KeyValue); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Delete); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Eom); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CancelSubscriptionRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CancelSubscriptionReply); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetSubscriptionsRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetSubscriptionsReply); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetOperationalStateRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetOperationalStateReply); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*DataEncodingRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_oc_oc_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*DataEncodingReply); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
file_oc_oc_proto_msgTypes[8].OneofWrappers = []interface{}{
(*KeyValue_DoubleValue)(nil),
(*KeyValue_IntValue)(nil),
(*KeyValue_UintValue)(nil),
(*KeyValue_SintValue)(nil),
(*KeyValue_BoolValue)(nil),
(*KeyValue_StrValue)(nil),
(*KeyValue_BytesValue)(nil),
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_oc_oc_proto_rawDesc,
NumEnums: 3,
NumMessages: 19,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_oc_oc_proto_goTypes,
DependencyIndexes: file_oc_oc_proto_depIdxs,
EnumInfos: file_oc_oc_proto_enumTypes,
MessageInfos: file_oc_oc_proto_msgTypes,
}.Build()
File_oc_oc_proto = out.File
file_oc_oc_proto_rawDesc = nil
file_oc_oc_proto_goTypes = nil
file_oc_oc_proto_depIdxs = nil
}
Copy permalink