Versions in this module Expand all Collapse all v0 v0.2.1 Sep 22, 2023 Changes in this version + const AggregateIDAttribute + const AggregateTypeAttribute + const AggregateVersionAttribute + const ErrorAttribute + const EventStoreNumEventsKey + const EventStreamExpectedVersionKey + const EventStreamIDKey + const EventStreamVersionSelectorKey + type InstrumentedEventStore struct + func NewInstrumentedEventStore(eventStore event.Store, options ...Option) (*InstrumentedEventStore, error) + func (ies *InstrumentedEventStore) Append(ctx context.Context, id event.StreamID, expected version.Check, ...) (newVersion version.Version, err error) + func (ies *InstrumentedEventStore) Stream(ctx context.Context, stream event.StreamWrite, id event.StreamID, ...) (err error) + type InstrumentedRepository struct + func NewInstrumentedRepository(aggregateType aggregate.Type[I, T], repository aggregate.Repository[I, T], ...) (*InstrumentedRepository[I, T], error) + func (ir *InstrumentedRepository[I, T]) Get(ctx context.Context, id I) (result T, err error) + func (ir *InstrumentedRepository[I, T]) Save(ctx context.Context, root T) (err error) + type Option interface + func WithMeterProvider(provider metric.MeterProvider) Option + func WithTracerProvider(provider trace.TracerProvider) Option