chief_of_statev1

package
v0.0.10 Latest Latest
Warning

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

 Go to latest Published: May 29, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ChiefOfStateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chief_of_state.v1.ChiefOfStateService",
	HandlerType: (*ChiefOfStateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProcessCommand",
			Handler:    _ChiefOfStateService_ProcessCommand_Handler,
		},
		{
			MethodName: "GetState",
			Handler:    _ChiefOfStateService_GetState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chief_of_state/v1/service.proto",
}

ChiefOfStateService_ServiceDesc is the grpc.ServiceDesc for ChiefOfStateService 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_chief_of_state_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_chief_of_state_v1_readside_manager_proto protoreflect.FileDescriptor
View Source 
var File_chief_of_state_v1_readside_proto protoreflect.FileDescriptor
View Source 
var File_chief_of_state_v1_service_proto protoreflect.FileDescriptor
View Source 
var File_chief_of_state_v1_writeside_proto protoreflect.FileDescriptor
View Source 
var ReadSideHandlerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chief_of_state.v1.ReadSideHandlerService",
	HandlerType: (*ReadSideHandlerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandleReadSide",
			Handler:    _ReadSideHandlerService_HandleReadSide_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chief_of_state/v1/readside.proto",
}

ReadSideHandlerService_ServiceDesc is the grpc.ServiceDesc for ReadSideHandlerService 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 ReadSideManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chief_of_state.v1.ReadSideManagerService",
	HandlerType: (*ReadSideManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLatestOffset",
			Handler:    _ReadSideManagerService_GetLatestOffset_Handler,
		},
		{
			MethodName: "GetLatestOffsetByShard",
			Handler:    _ReadSideManagerService_GetLatestOffsetByShard_Handler,
		},
		{
			MethodName: "RestartReadSide",
			Handler:    _ReadSideManagerService_RestartReadSide_Handler,
		},
		{
			MethodName: "RestartReadSideByShard",
			Handler:    _ReadSideManagerService_RestartReadSideByShard_Handler,
		},
		{
			MethodName: "PauseReadSide",
			Handler:    _ReadSideManagerService_PauseReadSide_Handler,
		},
		{
			MethodName: "PauseReadSideByShard",
			Handler:    _ReadSideManagerService_PauseReadSideByShard_Handler,
		},
		{
			MethodName: "ResumeReadSide",
			Handler:    _ReadSideManagerService_ResumeReadSide_Handler,
		},
		{
			MethodName: "ResumeReadSideByShard",
			Handler:    _ReadSideManagerService_ResumeReadSideByShard_Handler,
		},
		{
			MethodName: "SkipOffset",
			Handler:    _ReadSideManagerService_SkipOffset_Handler,
		},
		{
			MethodName: "SkipOffsetByShard",
			Handler:    _ReadSideManagerService_SkipOffsetByShard_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chief_of_state/v1/readside_manager.proto",
}

ReadSideManagerService_ServiceDesc is the grpc.ServiceDesc for ReadSideManagerService 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 WriteSideHandlerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chief_of_state.v1.WriteSideHandlerService",
	HandlerType: (*WriteSideHandlerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandleCommand",
			Handler:    _WriteSideHandlerService_HandleCommand_Handler,
		},
		{
			MethodName: "HandleEvent",
			Handler:    _WriteSideHandlerService_HandleEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chief_of_state/v1/writeside.proto",
}

WriteSideHandlerService_ServiceDesc is the grpc.ServiceDesc for WriteSideHandlerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterChiefOfStateServiceServer 

func RegisterChiefOfStateServiceServer(s grpc.ServiceRegistrar, srv ChiefOfStateServiceServer)

func RegisterReadSideHandlerServiceServer 

func RegisterReadSideHandlerServiceServer(s grpc.ServiceRegistrar, srv ReadSideHandlerServiceServer)

func RegisterReadSideManagerServiceServer 

func RegisterReadSideManagerServiceServer(s grpc.ServiceRegistrar, srv ReadSideManagerServiceServer)

func RegisterWriteSideHandlerServiceServer 

func RegisterWriteSideHandlerServiceServer(s grpc.ServiceRegistrar, srv WriteSideHandlerServiceServer)

Types

type ChiefOfStateServiceClient 

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

ChiefOfStateServiceClient is the client API for ChiefOfStateService 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 NewChiefOfStateServiceClient 

func NewChiefOfStateServiceClient(cc grpc.ClientConnInterface) ChiefOfStateServiceClient

type ChiefOfStateServiceServer 

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

