redirector

package
v0.0.0-...-459d1d0 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	AssignmentService_GetOne_FullMethodName           = "/arista.redirector.v1.AssignmentService/GetOne"
	AssignmentService_GetSome_FullMethodName          = "/arista.redirector.v1.AssignmentService/GetSome"
	AssignmentService_GetAll_FullMethodName           = "/arista.redirector.v1.AssignmentService/GetAll"
	AssignmentService_Subscribe_FullMethodName        = "/arista.redirector.v1.AssignmentService/Subscribe"
	AssignmentService_GetMeta_FullMethodName          = "/arista.redirector.v1.AssignmentService/GetMeta"
	AssignmentService_SubscribeMeta_FullMethodName    = "/arista.redirector.v1.AssignmentService/SubscribeMeta"
	AssignmentService_GetAllBatched_FullMethodName    = "/arista.redirector.v1.AssignmentService/GetAllBatched"
	AssignmentService_SubscribeBatched_FullMethodName = "/arista.redirector.v1.AssignmentService/SubscribeBatched"
)

Variables

View Source 
var AssignmentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.redirector.v1.AssignmentService",
	HandlerType: (*AssignmentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _AssignmentService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _AssignmentService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _AssignmentService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _AssignmentService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _AssignmentService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _AssignmentService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _AssignmentService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _AssignmentService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/redirector.v1/services.gen.proto",
}

AssignmentService_ServiceDesc is the grpc.ServiceDesc for AssignmentService 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 File_arista_redirector_v1_redirector_proto protoreflect.FileDescriptor
View Source 
var File_arista_redirector_v1_services_gen_proto protoreflect.FileDescriptor

Functions

func RegisterAssignmentServiceServer 

func RegisterAssignmentServiceServer(s grpc.ServiceRegistrar, srv AssignmentServiceServer)

Types

type Assignment 

type Assignment struct {

	// key uniquely identifies the assignment of system_id to the cluster.
	Key *AssignmentKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// clusters that the system is assigned to.
	Clusters *Clusters `protobuf:"bytes,2,opt,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

Assignment returns the information about the regional clusters that the system is assigned to. Each cluster consists of a series of hosts, each of which the client can use to connect.

func (*Assignment) Descriptor deprecated 

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

Deprecated: Use Assignment.ProtoReflect.Descriptor instead.

func (*Assignment) GetClusters 

func (x *Assignment) GetClusters() *Clusters

func (*Assignment) GetKey 

func (x *Assignment) GetKey() *AssignmentKey

func (*Assignment) ProtoMessage 

func (*Assignment) ProtoMessage()

func (*Assignment) ProtoReflect 

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

func (*Assignment) Reset 

func (x *Assignment) Reset()

func (*Assignment) String 

func (x *Assignment) String() string

type AssignmentBatchedStreamRequest 

type AssignmentBatchedStreamRequest 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 []*Assignment `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 Assignment at end.
	//   - Each Assignment response is fully-specified (all fields set).
	//   - start: Returns the state of each Assignment at start, followed by updates until now.
	//   - Each Assignment response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Assignment at start, followed by updates
	//     until end.
	//   - Each Assignment 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 (*AssignmentBatchedStreamRequest) Descriptor deprecated 

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

Deprecated: Use AssignmentBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*AssignmentBatchedStreamRequest) GetMaxMessages 

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

func (*AssignmentBatchedStreamRequest) GetPartialEqFilter 

func (x *AssignmentBatchedStreamRequest) GetPartialEqFilter() []*Assignment

func (*AssignmentBatchedStreamRequest) GetTime 

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

func (*AssignmentBatchedStreamRequest) ProtoMessage 

func (*AssignmentBatchedStreamRequest) ProtoMessage()

func (*AssignmentBatchedStreamRequest) ProtoReflect 

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

func (*AssignmentBatchedStreamRequest) Reset 

func (x *AssignmentBatchedStreamRequest) Reset()

func (*AssignmentBatchedStreamRequest) String 

func (x *AssignmentBatchedStreamRequest) String() string

type AssignmentBatchedStreamResponse 

type AssignmentBatchedStreamResponse 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 []*AssignmentStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignmentBatchedStreamResponse) Descriptor deprecated 

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

Deprecated: Use AssignmentBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*AssignmentBatchedStreamResponse) GetResponses 

func (x *AssignmentBatchedStreamResponse) GetResponses() []*AssignmentStreamResponse

func (*AssignmentBatchedStreamResponse) ProtoMessage 

func (*AssignmentBatchedStreamResponse) ProtoMessage()

