evercore

Sep 13, 2025

Changes in this version

+ const StartBeginning

+ const StartEnd

+ const StartEventID

+ const StartTimestamp

+ var ErrSubscriptionAlreadyOwned = errors.New("subscription already owned")

type EventStore

+ func (store *EventStore) RunEphemeralSubscription(ctx context.Context, filter SubscriptionFilter, start StartFrom, opts Options, ...) error

+ func (store *EventStore) RunSubscription(ctx context.Context, name string, filter SubscriptionFilter, start StartFrom, ...) error

type MemoryStorageEngine

+ NextSubscriptionID int64

+ SubscriptionByID map[int64]*Subscription

+ SubscriptionEventTypes map[int64]map[int64]bool

+ Subscriptions map[string]*Subscription

+ func (store *MemoryStorageEngine) AddSubscriptionEventType(tx StorageEngineTxInfo, ctx context.Context, subscriptionId int64, ...) error

+ func (store *MemoryStorageEngine) AdvanceSubscriptionCursor(tx StorageEngineTxInfo, ctx context.Context, id int64, lastEventId int64) error

+ func (store *MemoryStorageEngine) ClaimSubscription(tx StorageEngineTxInfo, ctx context.Context, name string, owner string, ...) (bool, error)

+ func (store *MemoryStorageEngine) GetEventsForSubscription(tx StorageEngineTxInfo, ctx context.Context, sub *Subscription, limit int) ([]SerializedEvent, error)

+ func (store *MemoryStorageEngine) GetFirstEventIdFromTimestamp(tx StorageEngineTxInfo, ctx context.Context, ts time.Time) (int64, error)

+ func (store *MemoryStorageEngine) GetMaxEventId(tx StorageEngineTxInfo, ctx context.Context) (int64, error)

+ func (store *MemoryStorageEngine) GetSubscriptionByName(tx StorageEngineTxInfo, ctx context.Context, name string) (*Subscription, error)

+ func (store *MemoryStorageEngine) ReleaseSubscription(tx StorageEngineTxInfo, ctx context.Context, name string, owner string) error

+ func (store *MemoryStorageEngine) RenewSubscription(tx StorageEngineTxInfo, ctx context.Context, name string, owner string, ...) (bool, error)

+ func (store *MemoryStorageEngine) SetSubscriptionActive(tx StorageEngineTxInfo, ctx context.Context, id int64, active bool) error

+ func (store *MemoryStorageEngine) UpsertSubscription(tx StorageEngineTxInfo, ctx context.Context, name string, ...) (int64, error)

+ type Options struct

+ BatchSize int

+ Lease time.Duration

+ Owner string

+ PollInterval time.Duration

type SerializedEvent

+ EventID int64

+ type StartFrom struct

+ EventID int64

+ Kind string

+ Timestamp time.Time

type StorageEngine

+ AddSubscriptionEventType func(tx StorageEngineTxInfo, ctx context.Context, subscriptionId int64, ...) error

+ AdvanceSubscriptionCursor func(tx StorageEngineTxInfo, ctx context.Context, id int64, lastEventId int64) error

+ ClaimSubscription func(tx StorageEngineTxInfo, ctx context.Context, name string, owner string, ...) (bool, error)

+ GetEventsForSubscription func(tx StorageEngineTxInfo, ctx context.Context, sub *Subscription, limit int) ([]SerializedEvent, error)

+ GetFirstEventIdFromTimestamp func(tx StorageEngineTxInfo, ctx context.Context, ts time.Time) (int64, error)

+ GetMaxEventId func(tx StorageEngineTxInfo, ctx context.Context) (int64, error)

+ GetSubscriptionByName func(tx StorageEngineTxInfo, ctx context.Context, name string) (*Subscription, error)

+ ReleaseSubscription func(tx StorageEngineTxInfo, ctx context.Context, name string, owner string) error

+ RenewSubscription func(tx StorageEngineTxInfo, ctx context.Context, name string, owner string, ...) (bool, error)

+ SetSubscriptionActive func(tx StorageEngineTxInfo, ctx context.Context, id int64, active bool) error

+ UpsertSubscription func(tx StorageEngineTxInfo, ctx context.Context, name string, ...) (int64, error)

+ type Subscription struct

+ Active bool