ChiefOfStateServiceServer is the server API for ChiefOfStateService service. All implementations should embed UnimplementedChiefOfStateServiceServer for forward compatibility

type GetLatestOffsetByShardRequest 

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
}

func (*GetLatestOffsetByShardRequest) Descriptor deprecated 

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

Deprecated: Use GetLatestOffsetByShardRequest.ProtoReflect.Descriptor instead.

func (*GetLatestOffsetByShardRequest) GetClusterShardNumber 

func (x *GetLatestOffsetByShardRequest) GetClusterShardNumber() uint64

func (*GetLatestOffsetByShardRequest) GetReadSideId 

func (x *GetLatestOffsetByShardRequest) GetReadSideId() string

func (*GetLatestOffsetByShardRequest) ProtoMessage 

func (*GetLatestOffsetByShardRequest) ProtoMessage()

func (*GetLatestOffsetByShardRequest) ProtoReflect 

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

func (*GetLatestOffsetByShardRequest) Reset 

func (x *GetLatestOffsetByShardRequest) Reset()

func (*GetLatestOffsetByShardRequest) String 

func (x *GetLatestOffsetByShardRequest) String() string

type GetLatestOffsetByShardResponse 

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

func (*GetLatestOffsetByShardResponse) Descriptor deprecated 

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

Deprecated: Use GetLatestOffsetByShardResponse.ProtoReflect.Descriptor instead.

func (*GetLatestOffsetByShardResponse) GetOffsets 

func (x *GetLatestOffsetByShardResponse) GetOffsets() *ReadSideOffset

func (*GetLatestOffsetByShardResponse) ProtoMessage 

func (*GetLatestOffsetByShardResponse) ProtoMessage()

func (*GetLatestOffsetByShardResponse) ProtoReflect 

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

func (*GetLatestOffsetByShardResponse) Reset 

func (x *GetLatestOffsetByShardResponse) Reset()

func (*GetLatestOffsetByShardResponse) String 

func (x *GetLatestOffsetByShardResponse) String() string

type GetLatestOffsetRequest 

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
}

GetReadSideLatestOffsetRequest helps retrieve the latest offset of a readside

func (*GetLatestOffsetRequest) Descriptor deprecated 

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

Deprecated: Use GetLatestOffsetRequest.ProtoReflect.Descriptor instead.

func (*GetLatestOffsetRequest) GetReadSideId 

func (x *GetLatestOffsetRequest) GetReadSideId() string

func (*GetLatestOffsetRequest) ProtoMessage 

func (*GetLatestOffsetRequest) ProtoMessage()

func (*GetLatestOffsetRequest) ProtoReflect 

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

func (*GetLatestOffsetRequest) Reset 

func (x *GetLatestOffsetRequest) Reset()

func (*GetLatestOffsetRequest) String 

func (x *GetLatestOffsetRequest) String() string

type GetLatestOffsetResponse 

type GetLatestOffsetResponse struct {

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

GetReadSideLatestOffsetResponse

func (*GetLatestOffsetResponse) Descriptor deprecated 

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

Deprecated: Use GetLatestOffsetResponse.ProtoReflect.Descriptor instead.

func (*GetLatestOffsetResponse) GetOffsets 

func (x *GetLatestOffsetResponse) GetOffsets() []*ReadSideOffset

func (*GetLatestOffsetResponse) ProtoMessage 

func (*GetLatestOffsetResponse) ProtoMessage()

func (*GetLatestOffsetResponse) ProtoReflect 

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

func (*GetLatestOffsetResponse) Reset 

func (x *GetLatestOffsetResponse) Reset()

func (*GetLatestOffsetResponse) String 

func (x *GetLatestOffsetResponse) String() string

type GetStateRequest 

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

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) GetEntityId 

func (x *GetStateRequest) GetEntityId() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect 

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

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

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
}

func (*GetStateResponse) Descriptor deprecated 

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

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetMeta 

func (x *GetStateResponse) GetMeta() *MetaData

func (*GetStateResponse) GetState 

func (x *GetStateResponse) GetState() *anypb.Any

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect 

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

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type HandleCommandRequest 

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
}

HandleCommandRequest

func (*HandleCommandRequest) Descriptor deprecated 

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

Deprecated: Use HandleCommandRequest.ProtoReflect.Descriptor instead.

func (*HandleCommandRequest) GetCommand 

func (x *HandleCommandRequest) GetCommand() *anypb.Any

func (*HandleCommandRequest) GetPriorEventMeta 

func (x *HandleCommandRequest) GetPriorEventMeta() *MetaData

