egopb

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_ego_v1_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 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 added in v1.1.0 

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 added in v1.1.0 

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

Deprecated: Use Offset.ProtoReflect.Descriptor instead.

func (*Offset) GetProjectionName added in v1.1.0 

func (x *Offset) GetProjectionName() string

func (*Offset) GetShardNumber added in v1.1.0 

func (x *Offset) GetShardNumber() uint64

func (*Offset) GetTimestamp added in v1.1.0 

func (x *Offset) GetTimestamp() int64

func (*Offset) GetValue added in v1.1.0 

func (x *Offset) GetValue() int64

func (*Offset) ProtoMessage added in v1.1.0 

func (*Offset) ProtoMessage()

func (*Offset) ProtoReflect added in v1.1.0 

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

func (*Offset) Reset added in v1.1.0 

func (x *Offset) Reset()

func (*Offset) String added in v1.1.0 

func (x *Offset) String() string

type ProjectionId added in v1.1.0 

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 added in v1.1.0 

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

Deprecated: Use ProjectionId.ProtoReflect.Descriptor instead.

func (*ProjectionId) GetProjectionName added in v1.1.0 

func (x *ProjectionId) GetProjectionName() string

func (*ProjectionId) GetShardNumber added in v1.1.0 

func (x *ProjectionId) GetShardNumber() uint64

func (*ProjectionId) ProtoMessage added in v1.1.0 

func (*ProjectionId) ProtoMessage()

func (*ProjectionId) ProtoReflect added in v1.1.0 

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

func (*ProjectionId) Reset added in v1.1.0 

func (x *ProjectionId) Reset()

func (*ProjectionId) String added in v1.1.0 

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.