+ AggregateKey *string

+ AggregateTypeID *int64

+ EventTypeID *int64

+ ID int64

+ LastEventID int64

+ LeaseExpiresAt *time.Time

+ LeaseOwner *string

+ Name string

+ StartEventID int64

+ StartFrom string

+ StartTimestamp *time.Time

+ type SubscriptionFilter struct

+ AggregateKey *string

+ AggregateType string

+ EventTypes []string

Jul 19, 2025

Changes in this version

type EventStoreContext

+ ChangeAggregateNaturalKey func(id int64, naturalKey string) error

type EventStoreContextType

+ func (etx *EventStoreContextType) ChangeAggregateNaturalKey(id int64, naturalKey string) error

Jul 18, 2025

Changes in this version

type MemoryStorageEngine

+ func (store *MemoryStorageEngine) ChangeAggregateNaturalKey(tx StorageEngineTxInfo, ctx context.Context, aggregateId int64, ...) error

type StorageEngine

+ ChangeAggregateNaturalKey func(tx StorageEngineTxInfo, ctx context.Context, aggregateId int64, ...) error

Jul 9, 2025

Changes in this version

type EventStore

+ func (store *EventStore) Close() error

type MemoryStorageEngine

+ func (store *MemoryStorageEngine) Close() error

type StorageEngine

+ Close func() error

Jun 24, 2025

Changes in this version

+ var ErrEventStateIsNotAStateEvent = ErrorMessage("Event state is not a StateEvent and there is no Apply method.")

+ func RegisterEventDecoder(decoders ...EventDecoder)

+ type ApplyFunc func(eventState EventState, eventTime time.Time, reference string) error

+ type ErrorMessage string

+ func (e ErrorMessage) Error() string

type EventState

+ func DecodeEvent(ev SerializedEvent) (bool, EventState, error)

type StateAggregate

+ HandleOtherEvents ApplyFunc

Jun 24, 2025

Changes in this version

+ const ErrorNotFound

+ const ErrorTypeConstraintViolation

+ var ErrorKeyExceedsMaximumLength error = fmt.Errorf("The specified key exceeds the maximum key length")

+ func CopyFields(e, t any) error

+ func DecodeEventStateTo[U any](e SerializedEvent, state *U) error

+ func DeserializeFromJson[T any](serialized string, target *T) error

+ func InContext[T any](ctx context.Context, store *EventStore, exec contextFuncReturns[T]) (T, error)

+ func InReadonlyContext[T any](ctx context.Context, store *EventStore, exec readonlyContextFuncReturns[T]) (T, error)

+ func RegisterStateEventDecoder(decoder EventDecoder)

+ func SerializeToJson(ev any) string

+ func TypeNameFromType[T any](ev T) string

+ type Aggregate interface

+ ApplyEventState func(eventState EventState, eventTime time.Time, reference string) error

+ ApplySnapshot func(snapshot *Snapshot) error

+ DecodeEvent func(ev SerializedEvent) (EventState, error)

+ GetAggregateType func() string

+ GetId func() int64

+ GetSequence func() int64

+ GetSnapshotFrequency func() int64

+ GetSnapshotState func() (*string, error)

+ SetId func(int64)

+ SetSequence func(int64)

+ type AggregateState struct

+ AggregateId int64

+ Events EventSlice

+ NaturalKey *string

+ Snapshot *Snapshot

+ type ContextOwner interface

+ type EventDecoder func(aggregateType string, ev SerializedEvent) (EventState, error)

+ type EventSlice []SerializedEvent

+ type EventState interface

+ GetEventType func() string

+ Serialize func() string

+ type EventStore struct

+ func NewEventStore(storageEngine StorageEngine) *EventStore

+ func (store *EventStore) SaveState(ctx context.Context, tx StorageEngineTxInfo, events EventSlice, ...) error

+ func (store *EventStore) Warmup(ctx context.Context, knownAggregateTypes []string, knownEventTypes []string) error

+ func (store *EventStore) WithContext(ctx context.Context, exec contextFunc) error

+ func (store *EventStore) WithReadonlyContext(ctx context.Context, exec readonlyContextFunc) error

+ type EventStoreContext interface

+ ApplyEventTo func(agg Aggregate, event EventState, time time.Time, reference string) error