func (*HandleCommandRequest) GetPriorState 

func (x *HandleCommandRequest) GetPriorState() *anypb.Any

func (*HandleCommandRequest) ProtoMessage 

func (*HandleCommandRequest) ProtoMessage()

func (*HandleCommandRequest) ProtoReflect 

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

func (*HandleCommandRequest) Reset 

func (x *HandleCommandRequest) Reset()

func (*HandleCommandRequest) String 

func (x *HandleCommandRequest) String() string

type HandleCommandResponse 

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
}

HandleCommandResponse

func (*HandleCommandResponse) Descriptor deprecated 

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

Deprecated: Use HandleCommandResponse.ProtoReflect.Descriptor instead.

func (*HandleCommandResponse) GetEvent 

func (x *HandleCommandResponse) GetEvent() *anypb.Any

func (*HandleCommandResponse) ProtoMessage 

func (*HandleCommandResponse) ProtoMessage()

func (*HandleCommandResponse) ProtoReflect 

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

func (*HandleCommandResponse) Reset 

func (x *HandleCommandResponse) Reset()

func (*HandleCommandResponse) String 

func (x *HandleCommandResponse) String() string

type HandleEventRequest 

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
}

HandleEventRequest

func (*HandleEventRequest) Descriptor deprecated 

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

Deprecated: Use HandleEventRequest.ProtoReflect.Descriptor instead.

func (*HandleEventRequest) GetEvent 

func (x *HandleEventRequest) GetEvent() *anypb.Any

func (*HandleEventRequest) GetEventMeta 

func (x *HandleEventRequest) GetEventMeta() *MetaData

func (*HandleEventRequest) GetPriorState 

func (x *HandleEventRequest) GetPriorState() *anypb.Any

func (*HandleEventRequest) ProtoMessage 

func (*HandleEventRequest) ProtoMessage()

func (*HandleEventRequest) ProtoReflect 

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

func (*HandleEventRequest) Reset 

func (x *HandleEventRequest) Reset()

func (*HandleEventRequest) String 

func (x *HandleEventRequest) String() string

type HandleEventResponse 

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
}

HandleEventResponse contains the resulting state after the event has been handled

func (*HandleEventResponse) Descriptor deprecated 

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

Deprecated: Use HandleEventResponse.ProtoReflect.Descriptor instead.

func (*HandleEventResponse) GetResultingState 

func (x *HandleEventResponse) GetResultingState() *anypb.Any

func (*HandleEventResponse) ProtoMessage 

func (*HandleEventResponse) ProtoMessage()

func (*HandleEventResponse) ProtoReflect 

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

func (*HandleEventResponse) Reset 

func (x *HandleEventResponse) Reset()

func (*HandleEventResponse) String 

func (x *HandleEventResponse) String() string

type HandleReadSideRequest 

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
}

ReadSideRequest is used to push the ReadSideHandler events and state persisted in the journal and the snapshot

func (*HandleReadSideRequest) Descriptor deprecated 

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

Deprecated: Use HandleReadSideRequest.ProtoReflect.Descriptor instead.

func (*HandleReadSideRequest) GetEvent 

func (x *HandleReadSideRequest) GetEvent() *anypb.Any

func (*HandleReadSideRequest) GetMeta 

func (x *HandleReadSideRequest) GetMeta() *MetaData

func (*HandleReadSideRequest) GetReadSideId 

func (x *HandleReadSideRequest) GetReadSideId() string

func (*HandleReadSideRequest) GetState 

func (x *HandleReadSideRequest) GetState() *anypb.Any

func (*HandleReadSideRequest) ProtoMessage 

func (*HandleReadSideRequest) ProtoMessage()

func (*HandleReadSideRequest) ProtoReflect 

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

func (*HandleReadSideRequest) Reset 

func (x *HandleReadSideRequest) Reset()

func (*HandleReadSideRequest) String 

func (x *HandleReadSideRequest) String() string

type HandleReadSideResponse 

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
}

ReadSideResponse is used by ChiefOfState to either commit events read offset or not.

func (*HandleReadSideResponse) Descriptor deprecated 

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

Deprecated: Use HandleReadSideResponse.ProtoReflect.Descriptor instead.

func (*HandleReadSideResponse) GetSuccessful 

func (x *HandleReadSideResponse) GetSuccessful() bool

func (*HandleReadSideResponse) ProtoMessage 

func (*HandleReadSideResponse) ProtoMessage()

func (*HandleReadSideResponse) ProtoReflect 

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