func (*AssignmentBatchedStreamResponse) ProtoReflect 

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

func (*AssignmentBatchedStreamResponse) Reset 

func (x *AssignmentBatchedStreamResponse) Reset()

func (*AssignmentBatchedStreamResponse) String 

func (x *AssignmentBatchedStreamResponse) String() string

type AssignmentKey 

type AssignmentKey struct {

	// system_id is the unique identifier of a device.
	SystemId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=system_id,json=systemId,proto3" json:"system_id,omitempty"`
	// contains filtered or unexported fields
}

AssignmentKey allows to uniquely identify an assignment.

func (*AssignmentKey) Descriptor deprecated 

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

Deprecated: Use AssignmentKey.ProtoReflect.Descriptor instead.

func (*AssignmentKey) GetSystemId 

func (x *AssignmentKey) GetSystemId() *wrapperspb.StringValue

func (*AssignmentKey) ProtoMessage 

func (*AssignmentKey) ProtoMessage()

func (*AssignmentKey) ProtoReflect 

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

func (*AssignmentKey) Reset 

func (x *AssignmentKey) Reset()

func (*AssignmentKey) String 

func (x *AssignmentKey) String() string

type AssignmentRequest 

type AssignmentRequest struct {

	// Key uniquely identifies a Assignment instance to retrieve.
	// This value must be populated.
	Key *AssignmentKey `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 (*AssignmentRequest) Descriptor deprecated 

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

Deprecated: Use AssignmentRequest.ProtoReflect.Descriptor instead.

func (*AssignmentRequest) GetKey 

func (x *AssignmentRequest) GetKey() *AssignmentKey

func (*AssignmentRequest) GetTime 

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

func (*AssignmentRequest) ProtoMessage 

func (*AssignmentRequest) ProtoMessage()

func (*AssignmentRequest) ProtoReflect 

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

func (*AssignmentRequest) Reset 

func (x *AssignmentRequest) Reset()

func (*AssignmentRequest) String 

func (x *AssignmentRequest) String() string

type AssignmentResponse 

type AssignmentResponse 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 *Assignment `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// Assignment instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignmentResponse) Descriptor deprecated 

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

Deprecated: Use AssignmentResponse.ProtoReflect.Descriptor instead.

func (*AssignmentResponse) GetTime 

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

func (*AssignmentResponse) GetValue 

func (x *AssignmentResponse) GetValue() *Assignment

func (*AssignmentResponse) ProtoMessage 

func (*AssignmentResponse) ProtoMessage()

func (*AssignmentResponse) ProtoReflect 

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

func (*AssignmentResponse) Reset 

func (x *AssignmentResponse) Reset()

func (*AssignmentResponse) String 

func (x *AssignmentResponse) String() string

type AssignmentServiceClient 

type AssignmentServiceClient interface {
	GetOne(ctx context.Context, in *AssignmentRequest, opts ...grpc.CallOption) (*AssignmentResponse, error)
	GetSome(ctx context.Context, in *AssignmentSomeRequest, opts ...grpc.CallOption) (AssignmentService_GetSomeClient, error)
	GetAll(ctx context.Context, in *AssignmentStreamRequest, opts ...grpc.CallOption) (AssignmentService_GetAllClient, error)
	Subscribe(ctx context.Context, in *AssignmentStreamRequest, opts ...grpc.CallOption) (AssignmentService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *AssignmentStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *AssignmentStreamRequest, opts ...grpc.CallOption) (AssignmentService_SubscribeMetaClient, error)
	GetAllBatched(ctx context.Context, in *AssignmentBatchedStreamRequest, opts ...grpc.CallOption) (AssignmentService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *AssignmentBatchedStreamRequest, opts ...grpc.CallOption) (AssignmentService_SubscribeBatchedClient, error)
}

AssignmentServiceClient is the client API for AssignmentService 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 NewAssignmentServiceClient 

func NewAssignmentServiceClient(cc grpc.ClientConnInterface) AssignmentServiceClient

type AssignmentServiceServer 

type AssignmentServiceServer interface {
	GetOne(context.Context, *AssignmentRequest) (*AssignmentResponse, error)
	GetSome(*AssignmentSomeRequest, AssignmentService_GetSomeServer) error
	GetAll(*AssignmentStreamRequest, AssignmentService_GetAllServer) error
	Subscribe(*AssignmentStreamRequest, AssignmentService_SubscribeServer) error
	GetMeta(context.Context, *AssignmentStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*AssignmentStreamRequest, AssignmentService_SubscribeMetaServer) error
	GetAllBatched(*AssignmentBatchedStreamRequest, AssignmentService_GetAllBatchedServer) error
	SubscribeBatched(*AssignmentBatchedStreamRequest, AssignmentService_SubscribeBatchedServer) error
	// contains filtered or unexported methods
}

AssignmentServiceServer is the server API for AssignmentService service. All implementations must embed UnimplementedAssignmentServiceServer for forward compatibility

type AssignmentService_GetAllBatchedClient 

type AssignmentService_GetAllBatchedClient interface {
	Recv() (*AssignmentBatchedStreamResponse, error)
	grpc.ClientStream
}

type AssignmentService_GetAllBatchedServer 

type AssignmentService_GetAllBatchedServer interface {
	Send(*AssignmentBatchedStreamResponse) error
	grpc.ServerStream
}

type AssignmentService_GetAllClient 

type AssignmentService_GetAllClient interface {
	Recv() (*AssignmentStreamResponse, error)
	grpc.ClientStream
}

type AssignmentService_GetAllServer 

type AssignmentService_GetAllServer interface {
	Send(*AssignmentStreamResponse) error
	grpc.ServerStream
}

type AssignmentService_GetSomeClient 

type AssignmentService_GetSomeClient interface {
	Recv() (*AssignmentSomeResponse, error)
	grpc.ClientStream
}

type AssignmentService_GetSomeServer 

type AssignmentService_GetSomeServer interface {
	Send(*AssignmentSomeResponse) error
	grpc.ServerStream
}

type AssignmentService_SubscribeBatchedClient 

type AssignmentService_SubscribeBatchedClient interface {
	Recv() (*AssignmentBatchedStreamResponse, error)
	grpc.ClientStream
}

type AssignmentService_SubscribeBatchedServer 

type AssignmentService_SubscribeBatchedServer interface {
	Send(*AssignmentBatchedStreamResponse) error
	grpc.ServerStream
}

type AssignmentService_SubscribeClient 

type AssignmentService_SubscribeClient interface {
	Recv() (*AssignmentStreamResponse, error)
	grpc.ClientStream
}

type AssignmentService_SubscribeMetaClient 

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

type AssignmentService_SubscribeMetaServer 

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

type AssignmentService_SubscribeServer 

type AssignmentService_SubscribeServer interface {
	Send(*AssignmentStreamResponse) error
	grpc.ServerStream
}

type AssignmentSomeRequest 

type AssignmentSomeRequest struct {
	Keys []*AssignmentKey `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 (*AssignmentSomeRequest) Descriptor deprecated 

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

Deprecated: Use AssignmentSomeRequest.ProtoReflect.Descriptor instead.

func (*AssignmentSomeRequest) GetKeys 

func (x *AssignmentSomeRequest) GetKeys() []*AssignmentKey

func (*AssignmentSomeRequest) GetTime 

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

func (*AssignmentSomeRequest) ProtoMessage 

func (*AssignmentSomeRequest) ProtoMessage()

func (*AssignmentSomeRequest) ProtoReflect 

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

func (*AssignmentSomeRequest) Reset 

func (x *AssignmentSomeRequest) Reset()

func (*AssignmentSomeRequest) String 

func (x *AssignmentSomeRequest) String() string

type AssignmentSomeResponse 

type AssignmentSomeResponse 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 *Assignment `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 (*AssignmentSomeResponse) Descriptor deprecated 

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

Deprecated: Use AssignmentSomeResponse.ProtoReflect.Descriptor instead.

func (*AssignmentSomeResponse) GetError 

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

func (*AssignmentSomeResponse) GetTime 

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

func (*AssignmentSomeResponse) GetValue 

func (x *AssignmentSomeResponse) GetValue() *Assignment

func (*AssignmentSomeResponse) ProtoMessage 

func (*AssignmentSomeResponse) ProtoMessage()

func (*AssignmentSomeResponse) ProtoReflect 

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

func (*AssignmentSomeResponse) Reset 

func (x *AssignmentSomeResponse) Reset()

func (*AssignmentSomeResponse) String 

func (x *AssignmentSomeResponse) String() string

type AssignmentStreamRequest 

type AssignmentStreamRequest 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 []*Assignment `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 Assignment at end.
	//   - Each Assignment response is fully-specified (all fields set).
	//   - start: Returns the state of each Assignment at start, followed by updates until now.
	//   - Each Assignment response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Assignment at start, followed by updates
	//     until end.
	//   - Each Assignment 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 (*AssignmentStreamRequest) Descriptor deprecated 

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

Deprecated: Use AssignmentStreamRequest.ProtoReflect.Descriptor instead.

func (*AssignmentStreamRequest) GetPartialEqFilter 

func (x *AssignmentStreamRequest) GetPartialEqFilter() []*Assignment

func (*AssignmentStreamRequest) GetTime 

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

func (*AssignmentStreamRequest) ProtoMessage 

func (*AssignmentStreamRequest) ProtoMessage()

func (*AssignmentStreamRequest) ProtoReflect 

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

func (*AssignmentStreamRequest) Reset 

func (x *AssignmentStreamRequest) Reset()

func (*AssignmentStreamRequest) String 

func (x *AssignmentStreamRequest) String() string

type AssignmentStreamResponse 

type AssignmentStreamResponse 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 *Assignment `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this Assignment's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the Assignment 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 (*AssignmentStreamResponse) Descriptor deprecated 

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

Deprecated: Use AssignmentStreamResponse.ProtoReflect.Descriptor instead.

func (*AssignmentStreamResponse) GetTime 

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

func (*AssignmentStreamResponse) GetType 

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

func (*AssignmentStreamResponse) GetValue 

func (x *AssignmentStreamResponse) GetValue() *Assignment

func (*AssignmentStreamResponse) ProtoMessage 

func (*AssignmentStreamResponse) ProtoMessage()

func (*AssignmentStreamResponse) ProtoReflect 

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

func (*AssignmentStreamResponse) Reset 

func (x *AssignmentStreamResponse) Reset()

func (*AssignmentStreamResponse) String 

func (x *AssignmentStreamResponse) String() string

type Cluster 

type Cluster struct {

	// name of the cluster. The name can change over time as new clusters
	// are added or removed.
	Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// hosts in the cluster that the devices can connect to.
	Hosts *fmp.RepeatedString `protobuf:"bytes,2,opt,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetHosts 

func (x *Cluster) GetHosts() *fmp.RepeatedString

func (*Cluster) GetName 

func (x *Cluster) GetName() *wrapperspb.StringValue

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type Clusters 

type Clusters struct {

	// values contains the list of clusters associated with the region
	Values []*Cluster `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Clusters wraps a cluster list which contain the information about the hosts.

func (*Clusters) Descriptor deprecated 

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

Deprecated: Use Clusters.ProtoReflect.Descriptor instead.

func (*Clusters) GetValues 

func (x *Clusters) GetValues() []*Cluster

func (*Clusters) ProtoMessage 

func (*Clusters) ProtoMessage()

func (*Clusters) ProtoReflect 

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

func (*Clusters) Reset 

func (x *Clusters) Reset()

func (*Clusters) String 

func (x *Clusters) String() string

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 UnimplementedAssignmentServiceServer 

type UnimplementedAssignmentServiceServer struct {
}

UnimplementedAssignmentServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAssignmentServiceServer) GetAll 

func (UnimplementedAssignmentServiceServer) GetAll(*AssignmentStreamRequest, AssignmentService_GetAllServer) error

func (UnimplementedAssignmentServiceServer) GetAllBatched 

func (UnimplementedAssignmentServiceServer) GetAllBatched(*AssignmentBatchedStreamRequest, AssignmentService_GetAllBatchedServer) error

func (UnimplementedAssignmentServiceServer) GetMeta 

func (UnimplementedAssignmentServiceServer) GetMeta(context.Context, *AssignmentStreamRequest) (*MetaResponse, error)

func (UnimplementedAssignmentServiceServer) GetOne 

func (UnimplementedAssignmentServiceServer) GetOne(context.Context, *AssignmentRequest) (*AssignmentResponse, error)

func (UnimplementedAssignmentServiceServer) GetSome 

func (UnimplementedAssignmentServiceServer) GetSome(*AssignmentSomeRequest, AssignmentService_GetSomeServer) error

func (UnimplementedAssignmentServiceServer) Subscribe 

func (UnimplementedAssignmentServiceServer) Subscribe(*AssignmentStreamRequest, AssignmentService_SubscribeServer) error

func (UnimplementedAssignmentServiceServer) SubscribeBatched 

func (UnimplementedAssignmentServiceServer) SubscribeBatched(*AssignmentBatchedStreamRequest, AssignmentService_SubscribeBatchedServer) error

func (UnimplementedAssignmentServiceServer) SubscribeMeta 

func (UnimplementedAssignmentServiceServer) SubscribeMeta(*AssignmentStreamRequest, AssignmentService_SubscribeMetaServer) error

type UnsafeAssignmentServiceServer 

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

UnsafeAssignmentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AssignmentServiceServer 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.