+ CreateAggregateInto func(agg Aggregate) error

+ CreateAggregateWithKeyInto func(agg Aggregate, naturalKey string) error

+ LoadOrCreateAggregate func(agg Aggregate, naturalKey string) (bool, error)

+ NewAggregateId func(aggregateType string) (int64, error)

+ NewAggregateIdWithKey func(aggregateType string, naturalKey string) (int64, error)

+ Publish func(*SerializedEvent)

+ SaveSnapshot func(snapshot Snapshot)

+ type EventStoreContextType struct

+ Transaction StorageEngineTxInfo

+ func (ctx *EventStoreContextType) LoadAggregateState(aggregateType string, aggregateId int64) (*AggregateState, error)

+ func (ctx *EventStoreContextType) LoadAggregateStateByKey(aggregateType string, naturalKey string) (*AggregateState, error)

+ func (ctx *EventStoreContextType) Publish(event *SerializedEvent)

+ func (ctx EventStoreContextType) NewAggregateId(aggregateType string) (int64, error)

+ func (ctx EventStoreContextType) NewAggregateIdWithKey(aggregateType string, naturalKey string) (int64, error)

+ func (etx *EventStoreContextType) ApplyEventTo(agg Aggregate, eventState EventState, time time.Time, reference string) error

+ func (etx *EventStoreContextType) CreateAggregateInto(agg Aggregate) error

+ func (etx *EventStoreContextType) CreateAggregateWithKeyInto(agg Aggregate, naturalKey string) error

+ func (etx *EventStoreContextType) LoadOrCreateAggregate(agg Aggregate, naturalKey string) (bool, error)

+ func (etx *EventStoreContextType) LoadStateByKeyInto(agg Aggregate, naturalKey string) error

+ func (etx *EventStoreContextType) LoadStateInto(agg Aggregate, aggregateId int64) error

+ func (etx *EventStoreContextType) SaveSnapshot(snapshot Snapshot)

+ type EventStoreReadonlyContext interface

+ LoadAggregateState func(aggregateType string, aggregateId int64) (*AggregateState, error)

+ LoadAggregateStateByKey func(aggregateType string, naturalKey string) (*AggregateState, error)

+ LoadStateByKeyInto func(aggregate Aggregate, naturalKey string) error

+ LoadStateInto func(aggregate Aggregate, id int64) error

+ type IdNameMap map[int64]string

+ func MapIdToName(idNamePair []IdNamePair) IdNameMap

+ type IdNamePair struct

+ Id int64

+ Name string

+ type MemoryStorageEngine struct

+ AggregateInv map[int64]*string

+ AggregateToTypeId map[int64]int64

+ AggregateTypes map[string]int64

+ AggregateTypesInv map[int64]string

+ Aggregates map[string]int64

+ CapturedEvents []StorageEngineEvent

+ CapturedSnapshots []Snapshot

+ CountAggregateType int64

+ CountAggregates int64

+ CountEventTypes int64

+ EventTypes map[string]int64

+ EventTypesInv map[int64]string

+ func NewMemoryStorageEngine() *MemoryStorageEngine

+ func (stor *MemoryStorageEngine) GetMaxKeyLength() int

+ func (stor *MemoryStorageEngine) GetTransactionInfo() (StorageEngineTxInfo, error)