func (*HandleReadSideResponse) Reset 

func (x *HandleReadSideResponse) Reset()

func (*HandleReadSideResponse) String 

func (x *HandleReadSideResponse) String() string
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
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetBytesValue 

func (x *Header) GetBytesValue() []byte

func (*Header) GetKey 

func (x *Header) GetKey() string

func (*Header) GetStringValue 

func (x *Header) GetStringValue() string

func (*Header) GetValue 

func (m *Header) GetValue() isHeader_Value

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type Header_BytesValue 

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

type Header_StringValue 

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

type MetaData 

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
}

func (*MetaData) Descriptor deprecated 

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

Deprecated: Use MetaData.ProtoReflect.Descriptor instead.

func (*MetaData) GetData 

func (x *MetaData) GetData() map[string]*anypb.Any

func (*MetaData) GetEntityId 

func (x *MetaData) GetEntityId() string

func (*MetaData) GetHeaders 

func (x *MetaData) GetHeaders() []*Header

func (*MetaData) GetRevisionDate 

func (x *MetaData) GetRevisionDate() *timestamppb.Timestamp

func (*MetaData) GetRevisionNumber 

func (x *MetaData) GetRevisionNumber() uint32

func (*MetaData) ProtoMessage 

func (*MetaData) ProtoMessage()

func (*MetaData) ProtoReflect 

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

func (*MetaData) Reset 

func (x *MetaData) Reset()

func (*MetaData) String 

func (x *MetaData) String() string

type PauseReadSideByShardRequest 

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
}

func (*PauseReadSideByShardRequest) Descriptor deprecated 

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

Deprecated: Use PauseReadSideByShardRequest.ProtoReflect.Descriptor instead.

func (*PauseReadSideByShardRequest) GetClusterShardNumber 

func (x *PauseReadSideByShardRequest) GetClusterShardNumber() uint64

func (*PauseReadSideByShardRequest) GetReadSideId 

func (x *PauseReadSideByShardRequest) GetReadSideId() string

func (*PauseReadSideByShardRequest) ProtoMessage 

func (*PauseReadSideByShardRequest) ProtoMessage()

func (*PauseReadSideByShardRequest) ProtoReflect 

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

func (*PauseReadSideByShardRequest) Reset 

func (x *PauseReadSideByShardRequest) Reset()

func (*PauseReadSideByShardRequest) String 

func (x *PauseReadSideByShardRequest) String() string

type PauseReadSideByShardResponse 

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
}

func (*PauseReadSideByShardResponse) Descriptor deprecated 

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

Deprecated: Use PauseReadSideByShardResponse.ProtoReflect.Descriptor instead.

func (*PauseReadSideByShardResponse) GetSuccessful 

func (x *PauseReadSideByShardResponse) GetSuccessful() bool

func (*PauseReadSideByShardResponse) ProtoMessage 

func (*PauseReadSideByShardResponse) ProtoMessage()

func (*PauseReadSideByShardResponse) ProtoReflect 

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

func (*PauseReadSideByShardResponse) Reset 

func (x *PauseReadSideByShardResponse) Reset()

func (*PauseReadSideByShardResponse) String 

func (x *PauseReadSideByShardResponse) String() string

type PauseReadSideRequest 

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
}

func (*PauseReadSideRequest) Descriptor deprecated 

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

Deprecated: Use PauseReadSideRequest.ProtoReflect.Descriptor instead.

func (*PauseReadSideRequest) GetReadSideId 

func (x *PauseReadSideRequest) GetReadSideId() string

func (*PauseReadSideRequest) ProtoMessage 

func (*PauseReadSideRequest) ProtoMessage()

func (*PauseReadSideRequest) ProtoReflect 

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

func (*PauseReadSideRequest) Reset 

func (x *PauseReadSideRequest) Reset()

func (*PauseReadSideRequest) String 

func (x *PauseReadSideRequest) String() string

type PauseReadSideResponse 

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
}

func (*PauseReadSideResponse) Descriptor deprecated 

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

Deprecated: Use PauseReadSideResponse.ProtoReflect.Descriptor instead.

func (*PauseReadSideResponse) GetSuccessful 

func (x *PauseReadSideResponse) GetSuccessful() bool

func (*PauseReadSideResponse) ProtoMessage 

func (*PauseReadSideResponse) ProtoMessage()

func (*PauseReadSideResponse) ProtoReflect 

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

func (*PauseReadSideResponse) Reset 

func (x *PauseReadSideResponse) Reset()

func (*PauseReadSideResponse) String 

