chief_of_statev1

type ChiefOfStateServiceClient interface {
	// Used to process command sent by an application
	ProcessCommand(ctx context.Context, in *ProcessCommandRequest, opts ...grpc.CallOption) (*ProcessCommandResponse, error)
	// Used to get the current state of that entity
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
}

type ChiefOfStateServiceServer interface {
	// Used to process command sent by an application
	ProcessCommand(context.Context, *ProcessCommandRequest) (*ProcessCommandResponse, error)
	// Used to get the current state of that entity
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
}

type GetLatestOffsetByShardRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// the cluster shard number
	ClusterShardNumber uint64 `protobuf:"varint,2,opt,name=cluster_shard_number,json=clusterShardNumber,proto3" json:"cluster_shard_number,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestOffsetByShardResponse struct {
	Offsets *ReadSideOffset `protobuf:"bytes,1,opt,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestOffsetRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestOffsetResponse struct {

	// the list of offset
	Offsets []*ReadSideOffset `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

type GetStateRequest struct {
	EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// contains filtered or unexported fields
}

type GetStateResponse struct {

	// the current state of the entity
	State *anypb.Any `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// additional meta data
	Meta *MetaData `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type HandleCommandRequest struct {

	// the command to handle
	Command *anypb.Any `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// the aggregate state at the moment of handling the command. This is the
	// state before the command being handled.
	PriorState *anypb.Any `protobuf:"bytes,2,opt,name=prior_state,json=priorState,proto3" json:"prior_state,omitempty"`
	// the prior event meta data. This is the event meta data of the last event
	// before this command
	PriorEventMeta *MetaData `protobuf:"bytes,3,opt,name=prior_event_meta,json=priorEventMeta,proto3" json:"prior_event_meta,omitempty"`
	// contains filtered or unexported fields
}

type HandleCommandResponse struct {

	// An event to append to the journal. If not set, COS
	// will treat this command as a no-op.
	Event *anypb.Any `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type HandleEventRequest struct {

	// the event to handle
	Event *anypb.Any `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// the state before the event is being handled.
	PriorState *anypb.Any `protobuf:"bytes,2,opt,name=prior_state,json=priorState,proto3" json:"prior_state,omitempty"`
	// the meta data of this event
	EventMeta *MetaData `protobuf:"bytes,3,opt,name=event_meta,json=eventMeta,proto3" json:"event_meta,omitempty"`
	// contains filtered or unexported fields
}

type HandleEventResponse struct {

	// resulting state after the event has been handled
	ResultingState *anypb.Any `protobuf:"bytes,1,opt,name=resulting_state,json=resultingState,proto3" json:"resulting_state,omitempty"`
	// contains filtered or unexported fields
}

