Documentation ¶
Index ¶
- Variables
- func NewJagwConnection(f interface{}) (connection *grpc.ClientConn, err error)
- func RegisterRequestServiceServer(s grpc.ServiceRegistrar, srv RequestServiceServer)
- func RegisterSubscriptionServiceServer(s grpc.ServiceRegistrar, srv SubscriptionServiceServer)
- type JagwEndpoint
- type LsLink
- func (*LsLink) Descriptor() ([]byte, []int)deprecated
- func (x *LsLink) GetAreaId() string
- func (x *LsLink) GetDomainId() int64
- func (x *LsLink) GetId() string
- func (x *LsLink) GetIgpMetric() uint32
- func (x *LsLink) GetIgpRouterId() string
- func (x *LsLink) GetKey() string
- func (x *LsLink) GetLocalLinkId() string
- func (x *LsLink) GetLocalLinkIp() string
- func (x *LsLink) GetLocalNodeHash() string
- func (x *LsLink) GetMaxLinkBwKbps() uint64
- func (x *LsLink) GetMtid() *MultiTopologyIdentifier
- func (x *LsLink) GetNexthop() string
- func (x *LsLink) GetPeerAsn() int32
- func (x *LsLink) GetPeerHash() string
- func (x *LsLink) GetPeerIp() string
- func (x *LsLink) GetProtocol() string
- func (x *LsLink) GetRemoteIgpRouterId() string
- func (x *LsLink) GetRemoteLinkId() string
- func (x *LsLink) GetRemoteLinkIp() string
- func (x *LsLink) GetRemoteNodeHash() string
- func (x *LsLink) GetRouterHash() string
- func (x *LsLink) GetRouterIp() string
- func (x *LsLink) GetTimestamp() string
- func (x *LsLink) GetUnidirAvailableBw() uint32
- func (x *LsLink) GetUnidirBwUtilization() uint32
- func (x *LsLink) GetUnidirDelayVariation() uint32
- func (x *LsLink) GetUnidirLinkDelay() uint32
- func (x *LsLink) GetUnidirLinkDelayMinMax() []uint32
- func (x *LsLink) GetUnidirPacketLoss() float32
- func (x *LsLink) GetUnidirResidualBw() uint32
- func (*LsLink) ProtoMessage()
- func (x *LsLink) ProtoReflect() protoreflect.Message
- func (x *LsLink) Reset()
- func (x *LsLink) String() string
- type LsLinkEvent
- func (*LsLinkEvent) Descriptor() ([]byte, []int)deprecated
- func (x *LsLinkEvent) GetAction() string
- func (x *LsLinkEvent) GetKey() string
- func (x *LsLinkEvent) GetLsLink() *LsLink
- func (*LsLinkEvent) ProtoMessage()
- func (x *LsLinkEvent) ProtoReflect() protoreflect.Message
- func (x *LsLinkEvent) Reset()
- func (x *LsLinkEvent) String() string
- type LsLinkResponse
- type LsNode
- func (*LsNode) Descriptor() ([]byte, []int)deprecated
- func (x *LsNode) GetAreaId() string
- func (x *LsNode) GetAsn() uint32
- func (x *LsNode) GetDomainId() int64
- func (x *LsNode) GetId() string
- func (x *LsNode) GetIgpRouterId() string
- func (x *LsNode) GetIsAdjRibIn() bool
- func (x *LsNode) GetIsPrepolicy() bool
- func (x *LsNode) GetKey() string
- func (x *LsNode) GetMtid() []*MultiTopologyIdentifier
- func (x *LsNode) GetName() string
- func (x *LsNode) GetPeerAsn() int32
- func (x *LsNode) GetPeerHash() string
- func (x *LsNode) GetPeerIp() string
- func (x *LsNode) GetProtocol() string
- func (x *LsNode) GetProtocolId() uint32
- func (x *LsNode) GetRouterHash() string
- func (x *LsNode) GetRouterIp() string
- func (x *LsNode) GetTimestamp() string
- func (*LsNode) ProtoMessage()
- func (x *LsNode) ProtoReflect() protoreflect.Message
- func (x *LsNode) Reset()
- func (x *LsNode) String() string
- type LsNodeCoordinates
- func (*LsNodeCoordinates) Descriptor() ([]byte, []int)deprecated
- func (x *LsNodeCoordinates) GetId() string
- func (x *LsNodeCoordinates) GetKey() string
- func (x *LsNodeCoordinates) GetLatitude() float64
- func (x *LsNodeCoordinates) GetLongitude() float64
- func (x *LsNodeCoordinates) GetLsNodeKey() string
- func (*LsNodeCoordinates) ProtoMessage()
- func (x *LsNodeCoordinates) ProtoReflect() protoreflect.Message
- func (x *LsNodeCoordinates) Reset()
- func (x *LsNodeCoordinates) String() string
- type LsNodeCoordinatesRequest
- func (*LsNodeCoordinatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LsNodeCoordinatesRequest) GetLsNodeKeys() []string
- func (*LsNodeCoordinatesRequest) ProtoMessage()
- func (x *LsNodeCoordinatesRequest) ProtoReflect() protoreflect.Message
- func (x *LsNodeCoordinatesRequest) Reset()
- func (x *LsNodeCoordinatesRequest) String() string
- type LsNodeCoordinatesResponse
- func (*LsNodeCoordinatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LsNodeCoordinatesResponse) GetCoordinates() []*LsNodeCoordinates
- func (*LsNodeCoordinatesResponse) ProtoMessage()
- func (x *LsNodeCoordinatesResponse) ProtoReflect() protoreflect.Message
- func (x *LsNodeCoordinatesResponse) Reset()
- func (x *LsNodeCoordinatesResponse) String() string
- type LsNodeEdge
- func (*LsNodeEdge) Descriptor() ([]byte, []int)deprecated
- func (x *LsNodeEdge) GetFrom() string
- func (x *LsNodeEdge) GetId() string
- func (x *LsNodeEdge) GetKey() string
- func (x *LsNodeEdge) GetLink() string
- func (x *LsNodeEdge) GetTo() string
- func (*LsNodeEdge) ProtoMessage()
- func (x *LsNodeEdge) ProtoReflect() protoreflect.Message
- func (x *LsNodeEdge) Reset()
- func (x *LsNodeEdge) String() string
- type LsNodeEdgeEvent
- func (*LsNodeEdgeEvent) Descriptor() ([]byte, []int)deprecated
- func (x *LsNodeEdgeEvent) GetAction() string
- func (x *LsNodeEdgeEvent) GetKey() string
- func (x *LsNodeEdgeEvent) GetLsNodeEdge() *LsNodeEdge
- func (*LsNodeEdgeEvent) ProtoMessage()
- func (x *LsNodeEdgeEvent) ProtoReflect() protoreflect.Message
- func (x *LsNodeEdgeEvent) Reset()
- func (x *LsNodeEdgeEvent) String() string
- type LsNodeEdgeResponse
- func (*LsNodeEdgeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LsNodeEdgeResponse) GetLsNodeEdges() []*LsNodeEdge
- func (*LsNodeEdgeResponse) ProtoMessage()
- func (x *LsNodeEdgeResponse) ProtoReflect() protoreflect.Message
- func (x *LsNodeEdgeResponse) Reset()
- func (x *LsNodeEdgeResponse) String() string
- type LsNodeEvent
- func (*LsNodeEvent) Descriptor() ([]byte, []int)deprecated
- func (x *LsNodeEvent) GetAction() string
- func (x *LsNodeEvent) GetKey() string
- func (x *LsNodeEvent) GetLsNode() *LsNode
- func (*LsNodeEvent) ProtoMessage()
- func (x *LsNodeEvent) ProtoReflect() protoreflect.Message
- func (x *LsNodeEvent) Reset()
- func (x *LsNodeEvent) String() string
- type LsNodeResponse
- type LsPrefix
- func (*LsPrefix) Descriptor() ([]byte, []int)deprecated
- func (x *LsPrefix) GetAreaId() string
- func (x *LsPrefix) GetDomainId() int64
- func (x *LsPrefix) GetId() string
- func (x *LsPrefix) GetIgpRouterId() string
- func (x *LsPrefix) GetIsAdjRibIn() bool
- func (x *LsPrefix) GetIsPrepolicy() bool
- func (x *LsPrefix) GetKey() string
- func (x *LsPrefix) GetLocalNodeHash() string
- func (x *LsPrefix) GetMtid() *MultiTopologyIdentifier
- func (x *LsPrefix) GetNexthop() string
- func (x *LsPrefix) GetPeerAsn() int32
- func (x *LsPrefix) GetPeerHash() string
- func (x *LsPrefix) GetPeerIp() string
- func (x *LsPrefix) GetPrefix() string
- func (x *LsPrefix) GetPrefixLen() int32
- func (x *LsPrefix) GetPrefixMetric() uint32
- func (x *LsPrefix) GetProtocol() string
- func (x *LsPrefix) GetRouterHash() string
- func (x *LsPrefix) GetRouterIp() string
- func (x *LsPrefix) GetTimestamp() string
- func (*LsPrefix) ProtoMessage()
- func (x *LsPrefix) ProtoReflect() protoreflect.Message
- func (x *LsPrefix) Reset()
- func (x *LsPrefix) String() string
- type LsPrefixEvent
- func (*LsPrefixEvent) Descriptor() ([]byte, []int)deprecated
- func (x *LsPrefixEvent) GetAction() string
- func (x *LsPrefixEvent) GetKey() string
- func (x *LsPrefixEvent) GetLsPrefix() *LsPrefix
- func (*LsPrefixEvent) ProtoMessage()
- func (x *LsPrefixEvent) ProtoReflect() protoreflect.Message
- func (x *LsPrefixEvent) Reset()
- func (x *LsPrefixEvent) String() string
- type LsPrefixResponse
- type LsSrv6Sid
- func (*LsSrv6Sid) Descriptor() ([]byte, []int)deprecated
- func (x *LsSrv6Sid) GetDomainId() int64
- func (x *LsSrv6Sid) GetId() string
- func (x *LsSrv6Sid) GetIgpFlags() uint32
- func (x *LsSrv6Sid) GetIgpRouterId() string
- func (x *LsSrv6Sid) GetIsAdjRibIn() bool
- func (x *LsSrv6Sid) GetIsPrepolicy() bool
- func (x *LsSrv6Sid) GetKey() string
- func (x *LsSrv6Sid) GetLocalNodeAsn() uint32
- func (x *LsSrv6Sid) GetLocalNodeHash() string
- func (x *LsSrv6Sid) GetMtid() *MultiTopologyIdentifier
- func (x *LsSrv6Sid) GetNexthop() string
- func (x *LsSrv6Sid) GetPeerAsn() int32
- func (x *LsSrv6Sid) GetPeerHash() string
- func (x *LsSrv6Sid) GetPeerIp() string
- func (x *LsSrv6Sid) GetProtocol() string
- func (x *LsSrv6Sid) GetRouterHash() string
- func (x *LsSrv6Sid) GetRouterIp() string
- func (x *LsSrv6Sid) GetSrv6Sid() string
- func (x *LsSrv6Sid) GetTimestamp() string
- func (*LsSrv6Sid) ProtoMessage()
- func (x *LsSrv6Sid) ProtoReflect() protoreflect.Message
- func (x *LsSrv6Sid) Reset()
- func (x *LsSrv6Sid) String() string
- type LsSrv6SidEvent
- func (*LsSrv6SidEvent) Descriptor() ([]byte, []int)deprecated
- func (x *LsSrv6SidEvent) GetAction() string
- func (x *LsSrv6SidEvent) GetKey() string
- func (x *LsSrv6SidEvent) GetLsSrv6Sid() *LsSrv6Sid
- func (*LsSrv6SidEvent) ProtoMessage()
- func (x *LsSrv6SidEvent) ProtoReflect() protoreflect.Message
- func (x *LsSrv6SidEvent) Reset()
- func (x *LsSrv6SidEvent) String() string
- type LsSrv6SidResponse
- func (*LsSrv6SidResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LsSrv6SidResponse) GetLsSrv6Sids() []*LsSrv6Sid
- func (*LsSrv6SidResponse) ProtoMessage()
- func (x *LsSrv6SidResponse) ProtoReflect() protoreflect.Message
- func (x *LsSrv6SidResponse) Reset()
- func (x *LsSrv6SidResponse) String() string
- type Measurement
- func (*Measurement) Descriptor() ([]byte, []int)deprecated
- func (x *Measurement) GetName() string
- func (x *Measurement) GetTimestampLatestMeasurement() int64
- func (*Measurement) ProtoMessage()
- func (x *Measurement) ProtoReflect() protoreflect.Message
- func (x *Measurement) Reset()
- func (x *Measurement) String() string
- type MeasurementColumn
- func (*MeasurementColumn) Descriptor() ([]byte, []int)deprecated
- func (x *MeasurementColumn) GetInfluxType() string
- func (x *MeasurementColumn) GetLastValueStringyfied() string
- func (x *MeasurementColumn) GetName() string
- func (x *MeasurementColumn) GetType() string
- func (*MeasurementColumn) ProtoMessage()
- func (x *MeasurementColumn) ProtoReflect() protoreflect.Message
- func (x *MeasurementColumn) Reset()
- func (x *MeasurementColumn) String() string
- type MeasurementDetailsRequest
- func (*MeasurementDetailsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MeasurementDetailsRequest) GetName() string
- func (*MeasurementDetailsRequest) ProtoMessage()
- func (x *MeasurementDetailsRequest) ProtoReflect() protoreflect.Message
- func (x *MeasurementDetailsRequest) Reset()
- func (x *MeasurementDetailsRequest) String() string
- type MeasurementDetailsResponse
- func (*MeasurementDetailsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MeasurementDetailsResponse) GetColumns() []*MeasurementColumn
- func (x *MeasurementDetailsResponse) GetTimestampLatestMeasurement() int64
- func (*MeasurementDetailsResponse) ProtoMessage()
- func (x *MeasurementDetailsResponse) ProtoReflect() protoreflect.Message
- func (x *MeasurementDetailsResponse) Reset()
- func (x *MeasurementDetailsResponse) String() string
- type MeasurementsRequest
- type MeasurementsResponse
- func (*MeasurementsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MeasurementsResponse) GetMeasurements() []*Measurement
- func (*MeasurementsResponse) ProtoMessage()
- func (x *MeasurementsResponse) ProtoReflect() protoreflect.Message
- func (x *MeasurementsResponse) Reset()
- func (x *MeasurementsResponse) String() string
- type MultiTopologyIdentifier
- func (*MultiTopologyIdentifier) Descriptor() ([]byte, []int)deprecated
- func (x *MultiTopologyIdentifier) GetAFlag() bool
- func (x *MultiTopologyIdentifier) GetMtid() uint32
- func (x *MultiTopologyIdentifier) GetOFlag() bool
- func (*MultiTopologyIdentifier) ProtoMessage()
- func (x *MultiTopologyIdentifier) ProtoReflect() protoreflect.Message
- func (x *MultiTopologyIdentifier) Reset()
- func (x *MultiTopologyIdentifier) String() string
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)deprecated
- func (x *Peer) GetId() string
- func (x *Peer) GetKey() string
- func (x *Peer) GetLocalBgpId() string
- func (x *Peer) GetRemoteBgpId() string
- func (x *Peer) GetRouterHash() string
- func (*Peer) ProtoMessage()
- func (x *Peer) ProtoReflect() protoreflect.Message
- func (x *Peer) Reset()
- func (x *Peer) String() string
- type PeerEvent
- func (*PeerEvent) Descriptor() ([]byte, []int)deprecated
- func (x *PeerEvent) GetAction() string
- func (x *PeerEvent) GetKey() string
- func (x *PeerEvent) GetPeer() *Peer
- func (*PeerEvent) ProtoMessage()
- func (x *PeerEvent) ProtoReflect() protoreflect.Message
- func (x *PeerEvent) Reset()
- func (x *PeerEvent) String() string
- type PeerResponse
- type RangeFilter
- func (*RangeFilter) Descriptor() ([]byte, []int)deprecated
- func (x *RangeFilter) GetEarliestTimestamp() int64
- func (x *RangeFilter) GetLatestTimestamp() int64
- func (*RangeFilter) ProtoMessage()
- func (x *RangeFilter) ProtoReflect() protoreflect.Message
- func (x *RangeFilter) Reset()
- func (x *RangeFilter) String() string
- type RequestServiceClient
- type RequestServiceServer
- type StringFilter
- func (*StringFilter) Descriptor() ([]byte, []int)deprecated
- func (x *StringFilter) GetOperator() StringOperator
- func (x *StringFilter) GetProperty() string
- func (x *StringFilter) GetValue() string
- func (*StringFilter) ProtoMessage()
- func (x *StringFilter) ProtoReflect() protoreflect.Message
- func (x *StringFilter) Reset()
- func (x *StringFilter) String() string
- type StringOperator
- func (StringOperator) Descriptor() protoreflect.EnumDescriptor
- func (x StringOperator) Enum() *StringOperator
- func (StringOperator) EnumDescriptor() ([]byte, []int)deprecated
- func (x StringOperator) Number() protoreflect.EnumNumber
- func (x StringOperator) String() string
- func (StringOperator) Type() protoreflect.EnumType
- func (x *StringOperator) UnmarshalJSON(b []byte) errordeprecated
- type SubscriptionServiceClient
- type SubscriptionServiceServer
- type SubscriptionService_SubscribeToLsLinksClient
- type SubscriptionService_SubscribeToLsLinksServer
- type SubscriptionService_SubscribeToLsNodeEdgesClient
- type SubscriptionService_SubscribeToLsNodeEdgesServer
- type SubscriptionService_SubscribeToLsNodesClient
- type SubscriptionService_SubscribeToLsNodesServer
- type SubscriptionService_SubscribeToLsPrefixesClient
- type SubscriptionService_SubscribeToLsPrefixesServer
- type SubscriptionService_SubscribeToLsSrv6SidsClient
- type SubscriptionService_SubscribeToLsSrv6SidsServer
- type SubscriptionService_SubscribeToPeersClient
- type SubscriptionService_SubscribeToPeersServer
- type SubscriptionService_SubscribeToTelemetryDataClient
- type SubscriptionService_SubscribeToTelemetryDataServer
- type TelemetryEvent
- type TelemetryRequest
- func (*TelemetryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryRequest) GetProperties() []string
- func (x *TelemetryRequest) GetRangeFilter() *RangeFilter
- func (x *TelemetryRequest) GetSensorPath() string
- func (x *TelemetryRequest) GetStringFilters() []*StringFilter
- func (x *TelemetryRequest) GetUnflatten() bool
- func (*TelemetryRequest) ProtoMessage()
- func (x *TelemetryRequest) ProtoReflect() protoreflect.Message
- func (x *TelemetryRequest) Reset()
- func (x *TelemetryRequest) String() string
- type TelemetryResponse
- func (*TelemetryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryResponse) GetTelemetryData() []string
- func (*TelemetryResponse) ProtoMessage()
- func (x *TelemetryResponse) ProtoReflect() protoreflect.Message
- func (x *TelemetryResponse) Reset()
- func (x *TelemetryResponse) String() string
- type TelemetrySubscription
- func (*TelemetrySubscription) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetrySubscription) GetProperties() []string
- func (x *TelemetrySubscription) GetSensorPath() string
- func (x *TelemetrySubscription) GetStringFilters() []*StringFilter
- func (x *TelemetrySubscription) GetUnflatten() bool
- func (*TelemetrySubscription) ProtoMessage()
- func (x *TelemetrySubscription) ProtoReflect() protoreflect.Message
- func (x *TelemetrySubscription) Reset()
- func (x *TelemetrySubscription) String() string
- type TopologyRequest
- func (*TopologyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TopologyRequest) GetKeys() []string
- func (x *TopologyRequest) GetProperties() []string
- func (*TopologyRequest) ProtoMessage()
- func (x *TopologyRequest) ProtoReflect() protoreflect.Message
- func (x *TopologyRequest) Reset()
- func (x *TopologyRequest) String() string
- type TopologySubscription
- func (*TopologySubscription) Descriptor() ([]byte, []int)deprecated
- func (x *TopologySubscription) GetKeys() []string
- func (x *TopologySubscription) GetProperties() []string
- func (*TopologySubscription) ProtoMessage()
- func (x *TopologySubscription) ProtoReflect() protoreflect.Message
- func (x *TopologySubscription) Reset()
- func (x *TopologySubscription) String() string
- type UnimplementedRequestServiceServer
- func (UnimplementedRequestServiceServer) GetLsLinks(context.Context, *TopologyRequest) (*LsLinkResponse, error)
- func (UnimplementedRequestServiceServer) GetLsNodeCoordinates(context.Context, *LsNodeCoordinatesRequest) (*LsNodeCoordinatesResponse, error)
- func (UnimplementedRequestServiceServer) GetLsNodeEdges(context.Context, *TopologyRequest) (*LsNodeEdgeResponse, error)
- func (UnimplementedRequestServiceServer) GetLsNodes(context.Context, *TopologyRequest) (*LsNodeResponse, error)
- func (UnimplementedRequestServiceServer) GetLsPrefixes(context.Context, *TopologyRequest) (*LsPrefixResponse, error)
- func (UnimplementedRequestServiceServer) GetLsSrv6Sids(context.Context, *TopologyRequest) (*LsSrv6SidResponse, error)
- func (UnimplementedRequestServiceServer) GetMeasurementDetails(context.Context, *MeasurementDetailsRequest) (*MeasurementDetailsResponse, error)
- func (UnimplementedRequestServiceServer) GetMeasurements(context.Context, *MeasurementsRequest) (*MeasurementsResponse, error)
- func (UnimplementedRequestServiceServer) GetPeers(context.Context, *TopologyRequest) (*PeerResponse, error)
- func (UnimplementedRequestServiceServer) GetTelemetryData(context.Context, *TelemetryRequest) (*TelemetryResponse, error)
- type UnimplementedSubscriptionServiceServer
- func (UnimplementedSubscriptionServiceServer) SubscribeToLsLinks(*TopologySubscription, SubscriptionService_SubscribeToLsLinksServer) error
- func (UnimplementedSubscriptionServiceServer) SubscribeToLsNodeEdges(*TopologySubscription, SubscriptionService_SubscribeToLsNodeEdgesServer) error
- func (UnimplementedSubscriptionServiceServer) SubscribeToLsNodes(*TopologySubscription, SubscriptionService_SubscribeToLsNodesServer) error
- func (UnimplementedSubscriptionServiceServer) SubscribeToLsPrefixes(*TopologySubscription, SubscriptionService_SubscribeToLsPrefixesServer) error
- func (UnimplementedSubscriptionServiceServer) SubscribeToLsSrv6Sids(*TopologySubscription, SubscriptionService_SubscribeToLsSrv6SidsServer) error
- func (UnimplementedSubscriptionServiceServer) SubscribeToPeers(*TopologySubscription, SubscriptionService_SubscribeToPeersServer) error
- func (UnimplementedSubscriptionServiceServer) SubscribeToTelemetryData(*TelemetrySubscription, SubscriptionService_SubscribeToTelemetryDataServer) error
- type UnsafeRequestServiceServer
- type UnsafeSubscriptionServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( StringOperator_name = map[int32]string{ 1: "EQUAL", 2: "NOT_EQUAL", } StringOperator_value = map[string]int32{ "EQUAL": 1, "NOT_EQUAL": 2, } )
Enum value maps for StringOperator.
var File_core_base_proto protoreflect.FileDescriptor
var File_core_enums_proto protoreflect.FileDescriptor
var File_core_filters_proto protoreflect.FileDescriptor
var File_core_topology_proto protoreflect.FileDescriptor
var File_requestservice_requestservice_proto protoreflect.FileDescriptor
var File_subscriptionservice_subscriptionservice_proto protoreflect.FileDescriptor
var RequestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jagw.RequestService", HandlerType: (*RequestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetLsNodes", Handler: _RequestService_GetLsNodes_Handler, }, { MethodName: "GetLsLinks", Handler: _RequestService_GetLsLinks_Handler, }, { MethodName: "GetLsPrefixes", Handler: _RequestService_GetLsPrefixes_Handler, }, { MethodName: "GetLsSrv6Sids", Handler: _RequestService_GetLsSrv6Sids_Handler, }, { MethodName: "GetLsNodeEdges", Handler: _RequestService_GetLsNodeEdges_Handler, }, { MethodName: "GetPeers", Handler: _RequestService_GetPeers_Handler, }, { MethodName: "GetLsNodeCoordinates", Handler: _RequestService_GetLsNodeCoordinates_Handler, }, { MethodName: "GetTelemetryData", Handler: _RequestService_GetTelemetryData_Handler, }, { MethodName: "GetMeasurements", Handler: _RequestService_GetMeasurements_Handler, }, { MethodName: "GetMeasurementDetails", Handler: _RequestService_GetMeasurementDetails_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "requestservice/requestservice.proto", }
RequestService_ServiceDesc is the grpc.ServiceDesc for RequestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SubscriptionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jagw.SubscriptionService", HandlerType: (*SubscriptionServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "SubscribeToLsNodes", Handler: _SubscriptionService_SubscribeToLsNodes_Handler, ServerStreams: true, }, { StreamName: "SubscribeToLsLinks", Handler: _SubscriptionService_SubscribeToLsLinks_Handler, ServerStreams: true, }, { StreamName: "SubscribeToLsPrefixes", Handler: _SubscriptionService_SubscribeToLsPrefixes_Handler, ServerStreams: true, }, { StreamName: "SubscribeToLsSrv6Sids", Handler: _SubscriptionService_SubscribeToLsSrv6Sids_Handler, ServerStreams: true, }, { StreamName: "SubscribeToLsNodeEdges", Handler: _SubscriptionService_SubscribeToLsNodeEdges_Handler, ServerStreams: true, }, { StreamName: "SubscribeToPeers", Handler: _SubscriptionService_SubscribeToPeers_Handler, ServerStreams: true, }, { StreamName: "SubscribeToTelemetryData", Handler: _SubscriptionService_SubscribeToTelemetryData_Handler, ServerStreams: true, }, }, Metadata: "subscriptionservice/subscriptionservice.proto", }
SubscriptionService_ServiceDesc is the grpc.ServiceDesc for SubscriptionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func NewJagwConnection ¶
func NewJagwConnection(f interface{}) (connection *grpc.ClientConn, err error)
func RegisterRequestServiceServer ¶
func RegisterRequestServiceServer(s grpc.ServiceRegistrar, srv RequestServiceServer)
func RegisterSubscriptionServiceServer ¶
func RegisterSubscriptionServiceServer(s grpc.ServiceRegistrar, srv SubscriptionServiceServer)
Types ¶
type JagwEndpoint ¶
type LsLink ¶
type LsLink struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"` RouterHash *string `protobuf:"bytes,3,opt,name=router_hash,json=routerHash" json:"router_hash,omitempty"` RouterIp *string `protobuf:"bytes,4,opt,name=router_ip,json=routerIp" json:"router_ip,omitempty"` DomainId *int64 `protobuf:"varint,5,opt,name=domain_id,json=domainId" json:"domain_id,omitempty"` PeerHash *string `protobuf:"bytes,6,opt,name=peer_hash,json=peerHash" json:"peer_hash,omitempty"` PeerIp *string `protobuf:"bytes,7,opt,name=peer_ip,json=peerIp" json:"peer_ip,omitempty"` PeerAsn *int32 `protobuf:"varint,8,opt,name=peer_asn,json=peerAsn" json:"peer_asn,omitempty"` Timestamp *string `protobuf:"bytes,9,opt,name=timestamp" json:"timestamp,omitempty"` IgpRouterId *string `protobuf:"bytes,10,opt,name=igp_router_id,json=igpRouterId" json:"igp_router_id,omitempty"` Protocol *string `protobuf:"bytes,11,opt,name=protocol" json:"protocol,omitempty"` AreaId *string `protobuf:"bytes,12,opt,name=area_id,json=areaId" json:"area_id,omitempty"` Nexthop *string `protobuf:"bytes,13,opt,name=nexthop" json:"nexthop,omitempty"` Mtid *MultiTopologyIdentifier `protobuf:"bytes,14,opt,name=mtid" json:"mtid,omitempty"` LocalLinkId *string `protobuf:"bytes,15,opt,name=local_link_id,json=localLinkId" json:"local_link_id,omitempty"` RemoteLinkId *string `protobuf:"bytes,16,opt,name=remote_link_id,json=remoteLinkId" json:"remote_link_id,omitempty"` LocalLinkIp *string `protobuf:"bytes,17,opt,name=local_link_ip,json=localLinkIp" json:"local_link_ip,omitempty"` RemoteLinkIp *string `protobuf:"bytes,18,opt,name=remote_link_ip,json=remoteLinkIp" json:"remote_link_ip,omitempty"` IgpMetric *uint32 `protobuf:"varint,19,opt,name=igp_metric,json=igpMetric" json:"igp_metric,omitempty"` RemoteNodeHash *string `protobuf:"bytes,20,opt,name=remote_node_hash,json=remoteNodeHash" json:"remote_node_hash,omitempty"` LocalNodeHash *string `protobuf:"bytes,21,opt,name=local_node_hash,json=localNodeHash" json:"local_node_hash,omitempty"` RemoteIgpRouterId *string `protobuf:"bytes,22,opt,name=remote_igp_router_id,json=remoteIgpRouterId" json:"remote_igp_router_id,omitempty"` UnidirLinkDelay *uint32 `protobuf:"varint,23,opt,name=unidir_link_delay,json=unidirLinkDelay" json:"unidir_link_delay,omitempty"` UnidirLinkDelayMinMax []uint32 `protobuf:"varint,24,rep,name=unidir_link_delay_min_max,json=unidirLinkDelayMinMax" json:"unidir_link_delay_min_max,omitempty"` MaxLinkBwKbps *uint64 `protobuf:"varint,25,opt,name=max_link_bw_kbps,json=maxLinkBwKbps" json:"max_link_bw_kbps,omitempty"` UnidirDelayVariation *uint32 `protobuf:"varint,26,opt,name=unidir_delay_variation,json=unidirDelayVariation" json:"unidir_delay_variation,omitempty"` UnidirPacketLoss *float32 `protobuf:"fixed32,27,opt,name=unidir_packet_loss,json=unidirPacketLoss" json:"unidir_packet_loss,omitempty"` UnidirResidualBw *uint32 `protobuf:"varint,28,opt,name=unidir_residual_bw,json=unidirResidualBw" json:"unidir_residual_bw,omitempty"` UnidirAvailableBw *uint32 `protobuf:"varint,29,opt,name=unidir_available_bw,json=unidirAvailableBw" json:"unidir_available_bw,omitempty"` UnidirBwUtilization *uint32 `protobuf:"varint,30,opt,name=unidir_bw_utilization,json=unidirBwUtilization" json:"unidir_bw_utilization,omitempty"` // contains filtered or unexported fields }
func (*LsLink) Descriptor
deprecated
func (*LsLink) GetDomainId ¶
func (*LsLink) GetIgpMetric ¶
func (*LsLink) GetIgpRouterId ¶
func (*LsLink) GetLocalLinkId ¶
func (*LsLink) GetLocalLinkIp ¶
func (*LsLink) GetLocalNodeHash ¶
func (*LsLink) GetMaxLinkBwKbps ¶ added in v1.3.4
func (*LsLink) GetMtid ¶
func (x *LsLink) GetMtid() *MultiTopologyIdentifier
func (*LsLink) GetNexthop ¶
func (*LsLink) GetPeerAsn ¶
func (*LsLink) GetPeerHash ¶
func (*LsLink) GetProtocol ¶
func (*LsLink) GetRemoteIgpRouterId ¶
func (*LsLink) GetRemoteLinkId ¶
func (*LsLink) GetRemoteLinkIp ¶
func (*LsLink) GetRemoteNodeHash ¶
func (*LsLink) GetRouterHash ¶
func (*LsLink) GetRouterIp ¶
func (*LsLink) GetTimestamp ¶
func (*LsLink) GetUnidirAvailableBw ¶ added in v1.3.4
func (*LsLink) GetUnidirBwUtilization ¶ added in v1.3.4
func (*LsLink) GetUnidirDelayVariation ¶ added in v1.3.4
func (*LsLink) GetUnidirLinkDelay ¶ added in v1.3.3
func (*LsLink) GetUnidirLinkDelayMinMax ¶ added in v1.3.3
func (*LsLink) GetUnidirPacketLoss ¶ added in v1.3.4
func (*LsLink) GetUnidirResidualBw ¶ added in v1.3.4
func (*LsLink) ProtoMessage ¶
func (*LsLink) ProtoMessage()
func (*LsLink) ProtoReflect ¶
func (x *LsLink) ProtoReflect() protoreflect.Message
type LsLinkEvent ¶
type LsLinkEvent struct { Action *string `protobuf:"bytes,1,req,name=action" json:"action,omitempty"` Key *string `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` LsLink *LsLink `protobuf:"bytes,3,opt,name=ls_link,json=lsLink" json:"ls_link,omitempty"` // contains filtered or unexported fields }
func (*LsLinkEvent) Descriptor
deprecated
func (*LsLinkEvent) Descriptor() ([]byte, []int)
Deprecated: Use LsLinkEvent.ProtoReflect.Descriptor instead.
func (*LsLinkEvent) GetAction ¶
func (x *LsLinkEvent) GetAction() string
func (*LsLinkEvent) GetKey ¶
func (x *LsLinkEvent) GetKey() string
func (*LsLinkEvent) GetLsLink ¶
func (x *LsLinkEvent) GetLsLink() *LsLink
func (*LsLinkEvent) ProtoMessage ¶
func (*LsLinkEvent) ProtoMessage()
func (*LsLinkEvent) ProtoReflect ¶
func (x *LsLinkEvent) ProtoReflect() protoreflect.Message
func (*LsLinkEvent) Reset ¶
func (x *LsLinkEvent) Reset()
func (*LsLinkEvent) String ¶
func (x *LsLinkEvent) String() string
type LsLinkResponse ¶
type LsLinkResponse struct { LsLinks []*LsLink `protobuf:"bytes,1,rep,name=ls_links,json=lsLinks" json:"ls_links,omitempty"` // contains filtered or unexported fields }
func (*LsLinkResponse) Descriptor
deprecated
func (*LsLinkResponse) Descriptor() ([]byte, []int)
Deprecated: Use LsLinkResponse.ProtoReflect.Descriptor instead.
func (*LsLinkResponse) GetLsLinks ¶
func (x *LsLinkResponse) GetLsLinks() []*LsLink
func (*LsLinkResponse) ProtoMessage ¶
func (*LsLinkResponse) ProtoMessage()
func (*LsLinkResponse) ProtoReflect ¶
func (x *LsLinkResponse) ProtoReflect() protoreflect.Message
func (*LsLinkResponse) Reset ¶
func (x *LsLinkResponse) Reset()
func (*LsLinkResponse) String ¶
func (x *LsLinkResponse) String() string
type LsNode ¶
type LsNode struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"` RouterHash *string `protobuf:"bytes,3,opt,name=router_hash,json=routerHash" json:"router_hash,omitempty"` DomainId *int64 `protobuf:"varint,4,opt,name=domain_id,json=domainId" json:"domain_id,omitempty"` RouterIp *string `protobuf:"bytes,5,opt,name=router_ip,json=routerIp" json:"router_ip,omitempty"` PeerHash *string `protobuf:"bytes,6,opt,name=peer_hash,json=peerHash" json:"peer_hash,omitempty"` PeerIp *string `protobuf:"bytes,7,opt,name=peer_ip,json=peerIp" json:"peer_ip,omitempty"` PeerAsn *int32 `protobuf:"varint,8,opt,name=peer_asn,json=peerAsn" json:"peer_asn,omitempty"` Timestamp *string `protobuf:"bytes,9,opt,name=timestamp" json:"timestamp,omitempty"` IgpRouterId *string `protobuf:"bytes,10,opt,name=igp_router_id,json=igpRouterId" json:"igp_router_id,omitempty"` Asn *uint32 `protobuf:"varint,11,opt,name=asn" json:"asn,omitempty"` Mtid []*MultiTopologyIdentifier `protobuf:"bytes,12,rep,name=mtid" json:"mtid,omitempty"` AreaId *string `protobuf:"bytes,13,opt,name=area_id,json=areaId" json:"area_id,omitempty"` Protocol *string `protobuf:"bytes,14,opt,name=protocol" json:"protocol,omitempty"` ProtocolId *uint32 `protobuf:"varint,15,opt,name=protocol_id,json=protocolId" json:"protocol_id,omitempty"` // protobuf does not support uint8 Name *string `protobuf:"bytes,16,opt,name=name" json:"name,omitempty"` IsPrepolicy *bool `protobuf:"varint,17,opt,name=is_prepolicy,json=isPrepolicy" json:"is_prepolicy,omitempty"` IsAdjRibIn *bool `protobuf:"varint,18,opt,name=is_adj_rib_in,json=isAdjRibIn" json:"is_adj_rib_in,omitempty"` // contains filtered or unexported fields }
func (*LsNode) Descriptor
deprecated
func (*LsNode) GetDomainId ¶
func (*LsNode) GetIgpRouterId ¶
func (*LsNode) GetIsAdjRibIn ¶
func (*LsNode) GetIsPrepolicy ¶
func (*LsNode) GetMtid ¶
func (x *LsNode) GetMtid() []*MultiTopologyIdentifier
func (*LsNode) GetPeerAsn ¶
func (*LsNode) GetPeerHash ¶
func (*LsNode) GetProtocol ¶
func (*LsNode) GetProtocolId ¶
func (*LsNode) GetRouterHash ¶
func (*LsNode) GetRouterIp ¶
func (*LsNode) GetTimestamp ¶
func (*LsNode) ProtoMessage ¶
func (*LsNode) ProtoMessage()
func (*LsNode) ProtoReflect ¶
func (x *LsNode) ProtoReflect() protoreflect.Message
type LsNodeCoordinates ¶
type LsNodeCoordinates struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"` LsNodeKey *string `protobuf:"bytes,3,req,name=ls_node_key,json=lsNodeKey" json:"ls_node_key,omitempty"` Latitude *float64 `protobuf:"fixed64,4,req,name=latitude" json:"latitude,omitempty"` Longitude *float64 `protobuf:"fixed64,5,req,name=longitude" json:"longitude,omitempty"` // contains filtered or unexported fields }
func (*LsNodeCoordinates) Descriptor
deprecated
func (*LsNodeCoordinates) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeCoordinates.ProtoReflect.Descriptor instead.
func (*LsNodeCoordinates) GetId ¶
func (x *LsNodeCoordinates) GetId() string
func (*LsNodeCoordinates) GetKey ¶
func (x *LsNodeCoordinates) GetKey() string
func (*LsNodeCoordinates) GetLatitude ¶
func (x *LsNodeCoordinates) GetLatitude() float64
func (*LsNodeCoordinates) GetLongitude ¶
func (x *LsNodeCoordinates) GetLongitude() float64
func (*LsNodeCoordinates) GetLsNodeKey ¶
func (x *LsNodeCoordinates) GetLsNodeKey() string
func (*LsNodeCoordinates) ProtoMessage ¶
func (*LsNodeCoordinates) ProtoMessage()
func (*LsNodeCoordinates) ProtoReflect ¶
func (x *LsNodeCoordinates) ProtoReflect() protoreflect.Message
func (*LsNodeCoordinates) Reset ¶
func (x *LsNodeCoordinates) Reset()
func (*LsNodeCoordinates) String ¶
func (x *LsNodeCoordinates) String() string
type LsNodeCoordinatesRequest ¶
type LsNodeCoordinatesRequest struct { LsNodeKeys []string `protobuf:"bytes,1,rep,name=ls_node_keys,json=lsNodeKeys" json:"ls_node_keys,omitempty"` // contains filtered or unexported fields }
func (*LsNodeCoordinatesRequest) Descriptor
deprecated
func (*LsNodeCoordinatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeCoordinatesRequest.ProtoReflect.Descriptor instead.
func (*LsNodeCoordinatesRequest) GetLsNodeKeys ¶
func (x *LsNodeCoordinatesRequest) GetLsNodeKeys() []string
func (*LsNodeCoordinatesRequest) ProtoMessage ¶
func (*LsNodeCoordinatesRequest) ProtoMessage()
func (*LsNodeCoordinatesRequest) ProtoReflect ¶
func (x *LsNodeCoordinatesRequest) ProtoReflect() protoreflect.Message
func (*LsNodeCoordinatesRequest) Reset ¶
func (x *LsNodeCoordinatesRequest) Reset()
func (*LsNodeCoordinatesRequest) String ¶
func (x *LsNodeCoordinatesRequest) String() string
type LsNodeCoordinatesResponse ¶
type LsNodeCoordinatesResponse struct { Coordinates []*LsNodeCoordinates `protobuf:"bytes,1,rep,name=coordinates" json:"coordinates,omitempty"` // contains filtered or unexported fields }
func (*LsNodeCoordinatesResponse) Descriptor
deprecated
func (*LsNodeCoordinatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeCoordinatesResponse.ProtoReflect.Descriptor instead.
func (*LsNodeCoordinatesResponse) GetCoordinates ¶
func (x *LsNodeCoordinatesResponse) GetCoordinates() []*LsNodeCoordinates
func (*LsNodeCoordinatesResponse) ProtoMessage ¶
func (*LsNodeCoordinatesResponse) ProtoMessage()
func (*LsNodeCoordinatesResponse) ProtoReflect ¶
func (x *LsNodeCoordinatesResponse) ProtoReflect() protoreflect.Message
func (*LsNodeCoordinatesResponse) Reset ¶
func (x *LsNodeCoordinatesResponse) Reset()
func (*LsNodeCoordinatesResponse) String ¶
func (x *LsNodeCoordinatesResponse) String() string
type LsNodeEdge ¶
type LsNodeEdge struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"` From *string `protobuf:"bytes,3,opt,name=from" json:"from,omitempty"` To *string `protobuf:"bytes,4,opt,name=to" json:"to,omitempty"` Link *string `protobuf:"bytes,5,opt,name=link" json:"link,omitempty"` // contains filtered or unexported fields }
func (*LsNodeEdge) Descriptor
deprecated
func (*LsNodeEdge) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeEdge.ProtoReflect.Descriptor instead.
func (*LsNodeEdge) GetFrom ¶
func (x *LsNodeEdge) GetFrom() string
func (*LsNodeEdge) GetId ¶
func (x *LsNodeEdge) GetId() string
func (*LsNodeEdge) GetKey ¶
func (x *LsNodeEdge) GetKey() string
func (*LsNodeEdge) GetLink ¶
func (x *LsNodeEdge) GetLink() string
func (*LsNodeEdge) GetTo ¶
func (x *LsNodeEdge) GetTo() string
func (*LsNodeEdge) ProtoMessage ¶
func (*LsNodeEdge) ProtoMessage()
func (*LsNodeEdge) ProtoReflect ¶
func (x *LsNodeEdge) ProtoReflect() protoreflect.Message
func (*LsNodeEdge) Reset ¶
func (x *LsNodeEdge) Reset()
func (*LsNodeEdge) String ¶
func (x *LsNodeEdge) String() string
type LsNodeEdgeEvent ¶
type LsNodeEdgeEvent struct { Action *string `protobuf:"bytes,1,req,name=action" json:"action,omitempty"` Key *string `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` LsNodeEdge *LsNodeEdge `protobuf:"bytes,3,opt,name=ls_node_edge,json=lsNodeEdge" json:"ls_node_edge,omitempty"` // contains filtered or unexported fields }
func (*LsNodeEdgeEvent) Descriptor
deprecated
func (*LsNodeEdgeEvent) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeEdgeEvent.ProtoReflect.Descriptor instead.
func (*LsNodeEdgeEvent) GetAction ¶
func (x *LsNodeEdgeEvent) GetAction() string
func (*LsNodeEdgeEvent) GetKey ¶
func (x *LsNodeEdgeEvent) GetKey() string
func (*LsNodeEdgeEvent) GetLsNodeEdge ¶
func (x *LsNodeEdgeEvent) GetLsNodeEdge() *LsNodeEdge
func (*LsNodeEdgeEvent) ProtoMessage ¶
func (*LsNodeEdgeEvent) ProtoMessage()
func (*LsNodeEdgeEvent) ProtoReflect ¶
func (x *LsNodeEdgeEvent) ProtoReflect() protoreflect.Message
func (*LsNodeEdgeEvent) Reset ¶
func (x *LsNodeEdgeEvent) Reset()
func (*LsNodeEdgeEvent) String ¶
func (x *LsNodeEdgeEvent) String() string
type LsNodeEdgeResponse ¶
type LsNodeEdgeResponse struct { LsNodeEdges []*LsNodeEdge `protobuf:"bytes,1,rep,name=ls_node_edges,json=lsNodeEdges" json:"ls_node_edges,omitempty"` // contains filtered or unexported fields }
func (*LsNodeEdgeResponse) Descriptor
deprecated
func (*LsNodeEdgeResponse) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeEdgeResponse.ProtoReflect.Descriptor instead.
func (*LsNodeEdgeResponse) GetLsNodeEdges ¶
func (x *LsNodeEdgeResponse) GetLsNodeEdges() []*LsNodeEdge
func (*LsNodeEdgeResponse) ProtoMessage ¶
func (*LsNodeEdgeResponse) ProtoMessage()
func (*LsNodeEdgeResponse) ProtoReflect ¶
func (x *LsNodeEdgeResponse) ProtoReflect() protoreflect.Message
func (*LsNodeEdgeResponse) Reset ¶
func (x *LsNodeEdgeResponse) Reset()
func (*LsNodeEdgeResponse) String ¶
func (x *LsNodeEdgeResponse) String() string
type LsNodeEvent ¶
type LsNodeEvent struct { Action *string `protobuf:"bytes,1,req,name=action" json:"action,omitempty"` Key *string `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` LsNode *LsNode `protobuf:"bytes,3,opt,name=ls_node,json=lsNode" json:"ls_node,omitempty"` // contains filtered or unexported fields }
func (*LsNodeEvent) Descriptor
deprecated
func (*LsNodeEvent) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeEvent.ProtoReflect.Descriptor instead.
func (*LsNodeEvent) GetAction ¶
func (x *LsNodeEvent) GetAction() string
func (*LsNodeEvent) GetKey ¶
func (x *LsNodeEvent) GetKey() string
func (*LsNodeEvent) GetLsNode ¶
func (x *LsNodeEvent) GetLsNode() *LsNode
func (*LsNodeEvent) ProtoMessage ¶
func (*LsNodeEvent) ProtoMessage()
func (*LsNodeEvent) ProtoReflect ¶
func (x *LsNodeEvent) ProtoReflect() protoreflect.Message
func (*LsNodeEvent) Reset ¶
func (x *LsNodeEvent) Reset()
func (*LsNodeEvent) String ¶
func (x *LsNodeEvent) String() string
type LsNodeResponse ¶
type LsNodeResponse struct { LsNodes []*LsNode `protobuf:"bytes,1,rep,name=ls_nodes,json=lsNodes" json:"ls_nodes,omitempty"` // contains filtered or unexported fields }
func (*LsNodeResponse) Descriptor
deprecated
func (*LsNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use LsNodeResponse.ProtoReflect.Descriptor instead.
func (*LsNodeResponse) GetLsNodes ¶
func (x *LsNodeResponse) GetLsNodes() []*LsNode
func (*LsNodeResponse) ProtoMessage ¶
func (*LsNodeResponse) ProtoMessage()
func (*LsNodeResponse) ProtoReflect ¶
func (x *LsNodeResponse) ProtoReflect() protoreflect.Message
func (*LsNodeResponse) Reset ¶
func (x *LsNodeResponse) Reset()
func (*LsNodeResponse) String ¶
func (x *LsNodeResponse) String() string
type LsPrefix ¶
type LsPrefix struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"` RouterHash *string `protobuf:"bytes,3,opt,name=router_hash,json=routerHash" json:"router_hash,omitempty"` RouterIp *string `protobuf:"bytes,4,opt,name=router_ip,json=routerIp" json:"router_ip,omitempty"` DomainId *int64 `protobuf:"varint,5,opt,name=domain_id,json=domainId" json:"domain_id,omitempty"` PeerHash *string `protobuf:"bytes,6,opt,name=peer_hash,json=peerHash" json:"peer_hash,omitempty"` PeerIp *string `protobuf:"bytes,7,opt,name=peer_ip,json=peerIp" json:"peer_ip,omitempty"` PeerAsn *int32 `protobuf:"varint,8,opt,name=peer_asn,json=peerAsn" json:"peer_asn,omitempty"` Timestamp *string `protobuf:"bytes,9,opt,name=timestamp" json:"timestamp,omitempty"` IgpRouterId *string `protobuf:"bytes,10,opt,name=igp_router_id,json=igpRouterId" json:"igp_router_id,omitempty"` Protocol *string `protobuf:"bytes,11,opt,name=protocol" json:"protocol,omitempty"` AreaId *string `protobuf:"bytes,12,opt,name=area_id,json=areaId" json:"area_id,omitempty"` Nexthop *string `protobuf:"bytes,13,opt,name=nexthop" json:"nexthop,omitempty"` LocalNodeHash *string `protobuf:"bytes,14,opt,name=local_node_hash,json=localNodeHash" json:"local_node_hash,omitempty"` Mtid *MultiTopologyIdentifier `protobuf:"bytes,15,opt,name=mtid" json:"mtid,omitempty"` Prefix *string `protobuf:"bytes,16,opt,name=prefix" json:"prefix,omitempty"` PrefixLen *int32 `protobuf:"varint,17,opt,name=prefix_len,json=prefixLen" json:"prefix_len,omitempty"` PrefixMetric *uint32 `protobuf:"varint,18,opt,name=prefix_metric,json=prefixMetric" json:"prefix_metric,omitempty"` IsPrepolicy *bool `protobuf:"varint,19,opt,name=is_prepolicy,json=isPrepolicy" json:"is_prepolicy,omitempty"` IsAdjRibIn *bool `protobuf:"varint,20,opt,name=is_adj_rib_in,json=isAdjRibIn" json:"is_adj_rib_in,omitempty"` // contains filtered or unexported fields }
func (*LsPrefix) Descriptor
deprecated
func (*LsPrefix) GetDomainId ¶
func (*LsPrefix) GetIgpRouterId ¶
func (*LsPrefix) GetIsAdjRibIn ¶
func (*LsPrefix) GetIsPrepolicy ¶
func (*LsPrefix) GetLocalNodeHash ¶
func (*LsPrefix) GetMtid ¶
func (x *LsPrefix) GetMtid() *MultiTopologyIdentifier
func (*LsPrefix) GetNexthop ¶
func (*LsPrefix) GetPeerAsn ¶
func (*LsPrefix) GetPeerHash ¶
func (*LsPrefix) GetPrefixLen ¶
func (*LsPrefix) GetPrefixMetric ¶
func (*LsPrefix) GetProtocol ¶
func (*LsPrefix) GetRouterHash ¶
func (*LsPrefix) GetRouterIp ¶
func (*LsPrefix) GetTimestamp ¶
func (*LsPrefix) ProtoMessage ¶
func (*LsPrefix) ProtoMessage()
func (*LsPrefix) ProtoReflect ¶
func (x *LsPrefix) ProtoReflect() protoreflect.Message
type LsPrefixEvent ¶
type LsPrefixEvent struct { Action *string `protobuf:"bytes,1,req,name=action" json:"action,omitempty"` Key *string `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` LsPrefix *LsPrefix `protobuf:"bytes,3,opt,name=ls_prefix,json=lsPrefix" json:"ls_prefix,omitempty"` // contains filtered or unexported fields }
func (*LsPrefixEvent) Descriptor
deprecated
func (*LsPrefixEvent) Descriptor() ([]byte, []int)
Deprecated: Use LsPrefixEvent.ProtoReflect.Descriptor instead.
func (*LsPrefixEvent) GetAction ¶
func (x *LsPrefixEvent) GetAction() string
func (*LsPrefixEvent) GetKey ¶
func (x *LsPrefixEvent) GetKey() string
func (*LsPrefixEvent) GetLsPrefix ¶
func (x *LsPrefixEvent) GetLsPrefix() *LsPrefix
func (*LsPrefixEvent) ProtoMessage ¶
func (*LsPrefixEvent) ProtoMessage()
func (*LsPrefixEvent) ProtoReflect ¶
func (x *LsPrefixEvent) ProtoReflect() protoreflect.Message
func (*LsPrefixEvent) Reset ¶
func (x *LsPrefixEvent) Reset()
func (*LsPrefixEvent) String ¶
func (x *LsPrefixEvent) String() string
type LsPrefixResponse ¶
type LsPrefixResponse struct { LsPrefixes []*LsPrefix `protobuf:"bytes,1,rep,name=ls_prefixes,json=lsPrefixes" json:"ls_prefixes,omitempty"` // contains filtered or unexported fields }
func (*LsPrefixResponse) Descriptor
deprecated
func (*LsPrefixResponse) Descriptor() ([]byte, []int)
Deprecated: Use LsPrefixResponse.ProtoReflect.Descriptor instead.
func (*LsPrefixResponse) GetLsPrefixes ¶
func (x *LsPrefixResponse) GetLsPrefixes() []*LsPrefix
func (*LsPrefixResponse) ProtoMessage ¶
func (*LsPrefixResponse) ProtoMessage()
func (*LsPrefixResponse) ProtoReflect ¶
func (x *LsPrefixResponse) ProtoReflect() protoreflect.Message
func (*LsPrefixResponse) Reset ¶
func (x *LsPrefixResponse) Reset()
func (*LsPrefixResponse) String ¶
func (x *LsPrefixResponse) String() string
type LsSrv6Sid ¶
type LsSrv6Sid struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"` RouterHash *string `protobuf:"bytes,3,opt,name=router_hash,json=routerHash" json:"router_hash,omitempty"` RouterIp *string `protobuf:"bytes,4,opt,name=router_ip,json=routerIp" json:"router_ip,omitempty"` DomainId *int64 `protobuf:"varint,5,opt,name=domain_id,json=domainId" json:"domain_id,omitempty"` PeerHash *string `protobuf:"bytes,6,opt,name=peer_hash,json=peerHash" json:"peer_hash,omitempty"` PeerIp *string `protobuf:"bytes,7,opt,name=peer_ip,json=peerIp" json:"peer_ip,omitempty"` PeerAsn *int32 `protobuf:"varint,8,opt,name=peer_asn,json=peerAsn" json:"peer_asn,omitempty"` Timestamp *string `protobuf:"bytes,9,opt,name=timestamp" json:"timestamp,omitempty"` IgpRouterId *string `protobuf:"bytes,10,opt,name=igp_router_id,json=igpRouterId" json:"igp_router_id,omitempty"` LocalNodeAsn *uint32 `protobuf:"varint,11,opt,name=local_node_asn,json=localNodeAsn" json:"local_node_asn,omitempty"` Protocol *string `protobuf:"bytes,12,opt,name=protocol" json:"protocol,omitempty"` Nexthop *string `protobuf:"bytes,13,opt,name=nexthop" json:"nexthop,omitempty"` LocalNodeHash *string `protobuf:"bytes,14,opt,name=local_node_hash,json=localNodeHash" json:"local_node_hash,omitempty"` Mtid *MultiTopologyIdentifier `protobuf:"bytes,15,opt,name=mtid" json:"mtid,omitempty"` IgpFlags *uint32 `protobuf:"varint,16,opt,name=igp_flags,json=igpFlags" json:"igp_flags,omitempty"` // protobuf does not support uint8 IsPrepolicy *bool `protobuf:"varint,17,opt,name=is_prepolicy,json=isPrepolicy" json:"is_prepolicy,omitempty"` IsAdjRibIn *bool `protobuf:"varint,18,opt,name=is_adj_rib_in,json=isAdjRibIn" json:"is_adj_rib_in,omitempty"` Srv6Sid *string `protobuf:"bytes,19,opt,name=srv6_sid,json=srv6Sid" json:"srv6_sid,omitempty"` // contains filtered or unexported fields }
func (*LsSrv6Sid) Descriptor
deprecated
func (*LsSrv6Sid) GetDomainId ¶
func (*LsSrv6Sid) GetIgpFlags ¶
func (*LsSrv6Sid) GetIgpRouterId ¶
func (*LsSrv6Sid) GetIsAdjRibIn ¶
func (*LsSrv6Sid) GetIsPrepolicy ¶
func (*LsSrv6Sid) GetLocalNodeAsn ¶
func (*LsSrv6Sid) GetLocalNodeHash ¶
func (*LsSrv6Sid) GetMtid ¶
func (x *LsSrv6Sid) GetMtid() *MultiTopologyIdentifier
func (*LsSrv6Sid) GetNexthop ¶
func (*LsSrv6Sid) GetPeerAsn ¶
func (*LsSrv6Sid) GetPeerHash ¶
func (*LsSrv6Sid) GetProtocol ¶
func (*LsSrv6Sid) GetRouterHash ¶
func (*LsSrv6Sid) GetRouterIp ¶
func (*LsSrv6Sid) GetSrv6Sid ¶
func (*LsSrv6Sid) GetTimestamp ¶
func (*LsSrv6Sid) ProtoMessage ¶
func (*LsSrv6Sid) ProtoMessage()
func (*LsSrv6Sid) ProtoReflect ¶
func (x *LsSrv6Sid) ProtoReflect() protoreflect.Message
type LsSrv6SidEvent ¶
type LsSrv6SidEvent struct { Action *string `protobuf:"bytes,1,req,name=action" json:"action,omitempty"` Key *string `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` LsSrv6Sid *LsSrv6Sid `protobuf:"bytes,3,opt,name=ls_srv6_sid,json=lsSrv6Sid" json:"ls_srv6_sid,omitempty"` // contains filtered or unexported fields }
func (*LsSrv6SidEvent) Descriptor
deprecated
func (*LsSrv6SidEvent) Descriptor() ([]byte, []int)
Deprecated: Use LsSrv6SidEvent.ProtoReflect.Descriptor instead.
func (*LsSrv6SidEvent) GetAction ¶
func (x *LsSrv6SidEvent) GetAction() string
func (*LsSrv6SidEvent) GetKey ¶
func (x *LsSrv6SidEvent) GetKey() string
func (*LsSrv6SidEvent) GetLsSrv6Sid ¶
func (x *LsSrv6SidEvent) GetLsSrv6Sid() *LsSrv6Sid
func (*LsSrv6SidEvent) ProtoMessage ¶
func (*LsSrv6SidEvent) ProtoMessage()
func (*LsSrv6SidEvent) ProtoReflect ¶
func (x *LsSrv6SidEvent) ProtoReflect() protoreflect.Message
func (*LsSrv6SidEvent) Reset ¶
func (x *LsSrv6SidEvent) Reset()
func (*LsSrv6SidEvent) String ¶
func (x *LsSrv6SidEvent) String() string
type LsSrv6SidResponse ¶
type LsSrv6SidResponse struct { LsSrv6Sids []*LsSrv6Sid `protobuf:"bytes,1,rep,name=ls_srv6_sids,json=lsSrv6Sids" json:"ls_srv6_sids,omitempty"` // contains filtered or unexported fields }
func (*LsSrv6SidResponse) Descriptor
deprecated
func (*LsSrv6SidResponse) Descriptor() ([]byte, []int)
Deprecated: Use LsSrv6SidResponse.ProtoReflect.Descriptor instead.
func (*LsSrv6SidResponse) GetLsSrv6Sids ¶
func (x *LsSrv6SidResponse) GetLsSrv6Sids() []*LsSrv6Sid
func (*LsSrv6SidResponse) ProtoMessage ¶
func (*LsSrv6SidResponse) ProtoMessage()
func (*LsSrv6SidResponse) ProtoReflect ¶
func (x *LsSrv6SidResponse) ProtoReflect() protoreflect.Message
func (*LsSrv6SidResponse) Reset ¶
func (x *LsSrv6SidResponse) Reset()
func (*LsSrv6SidResponse) String ¶
func (x *LsSrv6SidResponse) String() string
type Measurement ¶
type Measurement struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` TimestampLatestMeasurement *int64 `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Measurement) Descriptor
deprecated
func (*Measurement) Descriptor() ([]byte, []int)
Deprecated: Use Measurement.ProtoReflect.Descriptor instead.
func (*Measurement) GetName ¶
func (x *Measurement) GetName() string
func (*Measurement) GetTimestampLatestMeasurement ¶
func (x *Measurement) GetTimestampLatestMeasurement() int64
func (*Measurement) ProtoMessage ¶
func (*Measurement) ProtoMessage()
func (*Measurement) ProtoReflect ¶
func (x *Measurement) ProtoReflect() protoreflect.Message
func (*Measurement) Reset ¶
func (x *Measurement) Reset()
func (*Measurement) String ¶
func (x *Measurement) String() string
type MeasurementColumn ¶
type MeasurementColumn struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Type *string `protobuf:"bytes,2,req,name=type" json:"type,omitempty"` InfluxType *string `protobuf:"bytes,3,req,name=influx_type,json=influxType" json:"influx_type,omitempty"` LastValueStringyfied *string `protobuf:"bytes,4,req,name=last_value_stringyfied,json=lastValueStringyfied" json:"last_value_stringyfied,omitempty"` // contains filtered or unexported fields }
func (*MeasurementColumn) Descriptor
deprecated
func (*MeasurementColumn) Descriptor() ([]byte, []int)
Deprecated: Use MeasurementColumn.ProtoReflect.Descriptor instead.
func (*MeasurementColumn) GetInfluxType ¶
func (x *MeasurementColumn) GetInfluxType() string
func (*MeasurementColumn) GetLastValueStringyfied ¶
func (x *MeasurementColumn) GetLastValueStringyfied() string
func (*MeasurementColumn) GetName ¶
func (x *MeasurementColumn) GetName() string
func (*MeasurementColumn) GetType ¶
func (x *MeasurementColumn) GetType() string
func (*MeasurementColumn) ProtoMessage ¶
func (*MeasurementColumn) ProtoMessage()
func (*MeasurementColumn) ProtoReflect ¶
func (x *MeasurementColumn) ProtoReflect() protoreflect.Message
func (*MeasurementColumn) Reset ¶
func (x *MeasurementColumn) Reset()
func (*MeasurementColumn) String ¶
func (x *MeasurementColumn) String() string
type MeasurementDetailsRequest ¶
type MeasurementDetailsRequest struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` // contains filtered or unexported fields }
func (*MeasurementDetailsRequest) Descriptor
deprecated
func (*MeasurementDetailsRequest) Descriptor() ([]byte, []int)
Deprecated: Use MeasurementDetailsRequest.ProtoReflect.Descriptor instead.
func (*MeasurementDetailsRequest) GetName ¶
func (x *MeasurementDetailsRequest) GetName() string
func (*MeasurementDetailsRequest) ProtoMessage ¶
func (*MeasurementDetailsRequest) ProtoMessage()
func (*MeasurementDetailsRequest) ProtoReflect ¶
func (x *MeasurementDetailsRequest) ProtoReflect() protoreflect.Message
func (*MeasurementDetailsRequest) Reset ¶
func (x *MeasurementDetailsRequest) Reset()
func (*MeasurementDetailsRequest) String ¶
func (x *MeasurementDetailsRequest) String() string
type MeasurementDetailsResponse ¶
type MeasurementDetailsResponse struct { TimestampLatestMeasurement *int64 `` /* 135-byte string literal not displayed */ Columns []*MeasurementColumn `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"` // contains filtered or unexported fields }
func (*MeasurementDetailsResponse) Descriptor
deprecated
func (*MeasurementDetailsResponse) Descriptor() ([]byte, []int)
Deprecated: Use MeasurementDetailsResponse.ProtoReflect.Descriptor instead.
func (*MeasurementDetailsResponse) GetColumns ¶
func (x *MeasurementDetailsResponse) GetColumns() []*MeasurementColumn
func (*MeasurementDetailsResponse) GetTimestampLatestMeasurement ¶
func (x *MeasurementDetailsResponse) GetTimestampLatestMeasurement() int64
func (*MeasurementDetailsResponse) ProtoMessage ¶
func (*MeasurementDetailsResponse) ProtoMessage()
func (*MeasurementDetailsResponse) ProtoReflect ¶
func (x *MeasurementDetailsResponse) ProtoReflect() protoreflect.Message
func (*MeasurementDetailsResponse) Reset ¶
func (x *MeasurementDetailsResponse) Reset()
func (*MeasurementDetailsResponse) String ¶
func (x *MeasurementDetailsResponse) String() string
type MeasurementsRequest ¶
type MeasurementsRequest struct {
// contains filtered or unexported fields
}
func (*MeasurementsRequest) Descriptor
deprecated
func (*MeasurementsRequest) Descriptor() ([]byte, []int)
Deprecated: Use MeasurementsRequest.ProtoReflect.Descriptor instead.
func (*MeasurementsRequest) ProtoMessage ¶
func (*MeasurementsRequest) ProtoMessage()
func (*MeasurementsRequest) ProtoReflect ¶
func (x *MeasurementsRequest) ProtoReflect() protoreflect.Message
func (*MeasurementsRequest) Reset ¶
func (x *MeasurementsRequest) Reset()
func (*MeasurementsRequest) String ¶
func (x *MeasurementsRequest) String() string
type MeasurementsResponse ¶
type MeasurementsResponse struct { Measurements []*Measurement `protobuf:"bytes,1,rep,name=measurements" json:"measurements,omitempty"` // contains filtered or unexported fields }
func (*MeasurementsResponse) Descriptor
deprecated
func (*MeasurementsResponse) Descriptor() ([]byte, []int)
Deprecated: Use MeasurementsResponse.ProtoReflect.Descriptor instead.
func (*MeasurementsResponse) GetMeasurements ¶
func (x *MeasurementsResponse) GetMeasurements() []*Measurement
func (*MeasurementsResponse) ProtoMessage ¶
func (*MeasurementsResponse) ProtoMessage()
func (*MeasurementsResponse) ProtoReflect ¶
func (x *MeasurementsResponse) ProtoReflect() protoreflect.Message
func (*MeasurementsResponse) Reset ¶
func (x *MeasurementsResponse) Reset()
func (*MeasurementsResponse) String ¶
func (x *MeasurementsResponse) String() string
type MultiTopologyIdentifier ¶
type MultiTopologyIdentifier struct { OFlag *bool `protobuf:"varint,1,req,name=o_flag,json=oFlag" json:"o_flag,omitempty"` AFlag *bool `protobuf:"varint,2,req,name=a_flag,json=aFlag" json:"a_flag,omitempty"` Mtid *uint32 `protobuf:"varint,3,req,name=mtid" json:"mtid,omitempty"` // protobuf does not support uint16 // contains filtered or unexported fields }
func (*MultiTopologyIdentifier) Descriptor
deprecated
func (*MultiTopologyIdentifier) Descriptor() ([]byte, []int)
Deprecated: Use MultiTopologyIdentifier.ProtoReflect.Descriptor instead.
func (*MultiTopologyIdentifier) GetAFlag ¶
func (x *MultiTopologyIdentifier) GetAFlag() bool
func (*MultiTopologyIdentifier) GetMtid ¶
func (x *MultiTopologyIdentifier) GetMtid() uint32
func (*MultiTopologyIdentifier) GetOFlag ¶
func (x *MultiTopologyIdentifier) GetOFlag() bool
func (*MultiTopologyIdentifier) ProtoMessage ¶
func (*MultiTopologyIdentifier) ProtoMessage()
func (*MultiTopologyIdentifier) ProtoReflect ¶
func (x *MultiTopologyIdentifier) ProtoReflect() protoreflect.Message
func (*MultiTopologyIdentifier) Reset ¶
func (x *MultiTopologyIdentifier) Reset()
func (*MultiTopologyIdentifier) String ¶
func (x *MultiTopologyIdentifier) String() string
type Peer ¶
type Peer struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"` RouterHash *string `protobuf:"bytes,3,opt,name=router_hash,json=routerHash" json:"router_hash,omitempty"` RemoteBgpId *string `protobuf:"bytes,4,opt,name=remote_bgp_id,json=remoteBgpId" json:"remote_bgp_id,omitempty"` LocalBgpId *string `protobuf:"bytes,5,opt,name=local_bgp_id,json=localBgpId" json:"local_bgp_id,omitempty"` // contains filtered or unexported fields }
func (*Peer) Descriptor
deprecated
func (*Peer) GetLocalBgpId ¶
func (*Peer) GetRemoteBgpId ¶
func (*Peer) GetRouterHash ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) ProtoReflect ¶
func (x *Peer) ProtoReflect() protoreflect.Message
type PeerEvent ¶
type PeerEvent struct { Action *string `protobuf:"bytes,1,req,name=action" json:"action,omitempty"` Key *string `protobuf:"bytes,2,req,name=key" json:"key,omitempty"` Peer *Peer `protobuf:"bytes,3,opt,name=peer" json:"peer,omitempty"` // contains filtered or unexported fields }
func (*PeerEvent) Descriptor
deprecated
func (*PeerEvent) ProtoMessage ¶
func (*PeerEvent) ProtoMessage()
func (*PeerEvent) ProtoReflect ¶
func (x *PeerEvent) ProtoReflect() protoreflect.Message
type PeerResponse ¶
type PeerResponse struct { Peer []*Peer `protobuf:"bytes,1,rep,name=peer" json:"peer,omitempty"` // contains filtered or unexported fields }
func (*PeerResponse) Descriptor
deprecated
func (*PeerResponse) Descriptor() ([]byte, []int)
Deprecated: Use PeerResponse.ProtoReflect.Descriptor instead.
func (*PeerResponse) GetPeer ¶
func (x *PeerResponse) GetPeer() []*Peer
func (*PeerResponse) ProtoMessage ¶
func (*PeerResponse) ProtoMessage()
func (*PeerResponse) ProtoReflect ¶
func (x *PeerResponse) ProtoReflect() protoreflect.Message
func (*PeerResponse) Reset ¶
func (x *PeerResponse) Reset()
func (*PeerResponse) String ¶
func (x *PeerResponse) String() string
type RangeFilter ¶
type RangeFilter struct { EarliestTimestamp *int64 `protobuf:"varint,3,req,name=earliest_timestamp,json=earliestTimestamp" json:"earliest_timestamp,omitempty"` LatestTimestamp *int64 `protobuf:"varint,4,opt,name=latest_timestamp,json=latestTimestamp" json:"latest_timestamp,omitempty"` // contains filtered or unexported fields }
func (*RangeFilter) Descriptor
deprecated
func (*RangeFilter) Descriptor() ([]byte, []int)
Deprecated: Use RangeFilter.ProtoReflect.Descriptor instead.
func (*RangeFilter) GetEarliestTimestamp ¶
func (x *RangeFilter) GetEarliestTimestamp() int64
func (*RangeFilter) GetLatestTimestamp ¶
func (x *RangeFilter) GetLatestTimestamp() int64
func (*RangeFilter) ProtoMessage ¶
func (*RangeFilter) ProtoMessage()
func (*RangeFilter) ProtoReflect ¶
func (x *RangeFilter) ProtoReflect() protoreflect.Message
func (*RangeFilter) Reset ¶
func (x *RangeFilter) Reset()
func (*RangeFilter) String ¶
func (x *RangeFilter) String() string
type RequestServiceClient ¶
type RequestServiceClient interface { GetLsNodes(ctx context.Context, in *TopologyRequest, opts ...grpc.CallOption) (*LsNodeResponse, error) GetLsLinks(ctx context.Context, in *TopologyRequest, opts ...grpc.CallOption) (*LsLinkResponse, error) GetLsPrefixes(ctx context.Context, in *TopologyRequest, opts ...grpc.CallOption) (*LsPrefixResponse, error) GetLsSrv6Sids(ctx context.Context, in *TopologyRequest, opts ...grpc.CallOption) (*LsSrv6SidResponse, error) GetLsNodeEdges(ctx context.Context, in *TopologyRequest, opts ...grpc.CallOption) (*LsNodeEdgeResponse, error) GetPeers(ctx context.Context, in *TopologyRequest, opts ...grpc.CallOption) (*PeerResponse, error) GetLsNodeCoordinates(ctx context.Context, in *LsNodeCoordinatesRequest, opts ...grpc.CallOption) (*LsNodeCoordinatesResponse, error) GetTelemetryData(ctx context.Context, in *TelemetryRequest, opts ...grpc.CallOption) (*TelemetryResponse, error) GetMeasurements(ctx context.Context, in *MeasurementsRequest, opts ...grpc.CallOption) (*MeasurementsResponse, error) GetMeasurementDetails(ctx context.Context, in *MeasurementDetailsRequest, opts ...grpc.CallOption) (*MeasurementDetailsResponse, error) }
RequestServiceClient is the client API for RequestService 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 NewRequestServiceClient ¶
func NewRequestServiceClient(cc grpc.ClientConnInterface) RequestServiceClient
type RequestServiceServer ¶
type RequestServiceServer interface { GetLsNodes(context.Context, *TopologyRequest) (*LsNodeResponse, error) GetLsLinks(context.Context, *TopologyRequest) (*LsLinkResponse, error) GetLsPrefixes(context.Context, *TopologyRequest) (*LsPrefixResponse, error) GetLsSrv6Sids(context.Context, *TopologyRequest) (*LsSrv6SidResponse, error) GetLsNodeEdges(context.Context, *TopologyRequest) (*LsNodeEdgeResponse, error) GetPeers(context.Context, *TopologyRequest) (*PeerResponse, error) GetLsNodeCoordinates(context.Context, *LsNodeCoordinatesRequest) (*LsNodeCoordinatesResponse, error) GetTelemetryData(context.Context, *TelemetryRequest) (*TelemetryResponse, error) GetMeasurements(context.Context, *MeasurementsRequest) (*MeasurementsResponse, error) GetMeasurementDetails(context.Context, *MeasurementDetailsRequest) (*MeasurementDetailsResponse, error) // contains filtered or unexported methods }
RequestServiceServer is the server API for RequestService service. All implementations must embed UnimplementedRequestServiceServer for forward compatibility
type StringFilter ¶
type StringFilter struct { Property *string `protobuf:"bytes,1,req,name=property" json:"property,omitempty"` Value *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"` Operator *StringOperator `protobuf:"varint,3,req,name=operator,enum=jagw.StringOperator" json:"operator,omitempty"` // contains filtered or unexported fields }
func (*StringFilter) Descriptor
deprecated
func (*StringFilter) Descriptor() ([]byte, []int)
Deprecated: Use StringFilter.ProtoReflect.Descriptor instead.
func (*StringFilter) GetOperator ¶
func (x *StringFilter) GetOperator() StringOperator
func (*StringFilter) GetProperty ¶
func (x *StringFilter) GetProperty() string
func (*StringFilter) GetValue ¶
func (x *StringFilter) GetValue() string
func (*StringFilter) ProtoMessage ¶
func (*StringFilter) ProtoMessage()
func (*StringFilter) ProtoReflect ¶
func (x *StringFilter) ProtoReflect() protoreflect.Message
func (*StringFilter) Reset ¶
func (x *StringFilter) Reset()
func (*StringFilter) String ¶
func (x *StringFilter) String() string
type StringOperator ¶
type StringOperator int32
const ( StringOperator_EQUAL StringOperator = 1 StringOperator_NOT_EQUAL StringOperator = 2 )
func (StringOperator) Descriptor ¶
func (StringOperator) Descriptor() protoreflect.EnumDescriptor
func (StringOperator) Enum ¶
func (x StringOperator) Enum() *StringOperator
func (StringOperator) EnumDescriptor
deprecated
func (StringOperator) EnumDescriptor() ([]byte, []int)
Deprecated: Use StringOperator.Descriptor instead.
func (StringOperator) Number ¶
func (x StringOperator) Number() protoreflect.EnumNumber
func (StringOperator) String ¶
func (x StringOperator) String() string
func (StringOperator) Type ¶
func (StringOperator) Type() protoreflect.EnumType
func (*StringOperator) UnmarshalJSON
deprecated
func (x *StringOperator) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type SubscriptionServiceClient ¶
type SubscriptionServiceClient interface { SubscribeToLsNodes(ctx context.Context, in *TopologySubscription, opts ...grpc.CallOption) (SubscriptionService_SubscribeToLsNodesClient, error) SubscribeToLsLinks(ctx context.Context, in *TopologySubscription, opts ...grpc.CallOption) (SubscriptionService_SubscribeToLsLinksClient, error) SubscribeToLsPrefixes(ctx context.Context, in *TopologySubscription, opts ...grpc.CallOption) (SubscriptionService_SubscribeToLsPrefixesClient, error) SubscribeToLsSrv6Sids(ctx context.Context, in *TopologySubscription, opts ...grpc.CallOption) (SubscriptionService_SubscribeToLsSrv6SidsClient, error) SubscribeToLsNodeEdges(ctx context.Context, in *TopologySubscription, opts ...grpc.CallOption) (SubscriptionService_SubscribeToLsNodeEdgesClient, error) SubscribeToPeers(ctx context.Context, in *TopologySubscription, opts ...grpc.CallOption) (SubscriptionService_SubscribeToPeersClient, error) SubscribeToTelemetryData(ctx context.Context, in *TelemetrySubscription, opts ...grpc.CallOption) (SubscriptionService_SubscribeToTelemetryDataClient, error) }
SubscriptionServiceClient is the client API for SubscriptionService 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 NewSubscriptionServiceClient ¶
func NewSubscriptionServiceClient(cc grpc.ClientConnInterface) SubscriptionServiceClient
type SubscriptionServiceServer ¶
type SubscriptionServiceServer interface { SubscribeToLsNodes(*TopologySubscription, SubscriptionService_SubscribeToLsNodesServer) error SubscribeToLsLinks(*TopologySubscription, SubscriptionService_SubscribeToLsLinksServer) error SubscribeToLsPrefixes(*TopologySubscription, SubscriptionService_SubscribeToLsPrefixesServer) error SubscribeToLsSrv6Sids(*TopologySubscription, SubscriptionService_SubscribeToLsSrv6SidsServer) error SubscribeToLsNodeEdges(*TopologySubscription, SubscriptionService_SubscribeToLsNodeEdgesServer) error SubscribeToPeers(*TopologySubscription, SubscriptionService_SubscribeToPeersServer) error SubscribeToTelemetryData(*TelemetrySubscription, SubscriptionService_SubscribeToTelemetryDataServer) error // contains filtered or unexported methods }
SubscriptionServiceServer is the server API for SubscriptionService service. All implementations must embed UnimplementedSubscriptionServiceServer for forward compatibility
type SubscriptionService_SubscribeToLsLinksClient ¶
type SubscriptionService_SubscribeToLsLinksClient interface { Recv() (*LsLinkEvent, error) grpc.ClientStream }
type SubscriptionService_SubscribeToLsLinksServer ¶
type SubscriptionService_SubscribeToLsLinksServer interface { Send(*LsLinkEvent) error grpc.ServerStream }
type SubscriptionService_SubscribeToLsNodeEdgesClient ¶
type SubscriptionService_SubscribeToLsNodeEdgesClient interface { Recv() (*LsNodeEdgeEvent, error) grpc.ClientStream }
type SubscriptionService_SubscribeToLsNodeEdgesServer ¶
type SubscriptionService_SubscribeToLsNodeEdgesServer interface { Send(*LsNodeEdgeEvent) error grpc.ServerStream }
type SubscriptionService_SubscribeToLsNodesClient ¶
type SubscriptionService_SubscribeToLsNodesClient interface { Recv() (*LsNodeEvent, error) grpc.ClientStream }
type SubscriptionService_SubscribeToLsNodesServer ¶
type SubscriptionService_SubscribeToLsNodesServer interface { Send(*LsNodeEvent) error grpc.ServerStream }
type SubscriptionService_SubscribeToLsPrefixesClient ¶
type SubscriptionService_SubscribeToLsPrefixesClient interface { Recv() (*LsPrefixEvent, error) grpc.ClientStream }
type SubscriptionService_SubscribeToLsPrefixesServer ¶
type SubscriptionService_SubscribeToLsPrefixesServer interface { Send(*LsPrefixEvent) error grpc.ServerStream }
type SubscriptionService_SubscribeToLsSrv6SidsClient ¶
type SubscriptionService_SubscribeToLsSrv6SidsClient interface { Recv() (*LsSrv6SidEvent, error) grpc.ClientStream }
type SubscriptionService_SubscribeToLsSrv6SidsServer ¶
type SubscriptionService_SubscribeToLsSrv6SidsServer interface { Send(*LsSrv6SidEvent) error grpc.ServerStream }
type SubscriptionService_SubscribeToPeersClient ¶
type SubscriptionService_SubscribeToPeersClient interface { Recv() (*PeerEvent, error) grpc.ClientStream }
type SubscriptionService_SubscribeToPeersServer ¶
type SubscriptionService_SubscribeToPeersServer interface { Send(*PeerEvent) error grpc.ServerStream }
type SubscriptionService_SubscribeToTelemetryDataClient ¶
type SubscriptionService_SubscribeToTelemetryDataClient interface { Recv() (*TelemetryEvent, error) grpc.ClientStream }
type SubscriptionService_SubscribeToTelemetryDataServer ¶
type SubscriptionService_SubscribeToTelemetryDataServer interface { Send(*TelemetryEvent) error grpc.ServerStream }
type TelemetryEvent ¶
type TelemetryEvent struct { TelemetryData *string `protobuf:"bytes,1,req,name=telemetry_data,json=telemetryData" json:"telemetry_data,omitempty"` // contains filtered or unexported fields }
func (*TelemetryEvent) Descriptor
deprecated
func (*TelemetryEvent) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryEvent.ProtoReflect.Descriptor instead.
func (*TelemetryEvent) GetTelemetryData ¶
func (x *TelemetryEvent) GetTelemetryData() string
func (*TelemetryEvent) ProtoMessage ¶
func (*TelemetryEvent) ProtoMessage()
func (*TelemetryEvent) ProtoReflect ¶
func (x *TelemetryEvent) ProtoReflect() protoreflect.Message
func (*TelemetryEvent) Reset ¶
func (x *TelemetryEvent) Reset()
func (*TelemetryEvent) String ¶
func (x *TelemetryEvent) String() string
type TelemetryRequest ¶
type TelemetryRequest struct { SensorPath *string `protobuf:"bytes,1,req,name=sensor_path,json=sensorPath" json:"sensor_path,omitempty"` Properties []string `protobuf:"bytes,2,rep,name=properties" json:"properties,omitempty"` Unflatten *bool `protobuf:"varint,3,opt,name=Unflatten" json:"Unflatten,omitempty"` StringFilters []*StringFilter `protobuf:"bytes,4,rep,name=string_filters,json=stringFilters" json:"string_filters,omitempty"` RangeFilter *RangeFilter `protobuf:"bytes,5,opt,name=range_filter,json=rangeFilter" json:"range_filter,omitempty"` // contains filtered or unexported fields }
func (*TelemetryRequest) Descriptor
deprecated
func (*TelemetryRequest) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryRequest.ProtoReflect.Descriptor instead.
func (*TelemetryRequest) GetProperties ¶
func (x *TelemetryRequest) GetProperties() []string
func (*TelemetryRequest) GetRangeFilter ¶
func (x *TelemetryRequest) GetRangeFilter() *RangeFilter
func (*TelemetryRequest) GetSensorPath ¶
func (x *TelemetryRequest) GetSensorPath() string
func (*TelemetryRequest) GetStringFilters ¶
func (x *TelemetryRequest) GetStringFilters() []*StringFilter
func (*TelemetryRequest) GetUnflatten ¶
func (x *TelemetryRequest) GetUnflatten() bool
func (*TelemetryRequest) ProtoMessage ¶
func (*TelemetryRequest) ProtoMessage()
func (*TelemetryRequest) ProtoReflect ¶
func (x *TelemetryRequest) ProtoReflect() protoreflect.Message
func (*TelemetryRequest) Reset ¶
func (x *TelemetryRequest) Reset()
func (*TelemetryRequest) String ¶
func (x *TelemetryRequest) String() string
type TelemetryResponse ¶
type TelemetryResponse struct { TelemetryData []string `protobuf:"bytes,1,rep,name=telemetry_data,json=telemetryData" json:"telemetry_data,omitempty"` // contains filtered or unexported fields }
func (*TelemetryResponse) Descriptor
deprecated
func (*TelemetryResponse) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryResponse.ProtoReflect.Descriptor instead.
func (*TelemetryResponse) GetTelemetryData ¶
func (x *TelemetryResponse) GetTelemetryData() []string
func (*TelemetryResponse) ProtoMessage ¶
func (*TelemetryResponse) ProtoMessage()
func (*TelemetryResponse) ProtoReflect ¶
func (x *TelemetryResponse) ProtoReflect() protoreflect.Message
func (*TelemetryResponse) Reset ¶
func (x *TelemetryResponse) Reset()
func (*TelemetryResponse) String ¶
func (x *TelemetryResponse) String() string
type TelemetrySubscription ¶
type TelemetrySubscription struct { SensorPath *string `protobuf:"bytes,1,req,name=sensor_path,json=sensorPath" json:"sensor_path,omitempty"` Properties []string `protobuf:"bytes,2,rep,name=properties" json:"properties,omitempty"` Unflatten *bool `protobuf:"varint,3,opt,name=Unflatten" json:"Unflatten,omitempty"` StringFilters []*StringFilter `protobuf:"bytes,4,rep,name=string_filters,json=stringFilters" json:"string_filters,omitempty"` // contains filtered or unexported fields }
func (*TelemetrySubscription) Descriptor
deprecated
func (*TelemetrySubscription) Descriptor() ([]byte, []int)
Deprecated: Use TelemetrySubscription.ProtoReflect.Descriptor instead.
func (*TelemetrySubscription) GetProperties ¶
func (x *TelemetrySubscription) GetProperties() []string
func (*TelemetrySubscription) GetSensorPath ¶
func (x *TelemetrySubscription) GetSensorPath() string
func (*TelemetrySubscription) GetStringFilters ¶
func (x *TelemetrySubscription) GetStringFilters() []*StringFilter
func (*TelemetrySubscription) GetUnflatten ¶
func (x *TelemetrySubscription) GetUnflatten() bool
func (*TelemetrySubscription) ProtoMessage ¶
func (*TelemetrySubscription) ProtoMessage()
func (*TelemetrySubscription) ProtoReflect ¶
func (x *TelemetrySubscription) ProtoReflect() protoreflect.Message
func (*TelemetrySubscription) Reset ¶
func (x *TelemetrySubscription) Reset()
func (*TelemetrySubscription) String ¶
func (x *TelemetrySubscription) String() string
type TopologyRequest ¶
type TopologyRequest struct { Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"` Properties []string `protobuf:"bytes,2,rep,name=properties" json:"properties,omitempty"` // contains filtered or unexported fields }
func (*TopologyRequest) Descriptor
deprecated
func (*TopologyRequest) Descriptor() ([]byte, []int)
Deprecated: Use TopologyRequest.ProtoReflect.Descriptor instead.
func (*TopologyRequest) GetKeys ¶
func (x *TopologyRequest) GetKeys() []string
func (*TopologyRequest) GetProperties ¶
func (x *TopologyRequest) GetProperties() []string
func (*TopologyRequest) ProtoMessage ¶
func (*TopologyRequest) ProtoMessage()
func (*TopologyRequest) ProtoReflect ¶
func (x *TopologyRequest) ProtoReflect() protoreflect.Message
func (*TopologyRequest) Reset ¶
func (x *TopologyRequest) Reset()
func (*TopologyRequest) String ¶
func (x *TopologyRequest) String() string
type TopologySubscription ¶
type TopologySubscription struct { Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"` Properties []string `protobuf:"bytes,2,rep,name=properties" json:"properties,omitempty"` // contains filtered or unexported fields }
func (*TopologySubscription) Descriptor
deprecated
func (*TopologySubscription) Descriptor() ([]byte, []int)
Deprecated: Use TopologySubscription.ProtoReflect.Descriptor instead.
func (*TopologySubscription) GetKeys ¶
func (x *TopologySubscription) GetKeys() []string
func (*TopologySubscription) GetProperties ¶
func (x *TopologySubscription) GetProperties() []string
func (*TopologySubscription) ProtoMessage ¶
func (*TopologySubscription) ProtoMessage()
func (*TopologySubscription) ProtoReflect ¶
func (x *TopologySubscription) ProtoReflect() protoreflect.Message
func (*TopologySubscription) Reset ¶
func (x *TopologySubscription) Reset()
func (*TopologySubscription) String ¶
func (x *TopologySubscription) String() string
type UnimplementedRequestServiceServer ¶
type UnimplementedRequestServiceServer struct { }
UnimplementedRequestServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRequestServiceServer) GetLsLinks ¶
func (UnimplementedRequestServiceServer) GetLsLinks(context.Context, *TopologyRequest) (*LsLinkResponse, error)
func (UnimplementedRequestServiceServer) GetLsNodeCoordinates ¶
func (UnimplementedRequestServiceServer) GetLsNodeCoordinates(context.Context, *LsNodeCoordinatesRequest) (*LsNodeCoordinatesResponse, error)
func (UnimplementedRequestServiceServer) GetLsNodeEdges ¶
func (UnimplementedRequestServiceServer) GetLsNodeEdges(context.Context, *TopologyRequest) (*LsNodeEdgeResponse, error)
func (UnimplementedRequestServiceServer) GetLsNodes ¶
func (UnimplementedRequestServiceServer) GetLsNodes(context.Context, *TopologyRequest) (*LsNodeResponse, error)
func (UnimplementedRequestServiceServer) GetLsPrefixes ¶
func (UnimplementedRequestServiceServer) GetLsPrefixes(context.Context, *TopologyRequest) (*LsPrefixResponse, error)
func (UnimplementedRequestServiceServer) GetLsSrv6Sids ¶
func (UnimplementedRequestServiceServer) GetLsSrv6Sids(context.Context, *TopologyRequest) (*LsSrv6SidResponse, error)
func (UnimplementedRequestServiceServer) GetMeasurementDetails ¶
func (UnimplementedRequestServiceServer) GetMeasurementDetails(context.Context, *MeasurementDetailsRequest) (*MeasurementDetailsResponse, error)
func (UnimplementedRequestServiceServer) GetMeasurements ¶
func (UnimplementedRequestServiceServer) GetMeasurements(context.Context, *MeasurementsRequest) (*MeasurementsResponse, error)
func (UnimplementedRequestServiceServer) GetPeers ¶
func (UnimplementedRequestServiceServer) GetPeers(context.Context, *TopologyRequest) (*PeerResponse, error)
func (UnimplementedRequestServiceServer) GetTelemetryData ¶
func (UnimplementedRequestServiceServer) GetTelemetryData(context.Context, *TelemetryRequest) (*TelemetryResponse, error)
type UnimplementedSubscriptionServiceServer ¶
type UnimplementedSubscriptionServiceServer struct { }
UnimplementedSubscriptionServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSubscriptionServiceServer) SubscribeToLsLinks ¶
func (UnimplementedSubscriptionServiceServer) SubscribeToLsLinks(*TopologySubscription, SubscriptionService_SubscribeToLsLinksServer) error
func (UnimplementedSubscriptionServiceServer) SubscribeToLsNodeEdges ¶
func (UnimplementedSubscriptionServiceServer) SubscribeToLsNodeEdges(*TopologySubscription, SubscriptionService_SubscribeToLsNodeEdgesServer) error
func (UnimplementedSubscriptionServiceServer) SubscribeToLsNodes ¶
func (UnimplementedSubscriptionServiceServer) SubscribeToLsNodes(*TopologySubscription, SubscriptionService_SubscribeToLsNodesServer) error
func (UnimplementedSubscriptionServiceServer) SubscribeToLsPrefixes ¶
func (UnimplementedSubscriptionServiceServer) SubscribeToLsPrefixes(*TopologySubscription, SubscriptionService_SubscribeToLsPrefixesServer) error
func (UnimplementedSubscriptionServiceServer) SubscribeToLsSrv6Sids ¶
func (UnimplementedSubscriptionServiceServer) SubscribeToLsSrv6Sids(*TopologySubscription, SubscriptionService_SubscribeToLsSrv6SidsServer) error
func (UnimplementedSubscriptionServiceServer) SubscribeToPeers ¶
func (UnimplementedSubscriptionServiceServer) SubscribeToPeers(*TopologySubscription, SubscriptionService_SubscribeToPeersServer) error
func (UnimplementedSubscriptionServiceServer) SubscribeToTelemetryData ¶
func (UnimplementedSubscriptionServiceServer) SubscribeToTelemetryData(*TelemetrySubscription, SubscriptionService_SubscribeToTelemetryDataServer) error
type UnsafeRequestServiceServer ¶
type UnsafeRequestServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRequestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RequestServiceServer will result in compilation errors.
type UnsafeSubscriptionServiceServer ¶
type UnsafeSubscriptionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSubscriptionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscriptionServiceServer will result in compilation errors.