func (x *PauseReadSideResponse) String() string

type ProcessCommandRequest 

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
}

ProcessCommandRequest

func (*ProcessCommandRequest) Descriptor deprecated 

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

Deprecated: Use ProcessCommandRequest.ProtoReflect.Descriptor instead.

func (*ProcessCommandRequest) GetCommand 

func (x *ProcessCommandRequest) GetCommand() *anypb.Any

func (*ProcessCommandRequest) GetEntityId 

func (x *ProcessCommandRequest) GetEntityId() string

func (*ProcessCommandRequest) ProtoMessage 

func (*ProcessCommandRequest) ProtoMessage()

func (*ProcessCommandRequest) ProtoReflect 

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

func (*ProcessCommandRequest) Reset 

func (x *ProcessCommandRequest) Reset()

func (*ProcessCommandRequest) String 

func (x *ProcessCommandRequest) String() string

type ProcessCommandResponse 

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
}

ProcessCommandResponse

func (*ProcessCommandResponse) Descriptor deprecated 

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

Deprecated: Use ProcessCommandResponse.ProtoReflect.Descriptor instead.

func (*ProcessCommandResponse) GetMeta 

func (x *ProcessCommandResponse) GetMeta() *MetaData

func (*ProcessCommandResponse) GetState 

func (x *ProcessCommandResponse) GetState() *anypb.Any

func (*ProcessCommandResponse) ProtoMessage 

func (*ProcessCommandResponse) ProtoMessage()

func (*ProcessCommandResponse) ProtoReflect 

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

func (*ProcessCommandResponse) Reset 

func (x *ProcessCommandResponse) Reset()

func (*ProcessCommandResponse) String 

func (x *ProcessCommandResponse) String() string

type ReadSideHandlerServiceClient 

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

ReadSideHandlerServiceClient is the client API for ReadSideHandlerService 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 NewReadSideHandlerServiceClient 

func NewReadSideHandlerServiceClient(cc grpc.ClientConnInterface) ReadSideHandlerServiceClient

type ReadSideHandlerServiceServer 

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

ReadSideHandlerServiceServer is the server API for ReadSideHandlerService service. All implementations should embed UnimplementedReadSideHandlerServiceServer for forward compatibility

type ReadSideManagerServiceClient 

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

ReadSideManagerServiceClient is the client API for ReadSideManagerService 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 NewReadSideManagerServiceClient 

func NewReadSideManagerServiceClient(cc grpc.ClientConnInterface) ReadSideManagerServiceClient

type ReadSideManagerServiceServer 

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

ReadSideManagerServiceServer is the server API for ReadSideManagerService service. All implementations should embed UnimplementedReadSideManagerServiceServer for forward compatibility

type ReadSideOffset 

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
}

func (*ReadSideOffset) Descriptor deprecated 

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

Deprecated: Use ReadSideOffset.ProtoReflect.Descriptor instead.

func (*ReadSideOffset) GetClusterShardNumber 

func (x *ReadSideOffset) GetClusterShardNumber() uint64

func (*ReadSideOffset) GetOffset 

func (x *ReadSideOffset) GetOffset() uint64

func (*ReadSideOffset) ProtoMessage 

func (*ReadSideOffset) ProtoMessage()

func (*ReadSideOffset) ProtoReflect 

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

func (*ReadSideOffset) Reset 

func (x *ReadSideOffset) Reset()

func (*ReadSideOffset) String 

func (x *ReadSideOffset) String() string

type RestartReadSideByShardRequest 

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
}

func (*RestartReadSideByShardRequest) Descriptor deprecated 

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

Deprecated: Use RestartReadSideByShardRequest.ProtoReflect.Descriptor instead.

func (*RestartReadSideByShardRequest) GetClusterShardNumber 

func (x *RestartReadSideByShardRequest) GetClusterShardNumber() uint64

func (*RestartReadSideByShardRequest) GetReadSideId 

func (x *RestartReadSideByShardRequest) GetReadSideId() string

func (*RestartReadSideByShardRequest) ProtoMessage 

func (*RestartReadSideByShardRequest) ProtoMessage()

func (*RestartReadSideByShardRequest) ProtoReflect 

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

func (*RestartReadSideByShardRequest) Reset 

func (x *RestartReadSideByShardRequest) Reset()

func (*RestartReadSideByShardRequest) String 

func (x *RestartReadSideByShardRequest) String() string

type RestartReadSideByShardResponse 

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
}

func (*RestartReadSideByShardResponse) Descriptor deprecated 

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

