Versions in this module Expand all Collapse all v2 v2.0.2 Jun 23, 2024 v2.0.1 Jun 6, 2024 Changes in this version + var File_ego_v2_ego_proto protoreflect.FileDescriptor + type CommandReply struct + Reply isCommandReply_Reply + func (*CommandReply) Descriptor() ([]byte, []int) + func (*CommandReply) ProtoMessage() + func (m *CommandReply) GetReply() isCommandReply_Reply + func (x *CommandReply) GetErrorReply() *ErrorReply + func (x *CommandReply) GetStateReply() *StateReply + func (x *CommandReply) ProtoReflect() protoreflect.Message + func (x *CommandReply) Reset() + func (x *CommandReply) String() string + type CommandReply_ErrorReply struct + ErrorReply *ErrorReply + type CommandReply_StateReply struct + StateReply *StateReply + type ErrorReply struct + Message string + func (*ErrorReply) Descriptor() ([]byte, []int) + func (*ErrorReply) ProtoMessage() + func (x *ErrorReply) GetMessage() string + func (x *ErrorReply) ProtoReflect() protoreflect.Message + func (x *ErrorReply) Reset() + func (x *ErrorReply) String() string + type Event struct + Event *anypb.Any + IsDeleted bool + PersistenceId string + ResultingState *anypb.Any + SequenceNumber uint64 + Shard uint64 + Timestamp int64 + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (x *Event) GetEvent() *anypb.Any + func (x *Event) GetIsDeleted() bool + func (x *Event) GetPersistenceId() string + func (x *Event) GetResultingState() *anypb.Any + func (x *Event) GetSequenceNumber() uint64 + func (x *Event) GetShard() uint64 + func (x *Event) GetTimestamp() int64 + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type GetStateCommand struct + func (*GetStateCommand) Descriptor() ([]byte, []int) + func (*GetStateCommand) ProtoMessage() + func (x *GetStateCommand) ProtoReflect() protoreflect.Message + func (x *GetStateCommand) Reset() + func (x *GetStateCommand) String() string + type NoReply struct + func (*NoReply) Descriptor() ([]byte, []int) + func (*NoReply) ProtoMessage() + func (x *NoReply) ProtoReflect() protoreflect.Message + func (x *NoReply) Reset() + func (x *NoReply) String() string + type Offset struct + ProjectionName string + ShardNumber uint64 + Timestamp int64 + Value int64 + func (*Offset) Descriptor() ([]byte, []int) + func (*Offset) ProtoMessage() + func (x *Offset) GetProjectionName() string + func (x *Offset) GetShardNumber() uint64 + func (x *Offset) GetTimestamp() int64 + func (x *Offset) GetValue() int64 + func (x *Offset) ProtoReflect() protoreflect.Message + func (x *Offset) Reset() + func (x *Offset) String() string + type ProjectionId struct + ProjectionName string + ShardNumber uint64 + func (*ProjectionId) Descriptor() ([]byte, []int) + func (*ProjectionId) ProtoMessage() + func (x *ProjectionId) GetProjectionName() string + func (x *ProjectionId) GetShardNumber() uint64 + func (x *ProjectionId) ProtoReflect() protoreflect.Message + func (x *ProjectionId) Reset() + func (x *ProjectionId) String() string + type StateReply struct + PersistenceId string + SequenceNumber uint64 + State *anypb.Any + Timestamp int64 + func (*StateReply) Descriptor() ([]byte, []int) + func (*StateReply) ProtoMessage() + func (x *StateReply) GetPersistenceId() string + func (x *StateReply) GetSequenceNumber() uint64 + func (x *StateReply) GetState() *anypb.Any + func (x *StateReply) GetTimestamp() int64 + func (x *StateReply) ProtoReflect() protoreflect.Message + func (x *StateReply) Reset() + func (x *StateReply) String() string Other modules containing this package github.com/tochemey/ego github.com/tochemey/ego/v3
Go to main page