connectivitymonitor

package
v0.0.0-...-6419794 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ProbeService_GetOne_FullMethodName           = "/arista.connectivitymonitor.v1.ProbeService/GetOne"
	ProbeService_GetSome_FullMethodName          = "/arista.connectivitymonitor.v1.ProbeService/GetSome"
	ProbeService_GetAll_FullMethodName           = "/arista.connectivitymonitor.v1.ProbeService/GetAll"
	ProbeService_Subscribe_FullMethodName        = "/arista.connectivitymonitor.v1.ProbeService/Subscribe"
	ProbeService_GetMeta_FullMethodName          = "/arista.connectivitymonitor.v1.ProbeService/GetMeta"
	ProbeService_SubscribeMeta_FullMethodName    = "/arista.connectivitymonitor.v1.ProbeService/SubscribeMeta"
	ProbeService_GetAllBatched_FullMethodName    = "/arista.connectivitymonitor.v1.ProbeService/GetAllBatched"
	ProbeService_SubscribeBatched_FullMethodName = "/arista.connectivitymonitor.v1.ProbeService/SubscribeBatched"
)
View Source 
const (
	ProbeStatsService_GetOne_FullMethodName           = "/arista.connectivitymonitor.v1.ProbeStatsService/GetOne"
	ProbeStatsService_GetSome_FullMethodName          = "/arista.connectivitymonitor.v1.ProbeStatsService/GetSome"
	ProbeStatsService_GetAll_FullMethodName           = "/arista.connectivitymonitor.v1.ProbeStatsService/GetAll"
	ProbeStatsService_Subscribe_FullMethodName        = "/arista.connectivitymonitor.v1.ProbeStatsService/Subscribe"
	ProbeStatsService_GetMeta_FullMethodName          = "/arista.connectivitymonitor.v1.ProbeStatsService/GetMeta"
	ProbeStatsService_SubscribeMeta_FullMethodName    = "/arista.connectivitymonitor.v1.ProbeStatsService/SubscribeMeta"
	ProbeStatsService_GetAllBatched_FullMethodName    = "/arista.connectivitymonitor.v1.ProbeStatsService/GetAllBatched"
	ProbeStatsService_SubscribeBatched_FullMethodName = "/arista.connectivitymonitor.v1.ProbeStatsService/SubscribeBatched"
)

Variables

View Source 
var File_arista_connectivitymonitor_v1_connectivitymonitor_proto protoreflect.FileDescriptor
View Source 
var File_arista_connectivitymonitor_v1_services_gen_proto protoreflect.FileDescriptor
View Source 
var ProbeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.connectivitymonitor.v1.ProbeService",
	HandlerType: (*ProbeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _ProbeService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _ProbeService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _ProbeService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _ProbeService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _ProbeService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _ProbeService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _ProbeService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _ProbeService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/connectivitymonitor.v1/services.gen.proto",
}

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

View Source 
var ProbeStatsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.connectivitymonitor.v1.ProbeStatsService",
	HandlerType: (*ProbeStatsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _ProbeStatsService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _ProbeStatsService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _ProbeStatsService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _ProbeStatsService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _ProbeStatsService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _ProbeStatsService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _ProbeStatsService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _ProbeStatsService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/connectivitymonitor.v1/services.gen.proto",
}

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

Functions

func RegisterProbeServiceServer 

func RegisterProbeServiceServer(s grpc.ServiceRegistrar, srv ProbeServiceServer)

func RegisterProbeStatsServiceServer 

func RegisterProbeStatsServiceServer(s grpc.ServiceRegistrar, srv ProbeStatsServiceServer)

Types

type MetaResponse 

type MetaResponse struct {

	// Time holds the timestamp of the last item included in the metadata calculation.
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,2,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// Count is the number of items present under the conditions of the request.
	Count *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaResponse) Descriptor deprecated 

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

Deprecated: Use MetaResponse.ProtoReflect.Descriptor instead.

func (*MetaResponse) GetCount 

func (x *MetaResponse) GetCount() *wrapperspb.UInt32Value

func (*MetaResponse) GetTime 

func (x *MetaResponse) GetTime() *timestamppb.Timestamp

func (*MetaResponse) GetType 

func (x *MetaResponse) GetType() subscriptions.Operation

func (*MetaResponse) ProtoMessage 

func (*MetaResponse) ProtoMessage()

func (*MetaResponse) ProtoReflect 

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

func (*MetaResponse) Reset 

func (x *MetaResponse) Reset()

func (*MetaResponse) String 

func (x *MetaResponse) String() string

type Probe 