Deprecated: Use RestartReadSideByShardResponse.ProtoReflect.Descriptor instead.

func (*RestartReadSideByShardResponse) GetSuccessful 

func (x *RestartReadSideByShardResponse) GetSuccessful() bool

func (*RestartReadSideByShardResponse) ProtoMessage 

func (*RestartReadSideByShardResponse) ProtoMessage()

func (*RestartReadSideByShardResponse) ProtoReflect 

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

func (*RestartReadSideByShardResponse) Reset 

func (x *RestartReadSideByShardResponse) Reset()

func (*RestartReadSideByShardResponse) String 

func (x *RestartReadSideByShardResponse) String() string

type RestartReadSideRequest 

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
}

func (*RestartReadSideRequest) Descriptor deprecated 

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

Deprecated: Use RestartReadSideRequest.ProtoReflect.Descriptor instead.

func (*RestartReadSideRequest) GetReadSideId 

func (x *RestartReadSideRequest) GetReadSideId() string

func (*RestartReadSideRequest) ProtoMessage 

func (*RestartReadSideRequest) ProtoMessage()

func (*RestartReadSideRequest) ProtoReflect 

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

func (*RestartReadSideRequest) Reset 

func (x *RestartReadSideRequest) Reset()

func (*RestartReadSideRequest) String 

func (x *RestartReadSideRequest) String() string

type RestartReadSideResponse 

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
}

func (*RestartReadSideResponse) Descriptor deprecated 

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

Deprecated: Use RestartReadSideResponse.ProtoReflect.Descriptor instead.

func (*RestartReadSideResponse) GetSuccessful 

func (x *RestartReadSideResponse) GetSuccessful() bool

func (*RestartReadSideResponse) ProtoMessage 

func (*RestartReadSideResponse) ProtoMessage()

func (*RestartReadSideResponse) ProtoReflect 

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

func (*RestartReadSideResponse) Reset 

func (x *RestartReadSideResponse) Reset()

func (*RestartReadSideResponse) String 

func (x *RestartReadSideResponse) String() string

type ResumeReadSideByShardRequest 

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
}

func (*ResumeReadSideByShardRequest) Descriptor deprecated 

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

Deprecated: Use ResumeReadSideByShardRequest.ProtoReflect.Descriptor instead.

func (*ResumeReadSideByShardRequest) GetClusterShardNumber 

func (x *ResumeReadSideByShardRequest) GetClusterShardNumber() uint64

func (*ResumeReadSideByShardRequest) GetReadSideId 

func (x *ResumeReadSideByShardRequest) GetReadSideId() string

func (*ResumeReadSideByShardRequest) ProtoMessage 

func (*ResumeReadSideByShardRequest) ProtoMessage()

func (*ResumeReadSideByShardRequest) ProtoReflect 

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

func (*ResumeReadSideByShardRequest) Reset 

func (x *ResumeReadSideByShardRequest) Reset()

func (*ResumeReadSideByShardRequest) String 

func (x *ResumeReadSideByShardRequest) String() string

type ResumeReadSideByShardResponse 

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
}

func (*ResumeReadSideByShardResponse) Descriptor deprecated 

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

Deprecated: Use ResumeReadSideByShardResponse.ProtoReflect.Descriptor instead.

func (*ResumeReadSideByShardResponse) GetSuccessful 

func (x *ResumeReadSideByShardResponse) GetSuccessful() bool

func (*ResumeReadSideByShardResponse) ProtoMessage 

func (*ResumeReadSideByShardResponse) ProtoMessage()

func (*ResumeReadSideByShardResponse) ProtoReflect 

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

func (*ResumeReadSideByShardResponse) Reset 

func (x *ResumeReadSideByShardResponse) Reset()

func (*ResumeReadSideByShardResponse) String 

func (x *ResumeReadSideByShardResponse) String() string

type ResumeReadSideRequest 

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
}

func (*ResumeReadSideRequest) Descriptor deprecated 

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

Deprecated: Use ResumeReadSideRequest.ProtoReflect.Descriptor instead.

func (*ResumeReadSideRequest) GetReadSideId 

func (x *ResumeReadSideRequest) GetReadSideId() string

func (*ResumeReadSideRequest) ProtoMessage 

func (*ResumeReadSideRequest) ProtoMessage()

func (*ResumeReadSideRequest) ProtoReflect 

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

func (*ResumeReadSideRequest) Reset 

func (x *ResumeReadSideRequest) Reset()

func (*ResumeReadSideRequest) String 

func (x *ResumeReadSideRequest) String() string

