egopb

package
v3.3.1 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2025 License: MIT Imports: 5 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_ego_v3_ego_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CommandReply 

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
}

CommandReply specifies the reply to a command sent to the aggregate

func (*CommandReply) Descriptor deprecated 

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

Deprecated: Use CommandReply.ProtoReflect.Descriptor instead.

func (*CommandReply) GetErrorReply 

func (x *CommandReply) GetErrorReply() *ErrorReply

func (*CommandReply) GetReply 

func (m *CommandReply) GetReply() isCommandReply_Reply

func (*CommandReply) GetStateReply 

func (x *CommandReply) GetStateReply() *StateReply

func (*CommandReply) ProtoMessage 

func (*CommandReply) ProtoMessage()

func (*CommandReply) ProtoReflect 

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

func (*CommandReply) Reset 

func (x *CommandReply) Reset()

func (*CommandReply) String 

func (x *CommandReply) String() string

type CommandReply_ErrorReply 

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

type CommandReply_StateReply 

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

type DurableState added in v3.2.0 

type DurableState struct {

	// Specifies the persistence unique identifier
	PersistenceId string `protobuf:"bytes,1,opt,name=persistence_id,json=persistenceId,proto3" json:"persistence_id,omitempty"`
	// Specifies the version number
	VersionNumber uint64 `protobuf:"varint,2,opt,name=version_number,json=versionNumber,proto3" json:"version_number,omitempty"`
	// the state obtained from processing a command
	ResultingState *anypb.Any `protobuf:"bytes,3,opt,name=resulting_state,json=resultingState,proto3" json:"resulting_state,omitempty"`
	// Specifies the timestamp
	Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Specifies the shard number
	Shard uint64 `protobuf:"varint,6,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

DurableState defines the durable state behavior actor

func (*DurableState) Descriptor deprecated added in v3.2.0 

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

Deprecated: Use DurableState.ProtoReflect.Descriptor instead.

func (*DurableState) GetPersistenceId added in v3.2.0 

func (x *DurableState) GetPersistenceId() string

func (*DurableState) GetResultingState added in v3.2.0 

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

func (*DurableState) GetShard added in v3.2.0 

func (x *DurableState) GetShard() uint64

func (*DurableState) GetTimestamp added in v3.2.0 

func (x *DurableState) GetTimestamp() int64

func (*DurableState) GetVersionNumber added in v3.2.0 

func (x *DurableState) GetVersionNumber() uint64

func (*DurableState) ProtoMessage added in v3.2.0 

func (*DurableState) ProtoMessage()

func (*DurableState) ProtoReflect added in v3.2.0 

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

func (*DurableState) Reset added in v3.2.0 

func (x *DurableState) Reset()

func (*DurableState) String added in v3.2.0 

func (x *DurableState) String() string

type ErrorReply 

type ErrorReply struct {

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

ErrorReply is used when a command processing has failed.

func (*ErrorReply) Descriptor deprecated 

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

Deprecated: Use ErrorReply.ProtoReflect.Descriptor instead.

func (*ErrorReply) GetMessage 

func (x *ErrorReply) GetMessage() string

func (*ErrorReply) ProtoMessage 

func (*ErrorReply) ProtoMessage()

func (*ErrorReply) ProtoReflect 

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

func (*ErrorReply) Reset 

func (x *ErrorReply) Reset()

func (*ErrorReply) String 

func (x *ErrorReply) String() string

type Event 

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
}

Event defines the event that needs to be persisted onto the events store

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEvent 

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

func (*Event) GetIsDeleted 

func (x *Event) GetIsDeleted() bool

func (*Event) GetPersistenceId 

func (x *Event) GetPersistenceId() string

func (*Event) GetResultingState 

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

func (*Event) GetSequenceNumber 

func (x *Event) GetSequenceNumber() uint64

func (*Event) GetShard 

func (x *Event) GetShard() uint64

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() int64

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type GetStateCommand 

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

GetStateCommand tells the Aggregate to reply with its latest state

func (*GetStateCommand) Descriptor deprecated 

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

Deprecated: Use GetStateCommand.ProtoReflect.Descriptor instead.

func (*GetStateCommand) ProtoMessage 

func (*GetStateCommand) ProtoMessage()

func (*GetStateCommand) ProtoReflect 

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

func (*GetStateCommand) Reset 

func (x *GetStateCommand) Reset()

func (*GetStateCommand) String 

func (x *GetStateCommand) String() string

type NoReply 

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

NoReply is used when a command does not need a reply

func (*NoReply) Descriptor deprecated 

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

Deprecated: Use NoReply.ProtoReflect.Descriptor instead.

func (*NoReply) ProtoMessage 

func (*NoReply) ProtoMessage()

func (*NoReply) ProtoReflect 

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

func (*NoReply) Reset 

func (x *NoReply) Reset()

func (*NoReply) String 

func (x *NoReply) String() string

type Offset 

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
}

Offset defines the projection offset

func (*Offset) Descriptor deprecated 

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

Deprecated: Use Offset.ProtoReflect.Descriptor instead.

func (*Offset) GetProjectionName 

func (x *Offset) GetProjectionName() string

func (*Offset) GetShardNumber 

func (x *Offset) GetShardNumber() uint64

func (*Offset) GetTimestamp 

func (x *Offset) GetTimestamp() int64

func (*Offset) GetValue 

func (x *Offset) GetValue() int64

func (*Offset) ProtoMessage 

func (*Offset) ProtoMessage()

func (*Offset) ProtoReflect 

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

func (*Offset) Reset 

func (x *Offset) Reset()

func (*Offset) String 

func (x *Offset) String() string

type ProjectionId 

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
}

ProjectionId defines the projection id

func (*ProjectionId) Descriptor deprecated 

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

Deprecated: Use ProjectionId.ProtoReflect.Descriptor instead.

func (*ProjectionId) GetProjectionName 

func (x *ProjectionId) GetProjectionName() string

func (*ProjectionId) GetShardNumber 

func (x *ProjectionId) GetShardNumber() uint64

func (*ProjectionId) ProtoMessage 

func (*ProjectionId) ProtoMessage()

func (*ProjectionId) ProtoReflect 

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

func (*ProjectionId) Reset 

func (x *ProjectionId) Reset()

func (*ProjectionId) String 

func (x *ProjectionId) String() string

type StateReply 

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
}

StateReply is a command reply. This is reply is used when there is a no-op

func (*StateReply) Descriptor deprecated 

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

Deprecated: Use StateReply.ProtoReflect.Descriptor instead.

func (*StateReply) GetPersistenceId 

func (x *StateReply) GetPersistenceId() string

func (*StateReply) GetSequenceNumber 

func (x *StateReply) GetSequenceNumber() uint64

func (*StateReply) GetState 

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

func (*StateReply) GetTimestamp 

func (x *StateReply) GetTimestamp() int64

func (*StateReply) ProtoMessage 

func (*StateReply) ProtoMessage()

func (*StateReply) ProtoReflect 

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

func (*StateReply) Reset 

func (x *StateReply) Reset()

func (*StateReply) String 

func (x *StateReply) String() string

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.