es_postgres

Documentation

Index

• type Aggregates
• type EventStore
  • func New(ctx context.Context, store db.DB) (*EventStore, error)
  • func (e *EventStore) GetAggregateWithoutSnapshot(ctx context.Context) ([]*eventsourcing.BaseAggregate, error)
  • func (e *EventStore) Load(ctx context.Context, aggregateID string) (*eventsourcing.Snapshot, []*eventsourcing.Event, error)
  • func (e *EventStore) SafeSave(ctx context.Context, events []*eventsourcing.Event) error
  • func (e *EventStore) Save(ctx context.Context, events []*eventsourcing.Event) error
  • func (e *EventStore) SaveSnapshot(ctx context.Context, snapshot *eventsourcing.Snapshot) error
• type Events
• type IncorrectUpdatedBillingError
  • func (e *IncorrectUpdatedBillingError) Error() string

Types

type Aggregates

type Aggregates interface {
	// contains filtered or unexported methods
}

type EventStore

type EventStore struct {
	Aggregates
	Events
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, store db.DB) (*EventStore, error)

func (*EventStore) GetAggregateWithoutSnapshot

func (e *EventStore) GetAggregateWithoutSnapshot(ctx context.Context) ([]*eventsourcing.BaseAggregate, error)

GetAggregateWithoutSnapshot - get aggregates without a snapshot

func (*EventStore) Load

func (e *EventStore) Load(ctx context.Context, aggregateID string) (*eventsourcing.Snapshot, []*eventsourcing.Event, error)

func (*EventStore) SafeSave

func (e *EventStore) SafeSave(ctx context.Context, events []*eventsourcing.Event) error

func (*EventStore) Save

func (e *EventStore) Save(ctx context.Context, events []*eventsourcing.Event) error

func (*EventStore) SaveSnapshot

func (e *EventStore) SaveSnapshot(ctx context.Context, snapshot *eventsourcing.Snapshot) error

SaveSnapshot - save snapshot

type Events

type Events interface {
	// contains filtered or unexported methods
}

type IncorrectUpdatedBillingError

type IncorrectUpdatedBillingError struct {
	Err     error
	Updated int64
}

func (*IncorrectUpdatedBillingError) Error

func (e *IncorrectUpdatedBillingError) Error() string