type HandleReadSideRequest struct {

	// the persisted event
	Event *anypb.Any `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// the resulting state associated to the persisted event
	State *anypb.Any `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// additional meta data
	Meta *MetaData `protobuf:"bytes,3,opt,name=meta,proto3" json:"meta,omitempty"`
	// the identifier of the read side service receiving the request
	ReadSideId string `protobuf:"bytes,4,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// contains filtered or unexported fields
}

type HandleReadSideResponse struct {

	// successful=true means the offset will be committed and the readside will
	// move on to process the next event. Otherwise, if successful=false, the
	// event will get reprocessed with a backoff strategy.
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type Header struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Value:
	//	*Header_StringValue
	//	*Header_BytesValue
	Value isHeader_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type Header_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,3,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Header_StringValue struct {
	StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type MetaData struct {
	EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// the revision number for the entity, increases sequentially
	// this is very useful to handle optimistic lock
	RevisionNumber uint32 `protobuf:"varint,2,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
	// the time the state has been modified
	RevisionDate *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=revision_date,json=revisionDate,proto3" json:"revision_date,omitempty"`
	// use to store additional data.
	Data map[string]*anypb.Any `` /* 149-byte string literal not displayed */
	// headers
	Headers []*Header `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

type PauseReadSideByShardRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// the cluster shard number
	ClusterShardNumber uint64 `protobuf:"varint,2,opt,name=cluster_shard_number,json=clusterShardNumber,proto3" json:"cluster_shard_number,omitempty"`
	// contains filtered or unexported fields
}

type PauseReadSideByShardResponse struct {

	// states whether the pause request was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type PauseReadSideRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// contains filtered or unexported fields
}

type PauseReadSideResponse struct {

	// states whether the pause request was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type ProcessCommandRequest struct {

	// the entity unique id
	EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// the command to process
	Command *anypb.Any `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type ProcessCommandResponse struct {

	// the entity state returned after the command has been processed
	State *anypb.Any `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// additional meta data
	Meta *MetaData `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type ReadSideHandlerServiceClient interface {
	// Helps build a read model from persisted events and snpahots
	HandleReadSide(ctx context.Context, in *HandleReadSideRequest, opts ...grpc.CallOption) (*HandleReadSideResponse, error)
}

type ReadSideHandlerServiceServer interface {
	// Helps build a read model from persisted events and snpahots
	HandleReadSide(context.Context, *HandleReadSideRequest) (*HandleReadSideResponse, error)
}

type ReadSideManagerServiceClient interface {
	// GetLatestOffset retrieves latest offset across all shards
	GetLatestOffset(ctx context.Context, in *GetLatestOffsetRequest, opts ...grpc.CallOption) (*GetLatestOffsetResponse, error)
	// GetLatestOffsetByShard retrieves the latest offset given a shard
	GetLatestOffsetByShard(ctx context.Context, in *GetLatestOffsetByShardRequest, opts ...grpc.CallOption) (*GetLatestOffsetByShardResponse, error)
	// RestartReadSide will clear the read side offset and start it over again
	// from the first offset and this across all shards
	RestartReadSide(ctx context.Context, in *RestartReadSideRequest, opts ...grpc.CallOption) (*RestartReadSideResponse, error)
	// RestartReadSideByShard will clear the read side offset for the given shard and start it over again from the first offset
	RestartReadSideByShard(ctx context.Context, in *RestartReadSideByShardRequest, opts ...grpc.CallOption) (*RestartReadSideByShardResponse, error)
	// PauseReadSide pauses a read side. This can be useful when running some data
	// migration and this across all shards
	PauseReadSide(ctx context.Context, in *PauseReadSideRequest, opts ...grpc.CallOption) (*PauseReadSideResponse, error)
	// PauseReadSide pauses a read side. This can be useful when running some data
	// migration and this for a given shard
	PauseReadSideByShard(ctx context.Context, in *PauseReadSideByShardRequest, opts ...grpc.CallOption) (*PauseReadSideByShardResponse, error)
	// ResumeReadSide resumes a paused read side and this across all shards
	ResumeReadSide(ctx context.Context, in *ResumeReadSideRequest, opts ...grpc.CallOption) (*ResumeReadSideResponse, error)
	// ResumeReadSideByShard  resumes a paused read side for a given shard
	ResumeReadSideByShard(ctx context.Context, in *ResumeReadSideByShardRequest, opts ...grpc.CallOption) (*ResumeReadSideByShardResponse, error)
	// SkippOffset skips the current offset to read across all shards and continue with next. The operation will automatically restart the read side.
	SkipOffset(ctx context.Context, in *SkipOffsetRequest, opts ...grpc.CallOption) (*SkipOffsetResponse, error)
	// SkippOffset skips the current offset to read for a given shard and continue with next. The operation will automatically restart the read side.
	SkipOffsetByShard(ctx context.Context, in *SkipOffsetByShardRequest, opts ...grpc.CallOption) (*SkipOffsetByShardResponse, error)
}

type ReadSideManagerServiceServer interface {
	// GetLatestOffset retrieves latest offset across all shards
	GetLatestOffset(context.Context, *GetLatestOffsetRequest) (*GetLatestOffsetResponse, error)
	// GetLatestOffsetByShard retrieves the latest offset given a shard
	GetLatestOffsetByShard(context.Context, *GetLatestOffsetByShardRequest) (*GetLatestOffsetByShardResponse, error)
	// RestartReadSide will clear the read side offset and start it over again
	// from the first offset and this across all shards
	RestartReadSide(context.Context, *RestartReadSideRequest) (*RestartReadSideResponse, error)
	// RestartReadSideByShard will clear the read side offset for the given shard and start it over again from the first offset
	RestartReadSideByShard(context.Context, *RestartReadSideByShardRequest) (*RestartReadSideByShardResponse, error)
	// PauseReadSide pauses a read side. This can be useful when running some data
	// migration and this across all shards
	PauseReadSide(context.Context, *PauseReadSideRequest) (*PauseReadSideResponse, error)
	// PauseReadSide pauses a read side. This can be useful when running some data
	// migration and this for a given shard
	PauseReadSideByShard(context.Context, *PauseReadSideByShardRequest) (*PauseReadSideByShardResponse, error)
	// ResumeReadSide resumes a paused read side and this across all shards
	ResumeReadSide(context.Context, *ResumeReadSideRequest) (*ResumeReadSideResponse, error)
	// ResumeReadSideByShard  resumes a paused read side for a given shard
	ResumeReadSideByShard(context.Context, *ResumeReadSideByShardRequest) (*ResumeReadSideByShardResponse, error)
	// SkippOffset skips the current offset to read across all shards and continue with next. The operation will automatically restart the read side.
	SkipOffset(context.Context, *SkipOffsetRequest) (*SkipOffsetResponse, error)
	// SkippOffset skips the current offset to read for a given shard and continue with next. The operation will automatically restart the read side.
	SkipOffsetByShard(context.Context, *SkipOffsetByShardRequest) (*SkipOffsetByShardResponse, error)
}

type ReadSideOffset struct {

	// the cluster shard number
	ClusterShardNumber uint64 `protobuf:"varint,1,opt,name=cluster_shard_number,json=clusterShardNumber,proto3" json:"cluster_shard_number,omitempty"`
	// the latest offset for the given read side id at the given
	// cluster shard
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type RestartReadSideByShardRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// the cluster shard number
	ClusterShardNumber uint64 `protobuf:"varint,2,opt,name=cluster_shard_number,json=clusterShardNumber,proto3" json:"cluster_shard_number,omitempty"`
	// contains filtered or unexported fields
}

type RestartReadSideByShardResponse struct {

	// states whether the restart was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type RestartReadSideRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// contains filtered or unexported fields
}

type RestartReadSideResponse struct {

	// states whether the restart was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type ResumeReadSideByShardRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// the cluster shard number
	ClusterShardNumber uint64 `protobuf:"varint,2,opt,name=cluster_shard_number,json=clusterShardNumber,proto3" json:"cluster_shard_number,omitempty"`
	// contains filtered or unexported fields
}

type ResumeReadSideByShardResponse struct {

	// states whether the pause request was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type ResumeReadSideRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// contains filtered or unexported fields
}

type ResumeReadSideResponse struct {

	// states whether the pause request was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type SkipOffsetByShardRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// the cluster shard number
	ClusterShardNumber uint64 `protobuf:"varint,2,opt,name=cluster_shard_number,json=clusterShardNumber,proto3" json:"cluster_shard_number,omitempty"`
	// contains filtered or unexported fields
}

type SkipOffsetByShardResponse struct {

	// states whether the pause request was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type SkipOffsetRequest struct {

	// the read side unique identifier
	ReadSideId string `protobuf:"bytes,1,opt,name=read_side_id,json=readSideId,proto3" json:"read_side_id,omitempty"`
	// contains filtered or unexported fields
}

type SkipOffsetResponse struct {

	// states whether the pause request was successful
	Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedChiefOfStateServiceServer struct {
}

type UnimplementedReadSideHandlerServiceServer struct {
}

type UnimplementedReadSideManagerServiceServer struct {
}

type UnimplementedWriteSideHandlerServiceServer struct {
}

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

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

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

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

type WriteSideHandlerServiceClient interface {
	// Processes every command sent by ChiefOfState and return either a response
	// containing an event to persist or a simple reply.
	HandleCommand(ctx context.Context, in *HandleCommandRequest, opts ...grpc.CallOption) (*HandleCommandResponse, error)
	// Processes every event sent by ChiefOfState by applying the event to the
	// current state to return a new state.
	HandleEvent(ctx context.Context, in *HandleEventRequest, opts ...grpc.CallOption) (*HandleEventResponse, error)
}

type WriteSideHandlerServiceServer interface {
	// Processes every command sent by ChiefOfState and return either a response
	// containing an event to persist or a simple reply.
	HandleCommand(context.Context, *HandleCommandRequest) (*HandleCommandResponse, error)
	// Processes every event sent by ChiefOfState by applying the event to the
	// current state to return a new state.
	HandleEvent(context.Context, *HandleEventRequest) (*HandleEventResponse, error)
}