pb

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2024 License: MPL-2.0 Imports: 14 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	Cluster_Hello_FullMethodName           = "/sidero.discovery.server.Cluster/Hello"
	Cluster_AffiliateUpdate_FullMethodName = "/sidero.discovery.server.Cluster/AffiliateUpdate"
	Cluster_AffiliateDelete_FullMethodName = "/sidero.discovery.server.Cluster/AffiliateDelete"
	Cluster_List_FullMethodName            = "/sidero.discovery.server.Cluster/List"
	Cluster_Watch_FullMethodName           = "/sidero.discovery.server.Cluster/Watch"
)

Variables

View Source 
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)

View Source 
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) CloneMessageVT added in v0.1.4 

func (m *Affiliate) CloneMessageVT() proto.Message

func (*Affiliate) CloneVT added in v0.1.4 

func (m *Affiliate) CloneVT() *Affiliate

func (*Affiliate) Descriptor deprecated 

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

Deprecated: Use Affiliate.ProtoReflect.Descriptor instead.

func (*Affiliate) EqualMessageVT added in v0.1.2 

func (this *Affiliate) EqualMessageVT(thatMsg proto.Message) bool

func (*Affiliate) EqualVT added in v0.1.2 

func (this *Affiliate) EqualVT(that *Affiliate) bool

func (*Affiliate) GetData 

func (x *Affiliate) GetData() []byte

func (*Affiliate) GetEndpoints 

func (x *Affiliate) GetEndpoints() [][]byte

func (*Affiliate) GetId 

func (x *Affiliate) GetId() string

func (*Affiliate) MarshalToSizedBufferVT 

func (m *Affiliate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Affiliate) MarshalToVT 

func (m *Affiliate) MarshalToVT(dAtA []byte) (int, error)

func (*Affiliate) MarshalVT 

func (m *Affiliate) MarshalVT() (dAtA []byte, err error)

func (*Affiliate) ProtoMessage 

func (*Affiliate) ProtoMessage()

func (*Affiliate) ProtoReflect 

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

func (*Affiliate) Reset 

func (x *Affiliate) Reset()

func (*Affiliate) SizeVT 

func (m *Affiliate) SizeVT() (n int)

func (*Affiliate) String 

func (x *Affiliate) String() string

func (*Affiliate) UnmarshalVT 

func (m *Affiliate) UnmarshalVT(dAtA []byte) error

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) CloneMessageVT added in v0.1.4 

func (m *AffiliateDeleteRequest) CloneMessageVT() proto.Message

func (*AffiliateDeleteRequest) CloneVT added in v0.1.4 

func (m *AffiliateDeleteRequest) CloneVT() *AffiliateDeleteRequest

func (*AffiliateDeleteRequest) Descriptor deprecated 

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

Deprecated: Use AffiliateDeleteRequest.ProtoReflect.Descriptor instead.

func (*AffiliateDeleteRequest) EqualMessageVT added in v0.1.2 

func (this *AffiliateDeleteRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*AffiliateDeleteRequest) EqualVT added in v0.1.2 

func (this *AffiliateDeleteRequest) EqualVT(that *AffiliateDeleteRequest) bool

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) CloneMessageVT added in v0.1.4 

func (m *AffiliateDeleteResponse) CloneMessageVT() proto.Message

func (*AffiliateDeleteResponse) CloneVT added in v0.1.4 

func (m *AffiliateDeleteResponse) CloneVT() *AffiliateDeleteResponse

func (*AffiliateDeleteResponse) Descriptor deprecated 

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

Deprecated: Use AffiliateDeleteResponse.ProtoReflect.Descriptor instead.

func (*AffiliateDeleteResponse) EqualMessageVT added in v0.1.2 

func (this *AffiliateDeleteResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*AffiliateDeleteResponse) EqualVT added in v0.1.2 

func (this *AffiliateDeleteResponse) EqualVT(that *AffiliateDeleteResponse) bool

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) CloneMessageVT added in v0.1.4 

func (m *AffiliateUpdateRequest) CloneMessageVT() proto.Message

func (*AffiliateUpdateRequest) CloneVT added in v0.1.4 

func (m *AffiliateUpdateRequest) CloneVT() *AffiliateUpdateRequest

func (*AffiliateUpdateRequest) Descriptor deprecated 

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

Deprecated: Use AffiliateUpdateRequest.ProtoReflect.Descriptor instead.

func (*AffiliateUpdateRequest) EqualMessageVT added in v0.1.2 

func (this *AffiliateUpdateRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*AffiliateUpdateRequest) EqualVT added in v0.1.2 

func (this *AffiliateUpdateRequest) EqualVT(that *AffiliateUpdateRequest) bool

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) CloneMessageVT added in v0.1.4 