type ResumeReadSideResponse 

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
}

func (*ResumeReadSideResponse) Descriptor deprecated 

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

Deprecated: Use ResumeReadSideResponse.ProtoReflect.Descriptor instead.

func (*ResumeReadSideResponse) GetSuccessful 

func (x *ResumeReadSideResponse) GetSuccessful() bool

func (*ResumeReadSideResponse) ProtoMessage 

func (*ResumeReadSideResponse) ProtoMessage()

func (*ResumeReadSideResponse) ProtoReflect 

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

func (*ResumeReadSideResponse) Reset 

func (x *ResumeReadSideResponse) Reset()

func (*ResumeReadSideResponse) String 

func (x *ResumeReadSideResponse) String() string

type SkipOffsetByShardRequest 

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
}

func (*SkipOffsetByShardRequest) Descriptor deprecated 

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

Deprecated: Use SkipOffsetByShardRequest.ProtoReflect.Descriptor instead.

func (*SkipOffsetByShardRequest) GetClusterShardNumber 

func (x *SkipOffsetByShardRequest) GetClusterShardNumber() uint64

func (*SkipOffsetByShardRequest) GetReadSideId 

func (x *SkipOffsetByShardRequest) GetReadSideId() string

func (*SkipOffsetByShardRequest) ProtoMessage 

func (*SkipOffsetByShardRequest) ProtoMessage()

func (*SkipOffsetByShardRequest) ProtoReflect 

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

func (*SkipOffsetByShardRequest) Reset 

func (x *SkipOffsetByShardRequest) Reset()

func (*SkipOffsetByShardRequest) String 

func (x *SkipOffsetByShardRequest) String() string

type SkipOffsetByShardResponse 

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
}

func (*SkipOffsetByShardResponse) Descriptor deprecated 

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

Deprecated: Use SkipOffsetByShardResponse.ProtoReflect.Descriptor instead.

func (*SkipOffsetByShardResponse) GetSuccessful 

func (x *SkipOffsetByShardResponse) GetSuccessful() bool

func (*SkipOffsetByShardResponse) ProtoMessage 

func (*SkipOffsetByShardResponse) ProtoMessage()

func (*SkipOffsetByShardResponse) ProtoReflect 

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

func (*SkipOffsetByShardResponse) Reset 

func (x *SkipOffsetByShardResponse) Reset()

func (*SkipOffsetByShardResponse) String 

func (x *SkipOffsetByShardResponse) String() string

type SkipOffsetRequest 

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
}

func (*SkipOffsetRequest) Descriptor deprecated 

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

Deprecated: Use SkipOffsetRequest.ProtoReflect.Descriptor instead.

func (*SkipOffsetRequest) GetReadSideId 

func (x *SkipOffsetRequest) GetReadSideId() string

func (*SkipOffsetRequest) ProtoMessage 

func (*SkipOffsetRequest) ProtoMessage()

func (*SkipOffsetRequest) ProtoReflect 

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

func (*SkipOffsetRequest) Reset 

func (x *SkipOffsetRequest) Reset()

func (*SkipOffsetRequest) String 

func (x *SkipOffsetRequest) String() string

type SkipOffsetResponse 

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
}

func (*SkipOffsetResponse) Descriptor deprecated 

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

Deprecated: Use SkipOffsetResponse.ProtoReflect.Descriptor instead.

func (*SkipOffsetResponse) GetSuccessful 

func (x *SkipOffsetResponse) GetSuccessful() bool

func (*SkipOffsetResponse) ProtoMessage 

func (*SkipOffsetResponse) ProtoMessage()

func (*SkipOffsetResponse) ProtoReflect 

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

func (*SkipOffsetResponse) Reset 

func (x *SkipOffsetResponse) Reset()

func (*SkipOffsetResponse) String 

func (x *SkipOffsetResponse) String() string

type UnimplementedChiefOfStateServiceServer 

type UnimplementedChiefOfStateServiceServer struct {
}

UnimplementedChiefOfStateServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedChiefOfStateServiceServer) GetState 

func (UnimplementedChiefOfStateServiceServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)

func (UnimplementedChiefOfStateServiceServer) ProcessCommand 

func (UnimplementedChiefOfStateServiceServer) ProcessCommand(context.Context, *ProcessCommandRequest) (*ProcessCommandResponse, error)

type UnimplementedReadSideHandlerServiceServer 

type UnimplementedReadSideHandlerServiceServer struct {
}

UnimplementedReadSideHandlerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedReadSideHandlerServiceServer) HandleReadSide 

