pb

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
}

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
}

type AffiliateDeleteResponse struct {
	// contains filtered or unexported fields
}

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
}

type AffiliateUpdateResponse struct {
	// contains filtered or unexported fields
}

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)
}

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
}

type Cluster_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type Cluster_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

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
}

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
}

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
}

type ListResponse struct {

	// List of cluster affiliates.
	Affiliates []*Affiliate `protobuf:"bytes,1,rep,name=affiliates,proto3" json:"affiliates,omitempty"`
	// contains filtered or unexported fields
}

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
}

type UnimplementedClusterServer struct {
}

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

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
}

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
}