egopb

type CommandReply struct {

	// the actual command reply
	//
	// Types that are assignable to Reply:
	//
	//	*CommandReply_StateReply
	//	*CommandReply_ErrorReply
	Reply isCommandReply_Reply `protobuf_oneof:"reply"`
	// contains filtered or unexported fields
}

type CommandReply_ErrorReply struct {
	// gRPC failure
	ErrorReply *ErrorReply `protobuf:"bytes,2,opt,name=error_reply,json=errorReply,proto3,oneof"`
}

type CommandReply_StateReply struct {
	// actual state is wrapped with metadata
	StateReply *StateReply `protobuf:"bytes,1,opt,name=state_reply,json=stateReply,proto3,oneof"`
}

type ErrorReply struct {

	// Specifies the error message
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type Event struct {

	// Specifies the persistence unique identifier
	PersistenceId string `protobuf:"bytes,1,opt,name=persistence_id,json=persistenceId,proto3" json:"persistence_id,omitempty"`
	// Specifies the sequence number
	SequenceNumber uint64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	// Specifies the deletion state
	IsDeleted bool `protobuf:"varint,3,opt,name=is_deleted,json=isDeleted,proto3" json:"is_deleted,omitempty"`
	// the event emitted
	Event *anypb.Any `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	// the state obtained from processing the event
	ResultingState *anypb.Any `protobuf:"bytes,5,opt,name=resulting_state,json=resultingState,proto3" json:"resulting_state,omitempty"`
	// Specifies the timestamp
	Timestamp int64 `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Specifies the shard number
	Shard uint64 `protobuf:"varint,7,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

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

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

type Offset struct {

	// Specifies the shard number
	ShardNumber uint64 `protobuf:"varint,1,opt,name=shard_number,json=shardNumber,proto3" json:"shard_number,omitempty"`
	// Specifies the projection name.
	ProjectionName string `protobuf:"bytes,2,opt,name=projection_name,json=projectionName,proto3" json:"projection_name,omitempty"`
	// Specifies the value
	Value int64 `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	// Specifies the timestamp
	Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type ProjectionId struct {

	// Specifies the projection name
	ProjectionName string `protobuf:"bytes,1,opt,name=projection_name,json=projectionName,proto3" json:"projection_name,omitempty"`
	// Specifies the shard number
	ShardNumber uint64 `protobuf:"varint,2,opt,name=shard_number,json=shardNumber,proto3" json:"shard_number,omitempty"`
	// contains filtered or unexported fields
}

type StateReply struct {

	// Specifies the persistence unique identifier
	PersistenceId string `protobuf:"bytes,1,opt,name=persistence_id,json=persistenceId,proto3" json:"persistence_id,omitempty"`
	// the entity state
	State *anypb.Any `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// Specifies the sequence number
	SequenceNumber uint64 `protobuf:"varint,3,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	// Specifies the timestamp
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}