func (UnimplementedReadSideHandlerServiceServer) HandleReadSide(context.Context, *HandleReadSideRequest) (*HandleReadSideResponse, error)

type UnimplementedReadSideManagerServiceServer 

type UnimplementedReadSideManagerServiceServer struct {
}

UnimplementedReadSideManagerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedReadSideManagerServiceServer) GetLatestOffset 

func (UnimplementedReadSideManagerServiceServer) GetLatestOffset(context.Context, *GetLatestOffsetRequest) (*GetLatestOffsetResponse, error)

func (UnimplementedReadSideManagerServiceServer) GetLatestOffsetByShard 

func (UnimplementedReadSideManagerServiceServer) GetLatestOffsetByShard(context.Context, *GetLatestOffsetByShardRequest) (*GetLatestOffsetByShardResponse, error)

func (UnimplementedReadSideManagerServiceServer) PauseReadSide 

func (UnimplementedReadSideManagerServiceServer) PauseReadSide(context.Context, *PauseReadSideRequest) (*PauseReadSideResponse, error)

func (UnimplementedReadSideManagerServiceServer) PauseReadSideByShard 

func (UnimplementedReadSideManagerServiceServer) PauseReadSideByShard(context.Context, *PauseReadSideByShardRequest) (*PauseReadSideByShardResponse, error)

func (UnimplementedReadSideManagerServiceServer) RestartReadSide 

func (UnimplementedReadSideManagerServiceServer) RestartReadSide(context.Context, *RestartReadSideRequest) (*RestartReadSideResponse, error)

func (UnimplementedReadSideManagerServiceServer) RestartReadSideByShard 

func (UnimplementedReadSideManagerServiceServer) RestartReadSideByShard(context.Context, *RestartReadSideByShardRequest) (*RestartReadSideByShardResponse, error)

func (UnimplementedReadSideManagerServiceServer) ResumeReadSide 

func (UnimplementedReadSideManagerServiceServer) ResumeReadSide(context.Context, *ResumeReadSideRequest) (*ResumeReadSideResponse, error)

func (UnimplementedReadSideManagerServiceServer) ResumeReadSideByShard 

func (UnimplementedReadSideManagerServiceServer) ResumeReadSideByShard(context.Context, *ResumeReadSideByShardRequest) (*ResumeReadSideByShardResponse, error)

func (UnimplementedReadSideManagerServiceServer) SkipOffset 

func (UnimplementedReadSideManagerServiceServer) SkipOffset(context.Context, *SkipOffsetRequest) (*SkipOffsetResponse, error)

func (UnimplementedReadSideManagerServiceServer) SkipOffsetByShard 

func (UnimplementedReadSideManagerServiceServer) SkipOffsetByShard(context.Context, *SkipOffsetByShardRequest) (*SkipOffsetByShardResponse, error)

type UnimplementedWriteSideHandlerServiceServer 

type UnimplementedWriteSideHandlerServiceServer struct {
}

UnimplementedWriteSideHandlerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedWriteSideHandlerServiceServer) HandleCommand 

func (UnimplementedWriteSideHandlerServiceServer) HandleCommand(context.Context, *HandleCommandRequest) (*HandleCommandResponse, error)

func (UnimplementedWriteSideHandlerServiceServer) HandleEvent 

func (UnimplementedWriteSideHandlerServiceServer) HandleEvent(context.Context, *HandleEventRequest) (*HandleEventResponse, error)

type UnsafeChiefOfStateServiceServer 

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

UnsafeChiefOfStateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChiefOfStateServiceServer will result in compilation errors.

type UnsafeReadSideHandlerServiceServer 

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

UnsafeReadSideHandlerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReadSideHandlerServiceServer will result in compilation errors.

type UnsafeReadSideManagerServiceServer 

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

UnsafeReadSideManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReadSideManagerServiceServer will result in compilation errors.

type UnsafeWriteSideHandlerServiceServer 

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

UnsafeWriteSideHandlerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WriteSideHandlerServiceServer will result in compilation errors.

type WriteSideHandlerServiceClient 

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

WriteSideHandlerServiceClient is the client API for WriteSideHandlerService 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 NewWriteSideHandlerServiceClient 

func NewWriteSideHandlerServiceClient(cc grpc.ClientConnInterface) WriteSideHandlerServiceClient

type WriteSideHandlerServiceServer 

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

WriteSideHandlerServiceServer is the server API for WriteSideHandlerService service. All implementations should embed UnimplementedWriteSideHandlerServiceServer for forward compatibility

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.