func (m *AffiliateUpdateResponse) CloneMessageVT() proto.Message

func (*AffiliateUpdateResponse) CloneVT added in v0.1.4 

func (m *AffiliateUpdateResponse) CloneVT() *AffiliateUpdateResponse

func (*AffiliateUpdateResponse) Descriptor deprecated 

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

Deprecated: Use AffiliateUpdateResponse.ProtoReflect.Descriptor instead.

func (*AffiliateUpdateResponse) EqualMessageVT added in v0.1.2 

func (this *AffiliateUpdateResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*AffiliateUpdateResponse) EqualVT added in v0.1.2 

func (this *AffiliateUpdateResponse) EqualVT(that *AffiliateUpdateResponse) bool

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) (grpc.ServerStreamingClient[WatchResponse], 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, grpc.ServerStreamingServer[WatchResponse]) 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 = grpc.ServerStreamingClient[WatchResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Cluster_WatchServer 

type Cluster_WatchServer = grpc.ServerStreamingServer[WatchResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

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) CloneMessageVT added in v0.1.4 

func (m *HelloRequest) CloneMessageVT() proto.Message

func (*HelloRequest) CloneVT added in v0.1.4 

func (m *HelloRequest) CloneVT() *HelloRequest

func (*HelloRequest) Descriptor deprecated 

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

Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.

func (*HelloRequest) EqualMessageVT added in v0.1.2 

func (this *HelloRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*HelloRequest) EqualVT added in v0.1.2 

func (this *HelloRequest) EqualVT(that *HelloRequest) bool

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) CloneMessageVT added in v0.1.4 

func (m *HelloResponse) CloneMessageVT() proto.Message

func (*HelloResponse) CloneVT added in v0.1.4 

func (m *HelloResponse) CloneVT() *HelloResponse

func (*HelloResponse) Descriptor deprecated 

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

Deprecated: Use HelloResponse.ProtoReflect.Descriptor instead.

func (*HelloResponse) EqualMessageVT added in v0.1.2 

func (this *HelloResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*HelloResponse) EqualVT added in v0.1.2 

func (this *HelloResponse) EqualVT(that *HelloResponse) bool

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) CloneMessageVT added in v0.1.4 

func (m *ListRequest) CloneMessageVT() proto.Message

func (*ListRequest) CloneVT added in v0.1.4 

func (m *ListRequest) CloneVT() *ListRequest

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) EqualMessageVT added in v0.1.2 

func (this *ListRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*ListRequest) EqualVT added in v0.1.2 

func (this *ListRequest) EqualVT(that *ListRequest) bool

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) CloneMessageVT added in v0.1.4 

func (m *ListResponse) CloneMessageVT() proto.Message

func (*ListResponse) CloneVT added in v0.1.4 

func (m *ListResponse) CloneVT() *ListResponse

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) EqualMessageVT added in v0.1.2 

func (this *ListResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*ListResponse) EqualVT added in v0.1.2 

func (this *ListResponse) EqualVT(that *ListResponse) bool

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) CloneMessageVT added in v0.1.4 

func (m *RedirectMessage) CloneMessageVT() proto.Message

func (*RedirectMessage) CloneVT added in v0.1.4 

func (m *RedirectMessage) CloneVT() *RedirectMessage

func (*RedirectMessage) Descriptor deprecated 

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

Deprecated: Use RedirectMessage.ProtoReflect.Descriptor instead.

func (*RedirectMessage) EqualMessageVT added in v0.1.2 

func (this *RedirectMessage) EqualMessageVT(thatMsg proto.Message) bool

func (*RedirectMessage) EqualVT added in v0.1.2 

func (this *RedirectMessage) EqualVT(that *RedirectMessage) bool

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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, grpc.ServerStreamingServer[WatchResponse]) 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) CloneMessageVT added in v0.1.4 

func (m *WatchRequest) CloneMessageVT() proto.Message

func (*WatchRequest) CloneVT added in v0.1.4 

func (m *WatchRequest) CloneVT() *WatchRequest

func (*WatchRequest) Descriptor deprecated 

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) EqualMessageVT added in v0.1.2 

func (this *WatchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*WatchRequest) EqualVT added in v0.1.2 

func (this *WatchRequest) EqualVT(that *WatchRequest) bool

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) CloneMessageVT added in v0.1.4 

func (m *WatchResponse) CloneMessageVT() proto.Message

func (*WatchResponse) CloneVT added in v0.1.4 

func (m *WatchResponse) CloneVT() *WatchResponse

func (*WatchResponse) Descriptor deprecated 

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) EqualMessageVT added in v0.1.2 

func (this *WatchResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*WatchResponse) EqualVT added in v0.1.2 

func (this *WatchResponse) EqualVT(that *WatchResponse) bool

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

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.