type Probe struct {

	// key uniquely identifies the connectivity monitor probe.
	Key *ProbeKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// ip_addr is the IP Address of the probe.
	IpAddr *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"`
	// host_name is the name of the host of the probe.
	HostName *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	// description is the description of the probe.
	Description *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

Probe is identifying information of a connectivity monitor probe. It is used to retrieve probe information without getting the corresponding stats so that probe information can be displayed without streaming all related data, such as in the UI.

func (*Probe) Descriptor deprecated 

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

Deprecated: Use Probe.ProtoReflect.Descriptor instead.

func (*Probe) GetDescription 

func (x *Probe) GetDescription() *wrapperspb.StringValue

func (*Probe) GetHostName 

func (x *Probe) GetHostName() *wrapperspb.StringValue

func (*Probe) GetIpAddr 

func (x *Probe) GetIpAddr() *wrapperspb.StringValue

func (*Probe) GetKey 

func (x *Probe) GetKey() *ProbeKey

func (*Probe) ProtoMessage 

func (*Probe) ProtoMessage()

func (*Probe) ProtoReflect 

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

func (*Probe) Reset 

func (x *Probe) Reset()

func (*Probe) String 

func (x *Probe) String() string

type ProbeBatchedStreamRequest 

type ProbeBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Probe `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Probe at end.
	//   - Each Probe response is fully-specified (all fields set).
	//   - start: Returns the state of each Probe at start, followed by updates until now.
	//   - Each Probe response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Probe at start, followed by updates
	//     until end.
	//   - Each Probe response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeBatchedStreamRequest) Descriptor deprecated 

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

Deprecated: Use ProbeBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*ProbeBatchedStreamRequest) GetMaxMessages 

func (x *ProbeBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value

func (*ProbeBatchedStreamRequest) GetPartialEqFilter 

func (x *ProbeBatchedStreamRequest) GetPartialEqFilter() []*Probe

func (*ProbeBatchedStreamRequest) GetTime 

func (x *ProbeBatchedStreamRequest) GetTime() *time.TimeBounds

func (*ProbeBatchedStreamRequest) ProtoMessage 

func (*ProbeBatchedStreamRequest) ProtoMessage()

func (*ProbeBatchedStreamRequest) ProtoReflect 

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

func (*ProbeBatchedStreamRequest) Reset 

func (x *ProbeBatchedStreamRequest) Reset()

func (*ProbeBatchedStreamRequest) String 

func (x *ProbeBatchedStreamRequest) String() string

type ProbeBatchedStreamResponse 

type ProbeBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*ProbeStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeBatchedStreamResponse) Descriptor deprecated 

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

Deprecated: Use ProbeBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*ProbeBatchedStreamResponse) GetResponses 

func (x *ProbeBatchedStreamResponse) GetResponses() []*ProbeStreamResponse

func (*ProbeBatchedStreamResponse) ProtoMessage 

func (*ProbeBatchedStreamResponse) ProtoMessage()

func (*ProbeBatchedStreamResponse) ProtoReflect 

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

func (*ProbeBatchedStreamResponse) Reset 

func (x *ProbeBatchedStreamResponse) Reset()

func (*ProbeBatchedStreamResponse) String 

func (x *ProbeBatchedStreamResponse) String() string

type ProbeKey 

type ProbeKey struct {

	// device_id is the id of the device in the probe.
	DeviceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// host is the hostname used in the probe.
	Host *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// vrf is the name of the VRF in the probe.
	Vrf *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=vrf,proto3" json:"vrf,omitempty"`
	// contains filtered or unexported fields
}

ProbeKey uniquely identifies a connectivity monitor probe.

func (*ProbeKey) Descriptor deprecated 

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

Deprecated: Use ProbeKey.ProtoReflect.Descriptor instead.

func (*ProbeKey) GetDeviceId 

func (x *ProbeKey) GetDeviceId() *wrapperspb.StringValue

func (*ProbeKey) GetHost 

func (x *ProbeKey) GetHost() *wrapperspb.StringValue

func (*ProbeKey) GetVrf 

func (x *ProbeKey) GetVrf() *wrapperspb.StringValue

func (*ProbeKey) ProtoMessage 

func (*ProbeKey) ProtoMessage()

func (*ProbeKey) ProtoReflect 

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

func (*ProbeKey) Reset 

func (x *ProbeKey) Reset()

func (*ProbeKey) String 

func (x *ProbeKey) String() string

type ProbeRequest 

type ProbeRequest struct {

	// Key uniquely identifies a Probe instance to retrieve.
	// This value must be populated.
	Key *ProbeKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeRequest) Descriptor deprecated 

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

Deprecated: Use ProbeRequest.ProtoReflect.Descriptor instead.

func (*ProbeRequest) GetKey 

func (x *ProbeRequest) GetKey() *ProbeKey

func (*ProbeRequest) GetTime 

func (x *ProbeRequest) GetTime() *timestamppb.Timestamp

func (*ProbeRequest) ProtoMessage 

func (*ProbeRequest) ProtoMessage()

func (*ProbeRequest) ProtoReflect 

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

func (*ProbeRequest) Reset 

func (x *ProbeRequest) Reset()

func (*ProbeRequest) String 

func (x *ProbeRequest) String() string

type ProbeResponse 

type ProbeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Probe `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// Probe instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeResponse) Descriptor deprecated 

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

Deprecated: Use ProbeResponse.ProtoReflect.Descriptor instead.

func (*ProbeResponse) GetTime 

func (x *ProbeResponse) GetTime() *timestamppb.Timestamp

func (*ProbeResponse) GetValue 

func (x *ProbeResponse) GetValue() *Probe

func (*ProbeResponse) ProtoMessage 

func (*ProbeResponse) ProtoMessage()

func (*ProbeResponse) ProtoReflect 

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

func (*ProbeResponse) Reset 

func (x *ProbeResponse) Reset()

func (*ProbeResponse) String 

func (x *ProbeResponse) String() string

type ProbeServiceClient 

type ProbeServiceClient interface {
	GetOne(ctx context.Context, in *ProbeRequest, opts ...grpc.CallOption) (*ProbeResponse, error)
	GetSome(ctx context.Context, in *ProbeSomeRequest, opts ...grpc.CallOption) (ProbeService_GetSomeClient, error)
	GetAll(ctx context.Context, in *ProbeStreamRequest, opts ...grpc.CallOption) (ProbeService_GetAllClient, error)
	Subscribe(ctx context.Context, in *ProbeStreamRequest, opts ...grpc.CallOption) (ProbeService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *ProbeStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *ProbeStreamRequest, opts ...grpc.CallOption) (ProbeService_SubscribeMetaClient, error)
	GetAllBatched(ctx context.Context, in *ProbeBatchedStreamRequest, opts ...grpc.CallOption) (ProbeService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *ProbeBatchedStreamRequest, opts ...grpc.CallOption) (ProbeService_SubscribeBatchedClient, error)
}

ProbeServiceClient is the client API for ProbeService 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 NewProbeServiceClient 

func NewProbeServiceClient(cc grpc.ClientConnInterface) ProbeServiceClient

type ProbeServiceServer 

type ProbeServiceServer interface {
	GetOne(context.Context, *ProbeRequest) (*ProbeResponse, error)
	GetSome(*ProbeSomeRequest, ProbeService_GetSomeServer) error
	GetAll(*ProbeStreamRequest, ProbeService_GetAllServer) error
	Subscribe(*ProbeStreamRequest, ProbeService_SubscribeServer) error
	GetMeta(context.Context, *ProbeStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*ProbeStreamRequest, ProbeService_SubscribeMetaServer) error
	GetAllBatched(*ProbeBatchedStreamRequest, ProbeService_GetAllBatchedServer) error
	SubscribeBatched(*ProbeBatchedStreamRequest, ProbeService_SubscribeBatchedServer) error
	// contains filtered or unexported methods
}

ProbeServiceServer is the server API for ProbeService service. All implementations must embed UnimplementedProbeServiceServer for forward compatibility

type ProbeService_GetAllBatchedClient 

type ProbeService_GetAllBatchedClient interface {
	Recv() (*ProbeBatchedStreamResponse, error)
	grpc.ClientStream
}

type ProbeService_GetAllBatchedServer 

type ProbeService_GetAllBatchedServer interface {
	Send(*ProbeBatchedStreamResponse) error
	grpc.ServerStream
}

type ProbeService_GetAllClient 

type ProbeService_GetAllClient interface {
	Recv() (*ProbeStreamResponse, error)
	grpc.ClientStream
}

type ProbeService_GetAllServer 

type ProbeService_GetAllServer interface {
	Send(*ProbeStreamResponse) error
	grpc.ServerStream
}

type ProbeService_GetSomeClient 

type ProbeService_GetSomeClient interface {
	Recv() (*ProbeSomeResponse, error)
	grpc.ClientStream
}

type ProbeService_GetSomeServer 

type ProbeService_GetSomeServer interface {
	Send(*ProbeSomeResponse) error
	grpc.ServerStream
}

type ProbeService_SubscribeBatchedClient 

type ProbeService_SubscribeBatchedClient interface {
	Recv() (*ProbeBatchedStreamResponse, error)
	grpc.ClientStream
}

type ProbeService_SubscribeBatchedServer 

type ProbeService_SubscribeBatchedServer interface {
	Send(*ProbeBatchedStreamResponse) error
	grpc.ServerStream
}

type ProbeService_SubscribeClient 

type ProbeService_SubscribeClient interface {
	Recv() (*ProbeStreamResponse, error)
	grpc.ClientStream
}

type ProbeService_SubscribeMetaClient 

type ProbeService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type ProbeService_SubscribeMetaServer 

type ProbeService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type ProbeService_SubscribeServer 

type ProbeService_SubscribeServer interface {
	Send(*ProbeStreamResponse) error
	grpc.ServerStream
}

type ProbeSomeRequest 

type ProbeSomeRequest struct {
	Keys []*ProbeKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeSomeRequest) Descriptor deprecated 

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

Deprecated: Use ProbeSomeRequest.ProtoReflect.Descriptor instead.

func (*ProbeSomeRequest) GetKeys 

func (x *ProbeSomeRequest) GetKeys() []*ProbeKey

func (*ProbeSomeRequest) GetTime 

func (x *ProbeSomeRequest) GetTime() *timestamppb.Timestamp

func (*ProbeSomeRequest) ProtoMessage 

func (*ProbeSomeRequest) ProtoMessage()

func (*ProbeSomeRequest) ProtoReflect 

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

func (*ProbeSomeRequest) Reset 

func (x *ProbeSomeRequest) Reset()

func (*ProbeSomeRequest) String 

func (x *ProbeSomeRequest) String() string

type ProbeSomeResponse 

type ProbeSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Probe `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeSomeResponse) Descriptor deprecated 

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

