Versions in this module Expand all Collapse all v1 v1.0.0 Oct 2, 2018 Changes in this version + var EncodingType_name = map[int32]string + var EncodingType_value = map[string]int32 + var ReturnCode_name = map[int32]string + var ReturnCode_value = map[string]int32 + var VerbosityLevel_name = map[int32]string + var VerbosityLevel_value = map[string]int32 + func RegisterOpenConfigTelemetryServer(s *grpc.Server, srv OpenConfigTelemetryServer) + type CancelSubscriptionReply struct + Code ReturnCode + CodeStr string + func (*CancelSubscriptionReply) Descriptor() ([]byte, []int) + func (*CancelSubscriptionReply) ProtoMessage() + func (m *CancelSubscriptionReply) GetCode() ReturnCode + func (m *CancelSubscriptionReply) GetCodeStr() string + func (m *CancelSubscriptionReply) Reset() + func (m *CancelSubscriptionReply) String() string + type CancelSubscriptionRequest struct + SubscriptionId uint32 + func (*CancelSubscriptionRequest) Descriptor() ([]byte, []int) + func (*CancelSubscriptionRequest) ProtoMessage() + func (m *CancelSubscriptionRequest) GetSubscriptionId() uint32 + func (m *CancelSubscriptionRequest) Reset() + func (m *CancelSubscriptionRequest) String() string + type Collector struct + Address string + Port uint32 + func (*Collector) Descriptor() ([]byte, []int) + func (*Collector) ProtoMessage() + func (m *Collector) GetAddress() string + func (m *Collector) GetPort() uint32 + func (m *Collector) Reset() + func (m *Collector) String() string + type DataEncodingReply struct + EncodingList []EncodingType + func (*DataEncodingReply) Descriptor() ([]byte, []int) + func (*DataEncodingReply) ProtoMessage() + func (m *DataEncodingReply) GetEncodingList() []EncodingType + func (m *DataEncodingReply) Reset() + func (m *DataEncodingReply) String() string + type DataEncodingRequest struct + func (*DataEncodingRequest) Descriptor() ([]byte, []int) + func (*DataEncodingRequest) ProtoMessage() + func (m *DataEncodingRequest) Reset() + func (m *DataEncodingRequest) String() string + type Delete struct + Path string + func (*Delete) Descriptor() ([]byte, []int) + func (*Delete) ProtoMessage() + func (m *Delete) GetPath() string + func (m *Delete) Reset() + func (m *Delete) String() string + type EncodingType int32 + const EncodingType_JSON_IETF + const EncodingType_PROTO3 + const EncodingType_UNDEFINED + const EncodingType_XML + func (EncodingType) EnumDescriptor() ([]byte, []int) + func (x EncodingType) String() string + type Eom struct + Path string + func (*Eom) Descriptor() ([]byte, []int) + func (*Eom) ProtoMessage() + func (m *Eom) GetPath() string + func (m *Eom) Reset() + func (m *Eom) String() string + type GetOperationalStateReply struct + Kv []*KeyValue + func (*GetOperationalStateReply) Descriptor() ([]byte, []int) + func (*GetOperationalStateReply) ProtoMessage() + func (m *GetOperationalStateReply) GetKv() []*KeyValue + func (m *GetOperationalStateReply) Reset() + func (m *GetOperationalStateReply) String() string + type GetOperationalStateRequest struct + SubscriptionId uint32 + Verbosity VerbosityLevel + func (*GetOperationalStateRequest) Descriptor() ([]byte, []int) + func (*GetOperationalStateRequest) ProtoMessage() + func (m *GetOperationalStateRequest) GetSubscriptionId() uint32 + func (m *GetOperationalStateRequest) GetVerbosity() VerbosityLevel + func (m *GetOperationalStateRequest) Reset() + func (m *GetOperationalStateRequest) String() string + type GetSubscriptionsReply struct + SubscriptionList []*SubscriptionReply + func (*GetSubscriptionsReply) Descriptor() ([]byte, []int) + func (*GetSubscriptionsReply) ProtoMessage() + func (m *GetSubscriptionsReply) GetSubscriptionList() []*SubscriptionReply + func (m *GetSubscriptionsReply) Reset() + func (m *GetSubscriptionsReply) String() string + type GetSubscriptionsRequest struct + SubscriptionId uint32 + func (*GetSubscriptionsRequest) Descriptor() ([]byte, []int) + func (*GetSubscriptionsRequest) ProtoMessage() + func (m *GetSubscriptionsRequest) GetSubscriptionId() uint32 + func (m *GetSubscriptionsRequest) Reset() + func (m *GetSubscriptionsRequest) String() string + type KeyValue struct + Key string + Value isKeyValue_Value + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (*KeyValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *KeyValue) GetBoolValue() bool + func (m *KeyValue) GetBytesValue() []byte + func (m *KeyValue) GetDoubleValue() float64 + func (m *KeyValue) GetIntValue() int64 + func (m *KeyValue) GetKey() string + func (m *KeyValue) GetSintValue() int64 + func (m *KeyValue) GetStrValue() string + func (m *KeyValue) GetUintValue() uint64 + func (m *KeyValue) GetValue() isKeyValue_Value + func (m *KeyValue) Reset() + func (m *KeyValue) String() string + type KeyValue_BoolValue struct + BoolValue bool + type KeyValue_BytesValue struct + BytesValue []byte + type KeyValue_DoubleValue struct + DoubleValue float64 + type KeyValue_IntValue struct + IntValue int64 + type KeyValue_SintValue struct + SintValue int64 + type KeyValue_StrValue struct + StrValue string + type KeyValue_UintValue struct + UintValue uint64 + type OpenConfigData struct + ComponentId uint32 + Delete []*Delete + Eom []*Eom + Kv []*KeyValue + Path string + SequenceNumber uint64 + SubComponentId uint32 + SyncResponse bool + SystemId string + Timestamp uint64 + func (*OpenConfigData) Descriptor() ([]byte, []int) + func (*OpenConfigData) ProtoMessage() + func (m *OpenConfigData) GetComponentId() uint32 + func (m *OpenConfigData) GetDelete() []*Delete + func (m *OpenConfigData) GetEom() []*Eom + func (m *OpenConfigData) GetKv() []*KeyValue + func (m *OpenConfigData) GetPath() string + func (m *OpenConfigData) GetSequenceNumber() uint64 + func (m *OpenConfigData) GetSubComponentId() uint32 + func (m *OpenConfigData) GetSyncResponse() bool + func (m *OpenConfigData) GetSystemId() string + func (m *OpenConfigData) GetTimestamp() uint64 + func (m *OpenConfigData) Reset() + func (m *OpenConfigData) String() string + type OpenConfigTelemetryClient interface + CancelTelemetrySubscription func(ctx context.Context, in *CancelSubscriptionRequest, opts ...grpc.CallOption) (*CancelSubscriptionReply, error) + GetDataEncodings func(ctx context.Context, in *DataEncodingRequest, opts ...grpc.CallOption) (*DataEncodingReply, error) + GetTelemetryOperationalState func(ctx context.Context, in *GetOperationalStateRequest, opts ...grpc.CallOption) (*GetOperationalStateReply, error) + GetTelemetrySubscriptions func(ctx context.Context, in *GetSubscriptionsRequest, opts ...grpc.CallOption) (*GetSubscriptionsReply, error) + TelemetrySubscribe func(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (OpenConfigTelemetry_TelemetrySubscribeClient, error) + func NewOpenConfigTelemetryClient(cc *grpc.ClientConn) OpenConfigTelemetryClient + type OpenConfigTelemetryServer interface + CancelTelemetrySubscription func(context.Context, *CancelSubscriptionRequest) (*CancelSubscriptionReply, error) + GetDataEncodings func(context.Context, *DataEncodingRequest) (*DataEncodingReply, error) + GetTelemetryOperationalState func(context.Context, *GetOperationalStateRequest) (*GetOperationalStateReply, error) + GetTelemetrySubscriptions func(context.Context, *GetSubscriptionsRequest) (*GetSubscriptionsReply, error) + TelemetrySubscribe func(*SubscriptionRequest, OpenConfigTelemetry_TelemetrySubscribeServer) error + type OpenConfigTelemetry_TelemetrySubscribeClient interface + Recv func() (*OpenConfigData, error) + type OpenConfigTelemetry_TelemetrySubscribeServer interface + Send func(*OpenConfigData) error + type Path struct + Filter string + MaxSilentInterval uint32 + NeedEom bool + Path string + SampleFrequency uint32 + SuppressUnchanged bool + func (*Path) Descriptor() ([]byte, []int) + func (*Path) ProtoMessage() + func (m *Path) GetFilter() string + func (m *Path) GetMaxSilentInterval() uint32 + func (m *Path) GetNeedEom() bool + func (m *Path) GetPath() string + func (m *Path) GetSampleFrequency() uint32 + func (m *Path) GetSuppressUnchanged() bool + func (m *Path) Reset() + func (m *Path) String() string + type ReturnCode int32 + const ReturnCode_NO_SUBSCRIPTION_ENTRY + const ReturnCode_SUCCESS + const ReturnCode_UNKNOWN_ERROR + func (ReturnCode) EnumDescriptor() ([]byte, []int) + func (x ReturnCode) String() string + type SubscriptionAdditionalConfig struct + LimitRecords int32 + LimitTimeSeconds int32 + NeedEos bool + func (*SubscriptionAdditionalConfig) Descriptor() ([]byte, []int) + func (*SubscriptionAdditionalConfig) ProtoMessage() + func (m *SubscriptionAdditionalConfig) GetLimitRecords() int32 + func (m *SubscriptionAdditionalConfig) GetLimitTimeSeconds() int32 + func (m *SubscriptionAdditionalConfig) GetNeedEos() bool + func (m *SubscriptionAdditionalConfig) Reset() + func (m *SubscriptionAdditionalConfig) String() string + type SubscriptionInput struct + CollectorList []*Collector + func (*SubscriptionInput) Descriptor() ([]byte, []int) + func (*SubscriptionInput) ProtoMessage() + func (m *SubscriptionInput) GetCollectorList() []*Collector + func (m *SubscriptionInput) Reset() + func (m *SubscriptionInput) String() string + type SubscriptionReply struct + PathList []*Path + Response *SubscriptionResponse + func (*SubscriptionReply) Descriptor() ([]byte, []int) + func (*SubscriptionReply) ProtoMessage() + func (m *SubscriptionReply) GetPathList() []*Path + func (m *SubscriptionReply) GetResponse() *SubscriptionResponse + func (m *SubscriptionReply) Reset() + func (m *SubscriptionReply) String() string + type SubscriptionRequest struct + AdditionalConfig *SubscriptionAdditionalConfig + Input *SubscriptionInput + PathList []*Path + func (*SubscriptionRequest) Descriptor() ([]byte, []int) + func (*SubscriptionRequest) ProtoMessage() + func (m *SubscriptionRequest) GetAdditionalConfig() *SubscriptionAdditionalConfig + func (m *SubscriptionRequest) GetInput() *SubscriptionInput + func (m *SubscriptionRequest) GetPathList() []*Path + func (m *SubscriptionRequest) Reset() + func (m *SubscriptionRequest) String() string + type SubscriptionResponse struct + SubscriptionId uint32 + func (*SubscriptionResponse) Descriptor() ([]byte, []int) + func (*SubscriptionResponse) ProtoMessage() + func (m *SubscriptionResponse) GetSubscriptionId() uint32 + func (m *SubscriptionResponse) Reset() + func (m *SubscriptionResponse) String() string + type VerbosityLevel int32 + const VerbosityLevel_BRIEF + const VerbosityLevel_DETAIL + const VerbosityLevel_TERSE + func (VerbosityLevel) EnumDescriptor() ([]byte, []int) + func (x VerbosityLevel) String() string
Go to main page