Documentation ¶
Index ¶
- Variables
- func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)
- type Affiliate
- func (*Affiliate) Descriptor() ([]byte, []int)deprecated
- func (x *Affiliate) GetData() []byte
- func (x *Affiliate) GetEndpoints() [][]byte
- func (x *Affiliate) GetId() string
- func (m *Affiliate) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Affiliate) MarshalToVT(dAtA []byte) (int, error)
- func (m *Affiliate) MarshalVT() (dAtA []byte, err error)
- func (*Affiliate) ProtoMessage()
- func (x *Affiliate) ProtoReflect() protoreflect.Message
- func (x *Affiliate) Reset()
- func (m *Affiliate) SizeVT() (n int)
- func (x *Affiliate) String() string
- func (m *Affiliate) UnmarshalVT(dAtA []byte) error
- type AffiliateDeleteRequest
- func (*AffiliateDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AffiliateDeleteRequest) GetAffiliateId() string
- func (x *AffiliateDeleteRequest) GetClusterId() string
- func (m *AffiliateDeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AffiliateDeleteRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *AffiliateDeleteRequest) MarshalVT() (dAtA []byte, err error)
- func (*AffiliateDeleteRequest) ProtoMessage()
- func (x *AffiliateDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *AffiliateDeleteRequest) Reset()
- func (m *AffiliateDeleteRequest) SizeVT() (n int)
- func (x *AffiliateDeleteRequest) String() string
- func (m *AffiliateDeleteRequest) UnmarshalVT(dAtA []byte) error
- type AffiliateDeleteResponse
- func (*AffiliateDeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (m *AffiliateDeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AffiliateDeleteResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *AffiliateDeleteResponse) MarshalVT() (dAtA []byte, err error)
- func (*AffiliateDeleteResponse) ProtoMessage()
- func (x *AffiliateDeleteResponse) ProtoReflect() protoreflect.Message
- func (x *AffiliateDeleteResponse) Reset()
- func (m *AffiliateDeleteResponse) SizeVT() (n int)
- func (x *AffiliateDeleteResponse) String() string
- func (m *AffiliateDeleteResponse) UnmarshalVT(dAtA []byte) error
- type AffiliateUpdateRequest
- func (*AffiliateUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AffiliateUpdateRequest) GetAffiliateData() []byte
- func (x *AffiliateUpdateRequest) GetAffiliateEndpoints() [][]byte
- func (x *AffiliateUpdateRequest) GetAffiliateId() string
- func (x *AffiliateUpdateRequest) GetClusterId() string
- func (x *AffiliateUpdateRequest) GetTtl() *durationpb.Duration
- func (m *AffiliateUpdateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AffiliateUpdateRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *AffiliateUpdateRequest) MarshalVT() (dAtA []byte, err error)
- func (*AffiliateUpdateRequest) ProtoMessage()
- func (x *AffiliateUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *AffiliateUpdateRequest) Reset()
- func (m *AffiliateUpdateRequest) SizeVT() (n int)
- func (x *AffiliateUpdateRequest) String() string
- func (m *AffiliateUpdateRequest) UnmarshalVT(dAtA []byte) error
- type AffiliateUpdateResponse
- func (*AffiliateUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (m *AffiliateUpdateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AffiliateUpdateResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *AffiliateUpdateResponse) MarshalVT() (dAtA []byte, err error)
- func (*AffiliateUpdateResponse) ProtoMessage()
- func (x *AffiliateUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *AffiliateUpdateResponse) Reset()
- func (m *AffiliateUpdateResponse) SizeVT() (n int)
- func (x *AffiliateUpdateResponse) String() string
- func (m *AffiliateUpdateResponse) UnmarshalVT(dAtA []byte) error
- type ClusterClient
- type ClusterServer
- type Cluster_WatchClient
- type Cluster_WatchServer
- type HelloRequest
- func (*HelloRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HelloRequest) GetClientVersion() string
- func (x *HelloRequest) GetClusterId() string
- func (m *HelloRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *HelloRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *HelloRequest) MarshalVT() (dAtA []byte, err error)
- func (*HelloRequest) ProtoMessage()
- func (x *HelloRequest) ProtoReflect() protoreflect.Message
- func (x *HelloRequest) Reset()
- func (m *HelloRequest) SizeVT() (n int)
- func (x *HelloRequest) String() string
- func (m *HelloRequest) UnmarshalVT(dAtA []byte) error
- type HelloResponse
- func (*HelloResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HelloResponse) GetClientIp() []byte
- func (x *HelloResponse) GetRedirect() *RedirectMessage
- func (m *HelloResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *HelloResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *HelloResponse) MarshalVT() (dAtA []byte, err error)
- func (*HelloResponse) ProtoMessage()
- func (x *HelloResponse) ProtoReflect() protoreflect.Message
- func (x *HelloResponse) Reset()
- func (m *HelloResponse) SizeVT() (n int)
- func (x *HelloResponse) String() string
- func (m *HelloResponse) UnmarshalVT(dAtA []byte) error
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetClusterId() string
- func (m *ListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListRequest) MarshalVT() (dAtA []byte, err error)
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (m *ListRequest) SizeVT() (n int)
- func (x *ListRequest) String() string
- func (m *ListRequest) UnmarshalVT(dAtA []byte) error
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetAffiliates() []*Affiliate
- func (m *ListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListResponse) MarshalVT() (dAtA []byte, err error)
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (m *ListResponse) SizeVT() (n int)
- func (x *ListResponse) String() string
- func (m *ListResponse) UnmarshalVT(dAtA []byte) error
- type RedirectMessage
- func (*RedirectMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RedirectMessage) GetEndpoint() string
- func (m *RedirectMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RedirectMessage) MarshalToVT(dAtA []byte) (int, error)
- func (m *RedirectMessage) MarshalVT() (dAtA []byte, err error)
- func (*RedirectMessage) ProtoMessage()
- func (x *RedirectMessage) ProtoReflect() protoreflect.Message
- func (x *RedirectMessage) Reset()
- func (m *RedirectMessage) SizeVT() (n int)
- func (x *RedirectMessage) String() string
- func (m *RedirectMessage) UnmarshalVT(dAtA []byte) error
- type UnimplementedClusterServer
- func (UnimplementedClusterServer) AffiliateDelete(context.Context, *AffiliateDeleteRequest) (*AffiliateDeleteResponse, error)
- func (UnimplementedClusterServer) AffiliateUpdate(context.Context, *AffiliateUpdateRequest) (*AffiliateUpdateResponse, error)
- func (UnimplementedClusterServer) Hello(context.Context, *HelloRequest) (*HelloResponse, error)
- func (UnimplementedClusterServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedClusterServer) Watch(*WatchRequest, Cluster_WatchServer) error
- type UnsafeClusterServer
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchRequest) GetClusterId() string
- func (m *WatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *WatchRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *WatchRequest) MarshalVT() (dAtA []byte, err error)
- func (*WatchRequest) ProtoMessage()
- func (x *WatchRequest) ProtoReflect() protoreflect.Message
- func (x *WatchRequest) Reset()
- func (m *WatchRequest) SizeVT() (n int)
- func (x *WatchRequest) String() string
- func (m *WatchRequest) UnmarshalVT(dAtA []byte) error
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchResponse) GetAffiliates() []*Affiliate
- func (x *WatchResponse) GetDeleted() bool
- func (m *WatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *WatchResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *WatchResponse) MarshalVT() (dAtA []byte, err error)
- func (*WatchResponse) ProtoMessage()
- func (x *WatchResponse) ProtoReflect() protoreflect.Message
- func (x *WatchResponse) Reset()
- func (m *WatchResponse) SizeVT() (n int)
- func (x *WatchResponse) String() string
- func (m *WatchResponse) UnmarshalVT(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var Cluster_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sidero.discovery.server.Cluster", HandlerType: (*ClusterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Hello", Handler: _Cluster_Hello_Handler, }, { MethodName: "AffiliateUpdate", Handler: _Cluster_AffiliateUpdate_Handler, }, { MethodName: "AffiliateDelete", Handler: _Cluster_AffiliateDelete_Handler, }, { MethodName: "List", Handler: _Cluster_List_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Watch", Handler: _Cluster_Watch_Handler, ServerStreams: true, }, }, Metadata: "v1alpha1/server/pb/cluster.proto", }
Cluster_ServiceDesc is the grpc.ServiceDesc for Cluster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_v1alpha1_server_pb_cluster_proto protoreflect.FileDescriptor
Functions ¶
func RegisterClusterServer ¶
func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)
Types ¶
type Affiliate ¶
type Affiliate struct { // Affiliate ID. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Affiliate data (encrypted). Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // Affiliate endpoints (encrypted)/ Endpoints [][]byte `protobuf:"bytes,3,rep,name=endpoints,proto3" json:"endpoints,omitempty"` // contains filtered or unexported fields }
func (*Affiliate) Descriptor
deprecated
func (*Affiliate) GetEndpoints ¶
func (*Affiliate) MarshalToSizedBufferVT ¶
func (*Affiliate) ProtoMessage ¶
func (*Affiliate) ProtoMessage()
func (*Affiliate) ProtoReflect ¶
func (x *Affiliate) ProtoReflect() protoreflect.Message
func (*Affiliate) UnmarshalVT ¶
type AffiliateDeleteRequest ¶
type AffiliateDeleteRequest struct { // Client ClusterID. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Affiliate ID to delete. AffiliateId string `protobuf:"bytes,2,opt,name=affiliate_id,json=affiliateId,proto3" json:"affiliate_id,omitempty"` // contains filtered or unexported fields }
func (*AffiliateDeleteRequest) Descriptor
deprecated
func (*AffiliateDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use AffiliateDeleteRequest.ProtoReflect.Descriptor instead.
func (*AffiliateDeleteRequest) GetAffiliateId ¶
func (x *AffiliateDeleteRequest) GetAffiliateId() string
func (*AffiliateDeleteRequest) GetClusterId ¶
func (x *AffiliateDeleteRequest) GetClusterId() string
func (*AffiliateDeleteRequest) MarshalToSizedBufferVT ¶
func (m *AffiliateDeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AffiliateDeleteRequest) MarshalToVT ¶
func (m *AffiliateDeleteRequest) MarshalToVT(dAtA []byte) (int, error)
func (*AffiliateDeleteRequest) MarshalVT ¶
func (m *AffiliateDeleteRequest) MarshalVT() (dAtA []byte, err error)
func (*AffiliateDeleteRequest) ProtoMessage ¶
func (*AffiliateDeleteRequest) ProtoMessage()
func (*AffiliateDeleteRequest) ProtoReflect ¶
func (x *AffiliateDeleteRequest) ProtoReflect() protoreflect.Message
func (*AffiliateDeleteRequest) Reset ¶
func (x *AffiliateDeleteRequest) Reset()
func (*AffiliateDeleteRequest) SizeVT ¶
func (m *AffiliateDeleteRequest) SizeVT() (n int)
func (*AffiliateDeleteRequest) String ¶
func (x *AffiliateDeleteRequest) String() string
func (*AffiliateDeleteRequest) UnmarshalVT ¶
func (m *AffiliateDeleteRequest) UnmarshalVT(dAtA []byte) error
type AffiliateDeleteResponse ¶
type AffiliateDeleteResponse struct {
// contains filtered or unexported fields
}
func (*AffiliateDeleteResponse) Descriptor
deprecated
func (*AffiliateDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use AffiliateDeleteResponse.ProtoReflect.Descriptor instead.
func (*AffiliateDeleteResponse) MarshalToSizedBufferVT ¶
func (m *AffiliateDeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AffiliateDeleteResponse) MarshalToVT ¶
func (m *AffiliateDeleteResponse) MarshalToVT(dAtA []byte) (int, error)
func (*AffiliateDeleteResponse) MarshalVT ¶
func (m *AffiliateDeleteResponse) MarshalVT() (dAtA []byte, err error)
func (*AffiliateDeleteResponse) ProtoMessage ¶
func (*AffiliateDeleteResponse) ProtoMessage()
func (*AffiliateDeleteResponse) ProtoReflect ¶
func (x *AffiliateDeleteResponse) ProtoReflect() protoreflect.Message
func (*AffiliateDeleteResponse) Reset ¶
func (x *AffiliateDeleteResponse) Reset()
func (*AffiliateDeleteResponse) SizeVT ¶
func (m *AffiliateDeleteResponse) SizeVT() (n int)
func (*AffiliateDeleteResponse) String ¶
func (x *AffiliateDeleteResponse) String() string
func (*AffiliateDeleteResponse) UnmarshalVT ¶
func (m *AffiliateDeleteResponse) UnmarshalVT(dAtA []byte) error
type AffiliateUpdateRequest ¶
type AffiliateUpdateRequest struct { // Client ClusterID. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Affiliate ID to update. AffiliateId string `protobuf:"bytes,2,opt,name=affiliate_id,json=affiliateId,proto3" json:"affiliate_id,omitempty"` // Encrypted affiliate data. // // If missing, affiliate data is not updated. AffiliateData []byte `protobuf:"bytes,3,opt,name=affiliate_data,json=affiliateData,proto3,oneof" json:"affiliate_data,omitempty"` // Encrypted list of affiliate endpoints. // // Endpoints are merged with the existing list of endpoints. AffiliateEndpoints [][]byte `protobuf:"bytes,4,rep,name=affiliate_endpoints,json=affiliateEndpoints,proto3" json:"affiliate_endpoints,omitempty"` // TTL for the new data submitted. Ttl *durationpb.Duration `protobuf:"bytes,5,opt,name=ttl,proto3" json:"ttl,omitempty"` // contains filtered or unexported fields }
func (*AffiliateUpdateRequest) Descriptor
deprecated
func (*AffiliateUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use AffiliateUpdateRequest.ProtoReflect.Descriptor instead.
func (*AffiliateUpdateRequest) GetAffiliateData ¶
func (x *AffiliateUpdateRequest) GetAffiliateData() []byte
func (*AffiliateUpdateRequest) GetAffiliateEndpoints ¶
func (x *AffiliateUpdateRequest) GetAffiliateEndpoints() [][]byte
func (*AffiliateUpdateRequest) GetAffiliateId ¶
func (x *AffiliateUpdateRequest) GetAffiliateId() string
func (*AffiliateUpdateRequest) GetClusterId ¶
func (x *AffiliateUpdateRequest) GetClusterId() string
func (*AffiliateUpdateRequest) GetTtl ¶
func (x *AffiliateUpdateRequest) GetTtl() *durationpb.Duration
func (*AffiliateUpdateRequest) MarshalToSizedBufferVT ¶
func (m *AffiliateUpdateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AffiliateUpdateRequest) MarshalToVT ¶
func (m *AffiliateUpdateRequest) MarshalToVT(dAtA []byte) (int, error)
func (*AffiliateUpdateRequest) MarshalVT ¶
func (m *AffiliateUpdateRequest) MarshalVT() (dAtA []byte, err error)
func (*AffiliateUpdateRequest) ProtoMessage ¶
func (*AffiliateUpdateRequest) ProtoMessage()
func (*AffiliateUpdateRequest) ProtoReflect ¶
func (x *AffiliateUpdateRequest) ProtoReflect() protoreflect.Message
func (*AffiliateUpdateRequest) Reset ¶
func (x *AffiliateUpdateRequest) Reset()
func (*AffiliateUpdateRequest) SizeVT ¶
func (m *AffiliateUpdateRequest) SizeVT() (n int)
func (*AffiliateUpdateRequest) String ¶
func (x *AffiliateUpdateRequest) String() string
func (*AffiliateUpdateRequest) UnmarshalVT ¶
func (m *AffiliateUpdateRequest) UnmarshalVT(dAtA []byte) error
type AffiliateUpdateResponse ¶
type AffiliateUpdateResponse struct {
// contains filtered or unexported fields
}
func (*AffiliateUpdateResponse) Descriptor
deprecated
func (*AffiliateUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use AffiliateUpdateResponse.ProtoReflect.Descriptor instead.
func (*AffiliateUpdateResponse) MarshalToSizedBufferVT ¶
func (m *AffiliateUpdateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AffiliateUpdateResponse) MarshalToVT ¶
func (m *AffiliateUpdateResponse) MarshalToVT(dAtA []byte) (int, error)
func (*AffiliateUpdateResponse) MarshalVT ¶
func (m *AffiliateUpdateResponse) MarshalVT() (dAtA []byte, err error)
func (*AffiliateUpdateResponse) ProtoMessage ¶
func (*AffiliateUpdateResponse) ProtoMessage()
func (*AffiliateUpdateResponse) ProtoReflect ¶
func (x *AffiliateUpdateResponse) ProtoReflect() protoreflect.Message
func (*AffiliateUpdateResponse) Reset ¶
func (x *AffiliateUpdateResponse) Reset()
func (*AffiliateUpdateResponse) SizeVT ¶
func (m *AffiliateUpdateResponse) SizeVT() (n int)
func (*AffiliateUpdateResponse) String ¶
func (x *AffiliateUpdateResponse) String() string
func (*AffiliateUpdateResponse) UnmarshalVT ¶
func (m *AffiliateUpdateResponse) UnmarshalVT(dAtA []byte) error
type ClusterClient ¶
type ClusterClient interface { // Hello is the first request sent by the client. // // Server might redirect the client to a different instance. Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error) // AffiliateUpdate updates (or creates) affiliate in the cluster. AffiliateUpdate(ctx context.Context, in *AffiliateUpdateRequest, opts ...grpc.CallOption) (*AffiliateUpdateResponse, error) // AffiliateDelete deletes affiliate from the cluster. AffiliateDelete(ctx context.Context, in *AffiliateDeleteRequest, opts ...grpc.CallOption) (*AffiliateDeleteResponse, error) // List affiliates in the cluster. List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) // Watch affiliate updates in the cluster. // // The first WatchResponse contains the snapshot of the current affiliate state (even if empty). // Subsequent response messages are sent as the affiliates get changed. Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Cluster_WatchClient, error) }
ClusterClient is the client API for Cluster 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 NewClusterClient ¶
func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient
type ClusterServer ¶
type ClusterServer interface { // Hello is the first request sent by the client. // // Server might redirect the client to a different instance. Hello(context.Context, *HelloRequest) (*HelloResponse, error) // AffiliateUpdate updates (or creates) affiliate in the cluster. AffiliateUpdate(context.Context, *AffiliateUpdateRequest) (*AffiliateUpdateResponse, error) // AffiliateDelete deletes affiliate from the cluster. AffiliateDelete(context.Context, *AffiliateDeleteRequest) (*AffiliateDeleteResponse, error) // List affiliates in the cluster. List(context.Context, *ListRequest) (*ListResponse, error) // Watch affiliate updates in the cluster. // // The first WatchResponse contains the snapshot of the current affiliate state (even if empty). // Subsequent response messages are sent as the affiliates get changed. Watch(*WatchRequest, Cluster_WatchServer) error // contains filtered or unexported methods }
ClusterServer is the server API for Cluster service. All implementations must embed UnimplementedClusterServer for forward compatibility
type Cluster_WatchClient ¶
type Cluster_WatchClient interface { Recv() (*WatchResponse, error) grpc.ClientStream }
type Cluster_WatchServer ¶
type Cluster_WatchServer interface { Send(*WatchResponse) error grpc.ServerStream }
type HelloRequest ¶
type HelloRequest struct { // ClusterID of the client. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Client version. ClientVersion string `protobuf:"bytes,2,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"` // contains filtered or unexported fields }
func (*HelloRequest) Descriptor
deprecated
func (*HelloRequest) Descriptor() ([]byte, []int)
Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.
func (*HelloRequest) GetClientVersion ¶
func (x *HelloRequest) GetClientVersion() string
func (*HelloRequest) GetClusterId ¶
func (x *HelloRequest) GetClusterId() string
func (*HelloRequest) MarshalToSizedBufferVT ¶
func (m *HelloRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*HelloRequest) MarshalToVT ¶
func (m *HelloRequest) MarshalToVT(dAtA []byte) (int, error)
func (*HelloRequest) MarshalVT ¶
func (m *HelloRequest) MarshalVT() (dAtA []byte, err error)
func (*HelloRequest) ProtoMessage ¶
func (*HelloRequest) ProtoMessage()
func (*HelloRequest) ProtoReflect ¶
func (x *HelloRequest) ProtoReflect() protoreflect.Message
func (*HelloRequest) Reset ¶
func (x *HelloRequest) Reset()
func (*HelloRequest) SizeVT ¶
func (m *HelloRequest) SizeVT() (n int)
func (*HelloRequest) String ¶
func (x *HelloRequest) String() string
func (*HelloRequest) UnmarshalVT ¶
func (m *HelloRequest) UnmarshalVT(dAtA []byte) error
type HelloResponse ¶
type HelloResponse struct { // If redirect is present, client should immediately reconnect to a different endpoint. Redirect *RedirectMessage `protobuf:"bytes,1,opt,name=redirect,proto3,oneof" json:"redirect,omitempty"` // Client IP as seen by the server. ClientIp []byte `protobuf:"bytes,2,opt,name=client_ip,json=clientIp,proto3" json:"client_ip,omitempty"` // contains filtered or unexported fields }
func (*HelloResponse) Descriptor
deprecated
func (*HelloResponse) Descriptor() ([]byte, []int)
Deprecated: Use HelloResponse.ProtoReflect.Descriptor instead.
func (*HelloResponse) GetClientIp ¶
func (x *HelloResponse) GetClientIp() []byte
func (*HelloResponse) GetRedirect ¶
func (x *HelloResponse) GetRedirect() *RedirectMessage
func (*HelloResponse) MarshalToSizedBufferVT ¶
func (m *HelloResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*HelloResponse) MarshalToVT ¶
func (m *HelloResponse) MarshalToVT(dAtA []byte) (int, error)
func (*HelloResponse) MarshalVT ¶
func (m *HelloResponse) MarshalVT() (dAtA []byte, err error)
func (*HelloResponse) ProtoMessage ¶
func (*HelloResponse) ProtoMessage()
func (*HelloResponse) ProtoReflect ¶
func (x *HelloResponse) ProtoReflect() protoreflect.Message
func (*HelloResponse) Reset ¶
func (x *HelloResponse) Reset()
func (*HelloResponse) SizeVT ¶
func (m *HelloResponse) SizeVT() (n int)
func (*HelloResponse) String ¶
func (x *HelloResponse) String() string
func (*HelloResponse) UnmarshalVT ¶
func (m *HelloResponse) UnmarshalVT(dAtA []byte) error
type ListRequest ¶
type ListRequest struct { // Client ClusterID. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetClusterId ¶
func (x *ListRequest) GetClusterId() string
func (*ListRequest) MarshalToSizedBufferVT ¶
func (m *ListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListRequest) MarshalToVT ¶
func (m *ListRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ListRequest) MarshalVT ¶
func (m *ListRequest) MarshalVT() (dAtA []byte, err error)
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) SizeVT ¶
func (m *ListRequest) SizeVT() (n int)
func (*ListRequest) String ¶
func (x *ListRequest) String() string
func (*ListRequest) UnmarshalVT ¶
func (m *ListRequest) UnmarshalVT(dAtA []byte) error
type ListResponse ¶
type ListResponse struct { // List of cluster affiliates. Affiliates []*Affiliate `protobuf:"bytes,1,rep,name=affiliates,proto3" json:"affiliates,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetAffiliates ¶
func (x *ListResponse) GetAffiliates() []*Affiliate
func (*ListResponse) MarshalToSizedBufferVT ¶
func (m *ListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListResponse) MarshalToVT ¶
func (m *ListResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ListResponse) MarshalVT ¶
func (m *ListResponse) MarshalVT() (dAtA []byte, err error)
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) SizeVT ¶
func (m *ListResponse) SizeVT() (n int)
func (*ListResponse) String ¶
func (x *ListResponse) String() string
func (*ListResponse) UnmarshalVT ¶
func (m *ListResponse) UnmarshalVT(dAtA []byte) error
type RedirectMessage ¶
type RedirectMessage struct { // gRPC URL of the service endpoint to connect to. Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // contains filtered or unexported fields }
func (*RedirectMessage) Descriptor
deprecated
func (*RedirectMessage) Descriptor() ([]byte, []int)
Deprecated: Use RedirectMessage.ProtoReflect.Descriptor instead.
func (*RedirectMessage) GetEndpoint ¶
func (x *RedirectMessage) GetEndpoint() string
func (*RedirectMessage) MarshalToSizedBufferVT ¶
func (m *RedirectMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RedirectMessage) MarshalToVT ¶
func (m *RedirectMessage) MarshalToVT(dAtA []byte) (int, error)
func (*RedirectMessage) MarshalVT ¶
func (m *RedirectMessage) MarshalVT() (dAtA []byte, err error)
func (*RedirectMessage) ProtoMessage ¶
func (*RedirectMessage) ProtoMessage()
func (*RedirectMessage) ProtoReflect ¶
func (x *RedirectMessage) ProtoReflect() protoreflect.Message
func (*RedirectMessage) Reset ¶
func (x *RedirectMessage) Reset()
func (*RedirectMessage) SizeVT ¶
func (m *RedirectMessage) SizeVT() (n int)
func (*RedirectMessage) String ¶
func (x *RedirectMessage) String() string
func (*RedirectMessage) UnmarshalVT ¶
func (m *RedirectMessage) UnmarshalVT(dAtA []byte) error
type UnimplementedClusterServer ¶
type UnimplementedClusterServer struct { }
UnimplementedClusterServer must be embedded to have forward compatible implementations.
func (UnimplementedClusterServer) AffiliateDelete ¶
func (UnimplementedClusterServer) AffiliateDelete(context.Context, *AffiliateDeleteRequest) (*AffiliateDeleteResponse, error)
func (UnimplementedClusterServer) AffiliateUpdate ¶
func (UnimplementedClusterServer) AffiliateUpdate(context.Context, *AffiliateUpdateRequest) (*AffiliateUpdateResponse, error)
func (UnimplementedClusterServer) Hello ¶
func (UnimplementedClusterServer) Hello(context.Context, *HelloRequest) (*HelloResponse, error)
func (UnimplementedClusterServer) List ¶
func (UnimplementedClusterServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedClusterServer) Watch ¶
func (UnimplementedClusterServer) Watch(*WatchRequest, Cluster_WatchServer) error
type UnsafeClusterServer ¶
type UnsafeClusterServer interface {
// contains filtered or unexported methods
}
UnsafeClusterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServer will result in compilation errors.
type WatchRequest ¶
type WatchRequest struct { // Client ClusterID. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*WatchRequest) Descriptor
deprecated
func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) GetClusterId ¶
func (x *WatchRequest) GetClusterId() string
func (*WatchRequest) MarshalToSizedBufferVT ¶
func (m *WatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WatchRequest) MarshalToVT ¶
func (m *WatchRequest) MarshalToVT(dAtA []byte) (int, error)
func (*WatchRequest) MarshalVT ¶
func (m *WatchRequest) MarshalVT() (dAtA []byte, err error)
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) SizeVT ¶
func (m *WatchRequest) SizeVT() (n int)
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
func (*WatchRequest) UnmarshalVT ¶
func (m *WatchRequest) UnmarshalVT(dAtA []byte) error
type WatchResponse ¶
type WatchResponse struct { // List of cluster affiliates. Affiliates []*Affiliate `protobuf:"bytes,1,rep,name=affiliates,proto3" json:"affiliates,omitempty"` // Flag that affiliate was deleted, only ID field is valid. Deleted bool `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"` // contains filtered or unexported fields }
func (*WatchResponse) Descriptor
deprecated
func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) GetAffiliates ¶
func (x *WatchResponse) GetAffiliates() []*Affiliate
func (*WatchResponse) GetDeleted ¶
func (x *WatchResponse) GetDeleted() bool
func (*WatchResponse) MarshalToSizedBufferVT ¶
func (m *WatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WatchResponse) MarshalToVT ¶
func (m *WatchResponse) MarshalToVT(dAtA []byte) (int, error)
func (*WatchResponse) MarshalVT ¶
func (m *WatchResponse) MarshalVT() (dAtA []byte, err error)
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) ProtoReflect ¶
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) SizeVT ¶
func (m *WatchResponse) SizeVT() (n int)
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string
func (*WatchResponse) UnmarshalVT ¶
func (m *WatchResponse) UnmarshalVT(dAtA []byte) error