Deprecated: Use ProbeSomeResponse.ProtoReflect.Descriptor instead.

func (*ProbeSomeResponse) GetError 

func (x *ProbeSomeResponse) GetError() *wrapperspb.StringValue

func (*ProbeSomeResponse) GetTime 

func (x *ProbeSomeResponse) GetTime() *timestamppb.Timestamp

func (*ProbeSomeResponse) GetValue 

func (x *ProbeSomeResponse) GetValue() *Probe

func (*ProbeSomeResponse) ProtoMessage 

func (*ProbeSomeResponse) ProtoMessage()

func (*ProbeSomeResponse) ProtoReflect 

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

func (*ProbeSomeResponse) Reset 

func (x *ProbeSomeResponse) Reset()

func (*ProbeSomeResponse) String 

func (x *ProbeSomeResponse) String() string

type ProbeStats 

type ProbeStats struct {

	// key uniquely identifies the connectivity monitor probe.
	Key *ProbeStatsKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// latency_millis is the latency between the device interface and the host.
	// Value is in milliseconds.
	LatencyMillis *wrapperspb.DoubleValue `protobuf:"bytes,2,opt,name=latency_millis,json=latencyMillis,proto3" json:"latency_millis,omitempty"`
	// jitter_millis is the amount of jitter experienced by requests
	// between the device interface and host.
	// Value is in milliseconds.
	JitterMillis *wrapperspb.DoubleValue `protobuf:"bytes,3,opt,name=jitter_millis,json=jitterMillis,proto3" json:"jitter_millis,omitempty"`
	// http_response_time_millis is the amount of time taken to respond to a http
	// request between the device interface and the host.
	// Value is in milliseconds.
	HttpResponseTimeMillis *wrapperspb.DoubleValue `` /* 131-byte string literal not displayed */
	// packet_loss_percent is the amount of packet loss experienced
	// by requests between the device interface and host.
	// Value is a percentage.
	PacketLossPercent *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=packet_loss_percent,json=packetLossPercent,proto3" json:"packet_loss_percent,omitempty"`
	// error is the error reported on the connection.
	Error *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ProbeStats is the connectivity monitor statistics related to the specified probe.

func (*ProbeStats) Descriptor deprecated 

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

Deprecated: Use ProbeStats.ProtoReflect.Descriptor instead.

func (*ProbeStats) GetError 

func (x *ProbeStats) GetError() *wrapperspb.StringValue

func (*ProbeStats) GetHttpResponseTimeMillis 

func (x *ProbeStats) GetHttpResponseTimeMillis() *wrapperspb.DoubleValue

func (*ProbeStats) GetJitterMillis 

func (x *ProbeStats) GetJitterMillis() *wrapperspb.DoubleValue

func (*ProbeStats) GetKey 

func (x *ProbeStats) GetKey() *ProbeStatsKey

func (*ProbeStats) GetLatencyMillis 

func (x *ProbeStats) GetLatencyMillis() *wrapperspb.DoubleValue

func (*ProbeStats) GetPacketLossPercent 

func (x *ProbeStats) GetPacketLossPercent() *wrapperspb.Int64Value

func (*ProbeStats) ProtoMessage 

func (*ProbeStats) ProtoMessage()

func (*ProbeStats) ProtoReflect 

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

func (*ProbeStats) Reset 

func (x *ProbeStats) Reset()

func (*ProbeStats) String 

func (x *ProbeStats) String() string

type ProbeStatsBatchedStreamRequest 

type ProbeStatsBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*ProbeStats `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each ProbeStats at end.
	//   - Each ProbeStats response is fully-specified (all fields set).
	//   - start: Returns the state of each ProbeStats at start, followed by updates until now.
	//   - Each ProbeStats response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each ProbeStats at start, followed by updates
	//     until end.
	//   - Each ProbeStats response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsBatchedStreamRequest) Descriptor deprecated 

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

Deprecated: Use ProbeStatsBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*ProbeStatsBatchedStreamRequest) GetMaxMessages 

func (x *ProbeStatsBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value

func (*ProbeStatsBatchedStreamRequest) GetPartialEqFilter 

func (x *ProbeStatsBatchedStreamRequest) GetPartialEqFilter() []*ProbeStats

func (*ProbeStatsBatchedStreamRequest) GetTime 

func (x *ProbeStatsBatchedStreamRequest) GetTime() *time.TimeBounds

func (*ProbeStatsBatchedStreamRequest) ProtoMessage 

func (*ProbeStatsBatchedStreamRequest) ProtoMessage()

func (*ProbeStatsBatchedStreamRequest) ProtoReflect 

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

func (*ProbeStatsBatchedStreamRequest) Reset 

func (x *ProbeStatsBatchedStreamRequest) Reset()

func (*ProbeStatsBatchedStreamRequest) String 

func (x *ProbeStatsBatchedStreamRequest) String() string

type ProbeStatsBatchedStreamResponse 

type ProbeStatsBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*ProbeStatsStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsBatchedStreamResponse) Descriptor deprecated 

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

Deprecated: Use ProbeStatsBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*ProbeStatsBatchedStreamResponse) GetResponses 

func (x *ProbeStatsBatchedStreamResponse) GetResponses() []*ProbeStatsStreamResponse

func (*ProbeStatsBatchedStreamResponse) ProtoMessage 

func (*ProbeStatsBatchedStreamResponse) ProtoMessage()

func (*ProbeStatsBatchedStreamResponse) ProtoReflect 

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

func (*ProbeStatsBatchedStreamResponse) Reset 

func (x *ProbeStatsBatchedStreamResponse) Reset()

func (*ProbeStatsBatchedStreamResponse) String 

func (x *ProbeStatsBatchedStreamResponse) String() string

type ProbeStatsKey 

type ProbeStatsKey struct {

	// device_id is the id of the device in the probe.
	DeviceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// host is the hostname used in the probe.
	Host *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// vrf is the name of the VRF in the probe.
	Vrf *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=vrf,proto3" json:"vrf,omitempty"`
	// source_intf is the name of the interface in the probe.
	SourceIntf *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=source_intf,json=sourceIntf,proto3" json:"source_intf,omitempty"`
	// contains filtered or unexported fields
}