+ func (store *MemoryStorageEngine) GetAggregateById(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (int64, *string, error)

+ func (store *MemoryStorageEngine) GetAggregateByKey(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (int64, error)

+ func (store *MemoryStorageEngine) GetAggregateTypeId(tx StorageEngineTxInfo, ctx context.Context, name string) (int64, error)

+ func (store *MemoryStorageEngine) GetAggregateTypes(tx StorageEngineTxInfo, ctx context.Context) ([]IdNamePair, error)

+ func (store *MemoryStorageEngine) GetEventTypeId(tx StorageEngineTxInfo, ctx context.Context, name string) (int64, error)

+ func (store *MemoryStorageEngine) GetEventTypes(tx StorageEngineTxInfo, ctx context.Context) ([]IdNamePair, error)

+ func (store *MemoryStorageEngine) GetEventsForAggregate(tx StorageEngineTxInfo, ctx context.Context, aggregateId int64, ...) ([]SerializedEvent, error)

+ func (store *MemoryStorageEngine) GetOrCreateAggregateByKey(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (bool, int64, error)

+ func (store *MemoryStorageEngine) GetSnapshotForAggregate(tx StorageEngineTxInfo, ctx context.Context, aggregateId int64) (*Snapshot, error)

+ func (store *MemoryStorageEngine) NewAggregate(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64) (int64, error)

+ func (store *MemoryStorageEngine) NewAggregateWithKey(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (int64, error)

+ func (store *MemoryStorageEngine) WriteState(tx StorageEngineTxInfo, ctx context.Context, events []StorageEngineEvent, ...) error

+ type MemoryStorageEngineTransaction struct

+ func (tx MemoryStorageEngineTransaction) Commit() error

+ func (tx MemoryStorageEngineTransaction) Rollback() error

+ type NameIdMap map[string]int64

+ func MapNameToId(idNamePair []IdNamePair) NameIdMap

+ type SerializedEvent struct

+ AggregateId int64

+ EventTime time.Time

+ EventType string

+ Reference string

+ Sequence int64

+ State string

+ type Snapshot struct

+ AggregateId int64

+ Sequence int64

+ State string

+ type SnapshotSlice []Snapshot

+ type StateAggregate struct

+ Id int64

+ Sequence int64

+ State T

+ func (t *StateAggregate[T]) ApplyEventState(eventState EventState, eventTime time.Time, reference string) error

+ func (t *StateAggregate[T]) ApplySnapshot(snapshot *Snapshot) error

+ func (t *StateAggregate[T]) DecodeEvent(ev SerializedEvent) (EventState, error)

+ func (t *StateAggregate[T]) GetAggregateType() string

+ func (t *StateAggregate[T]) GetId() int64

+ func (t *StateAggregate[T]) GetSequence() int64

+ func (t *StateAggregate[T]) GetSnapshotFrequency() int64

+ func (t *StateAggregate[T]) GetSnapshotState() (*string, error)

+ func (t *StateAggregate[T]) SetId(id int64)

+ func (t *StateAggregate[T]) SetSequence(seq int64)

+ type StateEvent struct

+ State T

+ func NewStateEvent[T any](state T) StateEvent[T]

+ func (ev *StateEvent[T]) Deserialize(serialized string) error

+ func (ev StateEvent[T]) GetEventType() string

+ func (ev StateEvent[T]) GetState() any

+ func (ev StateEvent[T]) Serialize() string

+ type StorageEngine interface

+ GetAggregateById func(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (int64, *string, error)

+ GetAggregateByKey func(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (int64, error)

+ GetAggregateTypeId func(tx StorageEngineTxInfo, ctx context.Context, typeName string) (int64, error)

+ GetAggregateTypes func(tx StorageEngineTxInfo, ctx context.Context) ([]IdNamePair, error)

+ GetEventTypeId func(tx StorageEngineTxInfo, ctx context.Context, typeName string) (int64, error)

+ GetEventTypes func(tx StorageEngineTxInfo, ctx context.Context) ([]IdNamePair, error)

+ GetEventsForAggregate func(tx StorageEngineTxInfo, ctx context.Context, aggregateId int64, ...) ([]SerializedEvent, error)

+ GetMaxKeyLength func() int

+ GetOrCreateAggregateByKey func(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (bool, int64, error)

+ GetSnapshotForAggregate func(tx StorageEngineTxInfo, ctx context.Context, aggregateId int64) (*Snapshot, error)

+ GetTransactionInfo func() (StorageEngineTxInfo, error)

+ NewAggregate func(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64) (int64, error)

+ NewAggregateWithKey func(tx StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, ...) (int64, error)

+ WriteState func(tx StorageEngineTxInfo, ctx context.Context, events []StorageEngineEvent, ...) error

+ type StorageEngineError struct

+ Err error

+ ErrorType string

+ Message string

+ func NewStorageEngineError(message string, err error) *StorageEngineError

+ func (e *StorageEngineError) Error() string

+ func (e *StorageEngineError) Unwrap() error

+ type StorageEngineEvent struct

+ AggregateID int64

+ EventTime time.Time

+ EventTypeID int64

+ Reference string

+ Sequence int64

+ State string

+ type StorageEngineTxInfo interface

+ Commit func() error

+ Rollback func() error