protos

type AddShardsRequest struct {
	Shards []*Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

type ClientControlMessage struct {

	// Types that are assignable to Details:
	//	*ClientControlMessage_ShardUpdated
	Details isClientControlMessage_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

type ClientControlMessage_ShardUpdated struct {
	ShardUpdated *ShardsUpdatedRequest `protobuf:"bytes,1,opt,name=shard_updated,json=shardUpdated,proto3,oneof"`
}

type ClientControlRequest struct {

	// Types that are assignable to Details:
	//	*ClientControlRequest_SubscribeRequest
	//	*ClientControlRequest_UnsubscribeRequest
	Details isClientControlRequest_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

type ClientControlRequest_SubscribeRequest struct {
	SubscribeRequest *SubscribeRequest `protobuf:"bytes,2,opt,name=subscribe_request,json=subscribeRequest,proto3,oneof"`
}

type ClientControlRequest_UnsubscribeRequest struct {
	UnsubscribeRequest *UnsubscribeRequest `protobuf:"bytes,3,opt,name=unsubscribe_request,json=unsubscribeRequest,proto3,oneof"`
}

type ControlServiceClient interface {
	//*
	// Get the source of truth/current snapshot of assignments of a shard key
	// to a set of handler addresses
	GetShard(ctx context.Context, in *GetShardRequest, opts ...grpc.CallOption) (*GetShardResponse, error)
	//*
	// Called by what ever is interested in notifying the controller of
	// updates to membership.
	SaveShard(ctx context.Context, in *SaveShardRequest, opts ...grpc.CallOption) (*SaveShardResponse, error)
	//*
	// Called by admin to delete a shard completely or particular targets for it
	DeleteShard(ctx context.Context, in *DeleteShardRequest, opts ...grpc.CallOption) (*DeleteShardResponse, error)
	//*
	// Returns information about a host as to which shards it (manually) hosts.
	GetTargets(ctx context.Context, in *GetTargetsRequest, opts ...grpc.CallOption) (*GetTargetsResponse, error)
	//*
	// Called to ping a target's health status
	PingTarget(ctx context.Context, in *PingTargetRequest, opts ...grpc.CallOption) (*Target, error)
	//*
	// Called to update a target (most likely its status).
	SaveTarget(ctx context.Context, in *SaveTargetRequest, opts ...grpc.CallOption) (*Target, error)
	//*
	// Deletes/Removes a target - should also remove all associated shards.
	DeleteTargets(ctx context.Context, in *DeleteTargetsRequest, opts ...grpc.CallOption) (*DeleteTargetsResponse, error)
	//*
	// Return all hosts participating in this cluster.
	ListTargets(ctx context.Context, in *ListTargetsRequest, opts ...grpc.CallOption) (*ListTargetsResponse, error)
	//*
	// Called by clients interested in being notified about shard assignment updates.
	ConnectClient(ctx context.Context, opts ...grpc.CallOption) (ControlService_ConnectClientClient, error)
	//*
	// Called by shard targets/hosts/producers that host the dataplane for a shard and can be
	// commanded to shard assignment requests.
	ConnectTarget(ctx context.Context, opts ...grpc.CallOption) (ControlService_ConnectTargetClient, error)
}

type ControlServiceServer interface {
	//*
	// Get the source of truth/current snapshot of assignments of a shard key
	// to a set of handler addresses
	GetShard(context.Context, *GetShardRequest) (*GetShardResponse, error)
	//*
	// Called by what ever is interested in notifying the controller of
	// updates to membership.
	SaveShard(context.Context, *SaveShardRequest) (*SaveShardResponse, error)
	//*
	// Called by admin to delete a shard completely or particular targets for it
	DeleteShard(context.Context, *DeleteShardRequest) (*DeleteShardResponse, error)
	//*
	// Returns information about a host as to which shards it (manually) hosts.
	GetTargets(context.Context, *GetTargetsRequest) (*GetTargetsResponse, error)
	//*
	// Called to ping a target's health status
	PingTarget(context.Context, *PingTargetRequest) (*Target, error)
	//*
	// Called to update a target (most likely its status).
	SaveTarget(context.Context, *SaveTargetRequest) (*Target, error)
	//*
	// Deletes/Removes a target - should also remove all associated shards.
	DeleteTargets(context.Context, *DeleteTargetsRequest) (*DeleteTargetsResponse, error)
	//*
	// Return all hosts participating in this cluster.
	ListTargets(context.Context, *ListTargetsRequest) (*ListTargetsResponse, error)
	//*
	// Called by clients interested in being notified about shard assignment updates.
	ConnectClient(ControlService_ConnectClientServer) error
	//*
	// Called by shard targets/hosts/producers that host the dataplane for a shard and can be
	// commanded to shard assignment requests.
	ConnectTarget(ControlService_ConnectTargetServer) error
	// contains filtered or unexported methods
}

type ControlService_ConnectClientClient interface {
	Send(*ClientControlRequest) error
	Recv() (*ClientControlMessage, error)
	grpc.ClientStream
}

type ControlService_ConnectClientServer interface {
	Send(*ClientControlMessage) error
	Recv() (*ClientControlRequest, error)
	grpc.ServerStream
}

type ControlService_ConnectTargetClient interface {
	Send(*TargetControlRequest) error
	Recv() (*TargetControlMessage, error)
	grpc.ClientStream
}

type ControlService_ConnectTargetServer interface {
	Send(*TargetControlMessage) error
	Recv() (*TargetControlRequest, error)
	grpc.ServerStream
}

type DeleteShardRequest struct {
	Key       *ShardKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Addresses []string  `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteTargetsRequest struct {
	Addresses []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

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

type GetShardRequest struct {
	Shard *ShardKey `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

type GetShardResponse struct {
	Key        *ShardKey          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Targets    []*ShardTarget     `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"`
	TargetInfo map[string]*Target `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetTargetsRequest struct {
	Address       []string `protobuf:"bytes,1,rep,name=address,proto3" json:"address,omitempty"`
	IncludeShards bool     `protobuf:"varint,2,opt,name=include_shards,json=includeShards,proto3" json:"include_shards,omitempty"`
	// contains filtered or unexported fields
}

type GetTargetsResponse struct {
	Targets []*Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

type ListTargetsRequest struct {
	IncludeShards bool `protobuf:"varint,1,opt,name=include_shards,json=includeShards,proto3" json:"include_shards,omitempty"`
	// contains filtered or unexported fields
}

type ListTargetsResponse struct {
	Hosts []*Target `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

type PingTargetRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type RemoveShardsRequest struct {
	Shards []*Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

type SaveShardRequest struct {
	Key       *ShardKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Added     []string  `protobuf:"bytes,2,rep,name=added,proto3" json:"added,omitempty"`
	Removed   []string  `protobuf:"bytes,3,rep,name=removed,proto3" json:"removed,omitempty"`
	RemoveAll bool      `protobuf:"varint,4,opt,name=remove_all,json=removeAll,proto3" json:"remove_all,omitempty"`
	// contains filtered or unexported fields
}

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

type SaveTargetRequest struct {
	Target     *Target                `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

type Shard struct {
	Key     *ShardKey      `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Targets []*ShardTarget `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

type ShardKey struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type ShardState int32

type ShardTarget struct {
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Target    string                 `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	Status    string                 `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ShardsUpdatedRequest struct {
	OldStates map[string]ShardState `` /* 200-byte string literal not displayed */
	NewStates map[string]ShardState `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SubscribeRequest struct {
	Shards []*Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

type Target struct {
	Address   string                 `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Status    string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	PingedAt  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=pinged_at,json=pingedAt,proto3" json:"pinged_at,omitempty"`
	Tags      []string               `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	Shards    []*ShardKey            `protobuf:"bytes,6,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

type TargetControlMessage struct {

	// Types that are assignable to Details:
	//	*TargetControlMessage_AddShardsRequest
	//	*TargetControlMessage_RemoveShardsRequest
	Details isTargetControlMessage_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

type TargetControlMessage_AddShardsRequest struct {
	AddShardsRequest *AddShardsRequest `protobuf:"bytes,2,opt,name=add_shards_request,json=addShardsRequest,proto3,oneof"`
}

type TargetControlMessage_RemoveShardsRequest struct {
	RemoveShardsRequest *RemoveShardsRequest `protobuf:"bytes,3,opt,name=remove_shards_request,json=removeShardsRequest,proto3,oneof"`
}

type TargetControlRequest struct {

	// Types that are assignable to Details:
	//	*TargetControlRequest_ShardUpdated
	Details isTargetControlRequest_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

type TargetControlRequest_ShardUpdated struct {
	ShardUpdated *ShardsUpdatedRequest `protobuf:"bytes,1,opt,name=shard_updated,json=shardUpdated,proto3,oneof"`
}

type UnimplementedControlServiceServer struct {
}

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

type UnsubscribeRequest struct {
	Shards []*Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}