ProbeStatsKey uniquely identifies a connectivity monitor probe's statistics, per source interface.

func (*ProbeStatsKey) Descriptor deprecated 

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

Deprecated: Use ProbeStatsKey.ProtoReflect.Descriptor instead.

func (*ProbeStatsKey) GetDeviceId 

func (x *ProbeStatsKey) GetDeviceId() *wrapperspb.StringValue

func (*ProbeStatsKey) GetHost 

func (x *ProbeStatsKey) GetHost() *wrapperspb.StringValue

func (*ProbeStatsKey) GetSourceIntf 

func (x *ProbeStatsKey) GetSourceIntf() *wrapperspb.StringValue

func (*ProbeStatsKey) GetVrf 

func (x *ProbeStatsKey) GetVrf() *wrapperspb.StringValue

func (*ProbeStatsKey) ProtoMessage 

func (*ProbeStatsKey) ProtoMessage()

func (*ProbeStatsKey) ProtoReflect 

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

func (*ProbeStatsKey) Reset 

func (x *ProbeStatsKey) Reset()

func (*ProbeStatsKey) String 

func (x *ProbeStatsKey) String() string

type ProbeStatsRequest 

type ProbeStatsRequest struct {

	// Key uniquely identifies a ProbeStats instance to retrieve.
	// This value must be populated.
	Key *ProbeStatsKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsRequest) Descriptor deprecated 

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

Deprecated: Use ProbeStatsRequest.ProtoReflect.Descriptor instead.

func (*ProbeStatsRequest) GetKey 

func (x *ProbeStatsRequest) GetKey() *ProbeStatsKey

func (*ProbeStatsRequest) GetTime 

func (x *ProbeStatsRequest) GetTime() *timestamppb.Timestamp

func (*ProbeStatsRequest) ProtoMessage 

func (*ProbeStatsRequest) ProtoMessage()

func (*ProbeStatsRequest) ProtoReflect 

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

func (*ProbeStatsRequest) Reset 

func (x *ProbeStatsRequest) Reset()

func (*ProbeStatsRequest) String 

func (x *ProbeStatsRequest) String() string

type ProbeStatsResponse 

type ProbeStatsResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *ProbeStats `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// ProbeStats instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsResponse) Descriptor deprecated 

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

Deprecated: Use ProbeStatsResponse.ProtoReflect.Descriptor instead.

func (*ProbeStatsResponse) GetTime 

func (x *ProbeStatsResponse) GetTime() *timestamppb.Timestamp

func (*ProbeStatsResponse) GetValue 

func (x *ProbeStatsResponse) GetValue() *ProbeStats

func (*ProbeStatsResponse) ProtoMessage 

func (*ProbeStatsResponse) ProtoMessage()

func (*ProbeStatsResponse) ProtoReflect 

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

func (*ProbeStatsResponse) Reset 

func (x *ProbeStatsResponse) Reset()

func (*ProbeStatsResponse) String 

func (x *ProbeStatsResponse) String() string

type ProbeStatsServiceClient 

type ProbeStatsServiceClient interface {
	GetOne(ctx context.Context, in *ProbeStatsRequest, opts ...grpc.CallOption) (*ProbeStatsResponse, error)
	GetSome(ctx context.Context, in *ProbeStatsSomeRequest, opts ...grpc.CallOption) (ProbeStatsService_GetSomeClient, error)
	GetAll(ctx context.Context, in *ProbeStatsStreamRequest, opts ...grpc.CallOption) (ProbeStatsService_GetAllClient, error)
	Subscribe(ctx context.Context, in *ProbeStatsStreamRequest, opts ...grpc.CallOption) (ProbeStatsService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *ProbeStatsStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *ProbeStatsStreamRequest, opts ...grpc.CallOption) (ProbeStatsService_SubscribeMetaClient, error)
	GetAllBatched(ctx context.Context, in *ProbeStatsBatchedStreamRequest, opts ...grpc.CallOption) (ProbeStatsService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *ProbeStatsBatchedStreamRequest, opts ...grpc.CallOption) (ProbeStatsService_SubscribeBatchedClient, error)
}

ProbeStatsServiceClient is the client API for ProbeStatsService 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 NewProbeStatsServiceClient 

func NewProbeStatsServiceClient(cc grpc.ClientConnInterface) ProbeStatsServiceClient

type ProbeStatsServiceServer 

type ProbeStatsServiceServer interface {
	GetOne(context.Context, *ProbeStatsRequest) (*ProbeStatsResponse, error)
	GetSome(*ProbeStatsSomeRequest, ProbeStatsService_GetSomeServer) error
	GetAll(*ProbeStatsStreamRequest, ProbeStatsService_GetAllServer) error
	Subscribe(*ProbeStatsStreamRequest, ProbeStatsService_SubscribeServer) error
	GetMeta(context.Context, *ProbeStatsStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*ProbeStatsStreamRequest, ProbeStatsService_SubscribeMetaServer) error
	GetAllBatched(*ProbeStatsBatchedStreamRequest, ProbeStatsService_GetAllBatchedServer) error
	SubscribeBatched(*ProbeStatsBatchedStreamRequest, ProbeStatsService_SubscribeBatchedServer) error
	// contains filtered or unexported methods
}

ProbeStatsServiceServer is the server API for ProbeStatsService service. All implementations must embed UnimplementedProbeStatsServiceServer for forward compatibility

type ProbeStatsService_GetAllBatchedClient 

type ProbeStatsService_GetAllBatchedClient interface {
	Recv() (*ProbeStatsBatchedStreamResponse, error)
	grpc.ClientStream
}

type ProbeStatsService_GetAllBatchedServer 

type ProbeStatsService_GetAllBatchedServer interface {
	Send(*ProbeStatsBatchedStreamResponse) error
	grpc.ServerStream
}

type ProbeStatsService_GetAllClient 

type ProbeStatsService_GetAllClient interface {
	Recv() (*ProbeStatsStreamResponse, error)
	grpc.ClientStream
}

type ProbeStatsService_GetAllServer 

type ProbeStatsService_GetAllServer interface {
	Send(*ProbeStatsStreamResponse) error
	grpc.ServerStream
}

type ProbeStatsService_GetSomeClient 

type ProbeStatsService_GetSomeClient interface {
	Recv() (*ProbeStatsSomeResponse, error)
	grpc.ClientStream
}

type ProbeStatsService_GetSomeServer 

type ProbeStatsService_GetSomeServer interface {
	Send(*ProbeStatsSomeResponse) error
	grpc.ServerStream
}

type ProbeStatsService_SubscribeBatchedClient 

type ProbeStatsService_SubscribeBatchedClient interface {
	Recv() (*ProbeStatsBatchedStreamResponse, error)
	grpc.ClientStream
}

type ProbeStatsService_SubscribeBatchedServer 

type ProbeStatsService_SubscribeBatchedServer interface {
	Send(*ProbeStatsBatchedStreamResponse) error
	grpc.ServerStream
}

type ProbeStatsService_SubscribeClient 

type ProbeStatsService_SubscribeClient interface {
	Recv() (*ProbeStatsStreamResponse, error)
	grpc.ClientStream
}

type ProbeStatsService_SubscribeMetaClient 

type ProbeStatsService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type ProbeStatsService_SubscribeMetaServer 

type ProbeStatsService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type ProbeStatsService_SubscribeServer 

type ProbeStatsService_SubscribeServer interface {
	Send(*ProbeStatsStreamResponse) error
	grpc.ServerStream
}

type ProbeStatsSomeRequest 

type ProbeStatsSomeRequest struct {
	Keys []*ProbeStatsKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsSomeRequest) Descriptor deprecated 

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

Deprecated: Use ProbeStatsSomeRequest.ProtoReflect.Descriptor instead.

func (*ProbeStatsSomeRequest) GetKeys 

func (x *ProbeStatsSomeRequest) GetKeys() []*ProbeStatsKey

func (*ProbeStatsSomeRequest) GetTime 

func (x *ProbeStatsSomeRequest) GetTime() *timestamppb.Timestamp

func (*ProbeStatsSomeRequest) ProtoMessage 

func (*ProbeStatsSomeRequest) ProtoMessage()

func (*ProbeStatsSomeRequest) ProtoReflect 

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

func (*ProbeStatsSomeRequest) Reset 

func (x *ProbeStatsSomeRequest) Reset()

func (*ProbeStatsSomeRequest) String 

func (x *ProbeStatsSomeRequest) String() string

type ProbeStatsSomeResponse 

type ProbeStatsSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *ProbeStats `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsSomeResponse) Descriptor deprecated 

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

