eventstore

Documentation

Index

• Constants
• type DBImpl
  • func NewEventStoreDBImpl(esdb *eventstore.StoreDB, mapper *event.TypeMapper) (*DBImpl, error)
  • func (e *DBImpl) Close() error
  • func (e *DBImpl) Load(ctx context.Context, streamID string, version int) ([]event.DomainEvent, error)
  • func (e *DBImpl) SafeStore(ctx context.Context, events []event.DomainEvent, expectedVersion int) error
  • func (e *DBImpl) Store(ctx context.Context, events []event.DomainEvent, version int) error

Constants

const (
	ErrorCodeCacheSet = domainerrors.ErrorCodeInfraDatasource + domainerrors.ErrorCodeInfraDatasource + domainerrors.ErrorCodeInfraDatasourceEventStore + iota
	ErrorCodeResourceNotFound
	ErrorCodeEventFormatWrong
)

const (
	ReadStreadNum = 100
	EventSplitNum = 2
)

Types

type DBImpl

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

func NewEventStoreDBImpl

func NewEventStoreDBImpl(esdb *eventstore.StoreDB, mapper *event.TypeMapper) (*DBImpl, error)

func (*DBImpl) Close

func (e *DBImpl) Close() error

func (*DBImpl) Load

func (e *DBImpl) Load(ctx context.Context, streamID string, version int) ([]event.DomainEvent, error)

func (*DBImpl) SafeStore

func (e *DBImpl) SafeStore(ctx context.Context, events []event.DomainEvent, expectedVersion int) error

func (*DBImpl) Store

func (e *DBImpl) Store(ctx context.Context, events []event.DomainEvent, version int) error