Deprecated: Use ProbeStatsSomeResponse.ProtoReflect.Descriptor instead.

func (*ProbeStatsSomeResponse) GetError 

func (x *ProbeStatsSomeResponse) GetError() *wrapperspb.StringValue

func (*ProbeStatsSomeResponse) GetTime 

func (x *ProbeStatsSomeResponse) GetTime() *timestamppb.Timestamp

func (*ProbeStatsSomeResponse) GetValue 

func (x *ProbeStatsSomeResponse) GetValue() *ProbeStats

func (*ProbeStatsSomeResponse) ProtoMessage 

func (*ProbeStatsSomeResponse) ProtoMessage()

func (*ProbeStatsSomeResponse) ProtoReflect 

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

func (*ProbeStatsSomeResponse) Reset 

func (x *ProbeStatsSomeResponse) Reset()

func (*ProbeStatsSomeResponse) String 

func (x *ProbeStatsSomeResponse) String() string

type ProbeStatsStreamRequest 

type ProbeStatsStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*ProbeStats `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each ProbeStats at end.
	//   - Each ProbeStats response is fully-specified (all fields set).
	//   - start: Returns the state of each ProbeStats at start, followed by updates until now.
	//   - Each ProbeStats response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each ProbeStats at start, followed by updates
	//     until end.
	//   - Each ProbeStats response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsStreamRequest) Descriptor deprecated 

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

Deprecated: Use ProbeStatsStreamRequest.ProtoReflect.Descriptor instead.

func (*ProbeStatsStreamRequest) GetPartialEqFilter 

func (x *ProbeStatsStreamRequest) GetPartialEqFilter() []*ProbeStats

func (*ProbeStatsStreamRequest) GetTime 

func (x *ProbeStatsStreamRequest) GetTime() *time.TimeBounds

func (*ProbeStatsStreamRequest) ProtoMessage 

func (*ProbeStatsStreamRequest) ProtoMessage()

func (*ProbeStatsStreamRequest) ProtoReflect 

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

func (*ProbeStatsStreamRequest) Reset 

func (x *ProbeStatsStreamRequest) Reset()

func (*ProbeStatsStreamRequest) String 

func (x *ProbeStatsStreamRequest) String() string

type ProbeStatsStreamResponse 

type ProbeStatsStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *ProbeStats `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this ProbeStats's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the ProbeStats value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStatsStreamResponse) Descriptor deprecated 

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

Deprecated: Use ProbeStatsStreamResponse.ProtoReflect.Descriptor instead.

func (*ProbeStatsStreamResponse) GetTime 

func (x *ProbeStatsStreamResponse) GetTime() *timestamppb.Timestamp

func (*ProbeStatsStreamResponse) GetType 

func (x *ProbeStatsStreamResponse) GetType() subscriptions.Operation

func (*ProbeStatsStreamResponse) GetValue 

func (x *ProbeStatsStreamResponse) GetValue() *ProbeStats

func (*ProbeStatsStreamResponse) ProtoMessage 

func (*ProbeStatsStreamResponse) ProtoMessage()

func (*ProbeStatsStreamResponse) ProtoReflect 

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

func (*ProbeStatsStreamResponse) Reset 

func (x *ProbeStatsStreamResponse) Reset()

func (*ProbeStatsStreamResponse) String 

func (x *ProbeStatsStreamResponse) String() string

type ProbeStreamRequest 

type ProbeStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Probe `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Probe at end.
	//   - Each Probe response is fully-specified (all fields set).
	//   - start: Returns the state of each Probe at start, followed by updates until now.
	//   - Each Probe response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Probe at start, followed by updates
	//     until end.
	//   - Each Probe response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStreamRequest) Descriptor deprecated 

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

Deprecated: Use ProbeStreamRequest.ProtoReflect.Descriptor instead.

func (*ProbeStreamRequest) GetPartialEqFilter 

func (x *ProbeStreamRequest) GetPartialEqFilter() []*Probe

func (*ProbeStreamRequest) GetTime 

func (x *ProbeStreamRequest) GetTime() *time.TimeBounds

func (*ProbeStreamRequest) ProtoMessage 

func (*ProbeStreamRequest) ProtoMessage()

func (*ProbeStreamRequest) ProtoReflect 

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

func (*ProbeStreamRequest) Reset 

func (x *ProbeStreamRequest) Reset()

func (*ProbeStreamRequest) String 

func (x *ProbeStreamRequest) String() string

type ProbeStreamResponse 

type ProbeStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *Probe `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this Probe's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the Probe value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ProbeStreamResponse) Descriptor deprecated 

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

Deprecated: Use ProbeStreamResponse.ProtoReflect.Descriptor instead.

func (*ProbeStreamResponse) GetTime 

func (x *ProbeStreamResponse) GetTime() *timestamppb.Timestamp

func (*ProbeStreamResponse) GetType 

func (x *ProbeStreamResponse) GetType() subscriptions.Operation

func (*ProbeStreamResponse) GetValue 

func (x *ProbeStreamResponse) GetValue() *Probe

func (*ProbeStreamResponse) ProtoMessage 

func (*ProbeStreamResponse) ProtoMessage()

func (*ProbeStreamResponse) ProtoReflect 

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

func (*ProbeStreamResponse) Reset 

func (x *ProbeStreamResponse) Reset()

func (*ProbeStreamResponse) String 

func (x *ProbeStreamResponse) String() string

type UnimplementedProbeServiceServer 

type UnimplementedProbeServiceServer struct {
}

UnimplementedProbeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProbeServiceServer) GetAll 

func (UnimplementedProbeServiceServer) GetAll(*ProbeStreamRequest, ProbeService_GetAllServer) error

func (UnimplementedProbeServiceServer) GetAllBatched 

func (UnimplementedProbeServiceServer) GetAllBatched(*ProbeBatchedStreamRequest, ProbeService_GetAllBatchedServer) error

func (UnimplementedProbeServiceServer) GetMeta 

func (UnimplementedProbeServiceServer) GetMeta(context.Context, *ProbeStreamRequest) (*MetaResponse, error)

func (UnimplementedProbeServiceServer) GetOne 

func (UnimplementedProbeServiceServer) GetOne(context.Context, *ProbeRequest) (*ProbeResponse, error)

func (UnimplementedProbeServiceServer) GetSome 

func (UnimplementedProbeServiceServer) GetSome(*ProbeSomeRequest, ProbeService_GetSomeServer) error

func (UnimplementedProbeServiceServer) Subscribe 

func (UnimplementedProbeServiceServer) Subscribe(*ProbeStreamRequest, ProbeService_SubscribeServer) error

func (UnimplementedProbeServiceServer) SubscribeBatched 

func (UnimplementedProbeServiceServer) SubscribeBatched(*ProbeBatchedStreamRequest, ProbeService_SubscribeBatchedServer) error

func (UnimplementedProbeServiceServer) SubscribeMeta 

func (UnimplementedProbeServiceServer) SubscribeMeta(*ProbeStreamRequest, ProbeService_SubscribeMetaServer) error

type UnimplementedProbeStatsServiceServer 

type UnimplementedProbeStatsServiceServer struct {
}

UnimplementedProbeStatsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProbeStatsServiceServer) GetAll 

func (UnimplementedProbeStatsServiceServer) GetAll(*ProbeStatsStreamRequest, ProbeStatsService_GetAllServer) error

func (UnimplementedProbeStatsServiceServer) GetAllBatched 

func (UnimplementedProbeStatsServiceServer) GetAllBatched(*ProbeStatsBatchedStreamRequest, ProbeStatsService_GetAllBatchedServer) error

func (UnimplementedProbeStatsServiceServer) GetMeta 

func (UnimplementedProbeStatsServiceServer) GetMeta(context.Context, *ProbeStatsStreamRequest) (*MetaResponse, error)

func (UnimplementedProbeStatsServiceServer) GetOne 

func (UnimplementedProbeStatsServiceServer) GetOne(context.Context, *ProbeStatsRequest) (*ProbeStatsResponse, error)

func (UnimplementedProbeStatsServiceServer) GetSome 

func (UnimplementedProbeStatsServiceServer) GetSome(*ProbeStatsSomeRequest, ProbeStatsService_GetSomeServer) error

func (UnimplementedProbeStatsServiceServer) Subscribe 

func (UnimplementedProbeStatsServiceServer) Subscribe(*ProbeStatsStreamRequest, ProbeStatsService_SubscribeServer) error

func (UnimplementedProbeStatsServiceServer) SubscribeBatched 

func (UnimplementedProbeStatsServiceServer) SubscribeBatched(*ProbeStatsBatchedStreamRequest, ProbeStatsService_SubscribeBatchedServer) error

func (UnimplementedProbeStatsServiceServer) SubscribeMeta 

func (UnimplementedProbeStatsServiceServer) SubscribeMeta(*ProbeStatsStreamRequest, ProbeStatsService_SubscribeMetaServer) error

type UnsafeProbeServiceServer 

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

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

type UnsafeProbeStatsServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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