event_store

Documentation

Overview

Billing Service. Infrastructure layer

Index

• type EventStore
• type Repository
  • func (s *Repository) Use(ctx context.Context, log logger.Logger, db *db.Store) (*Repository, error)

Types

type EventStore

type EventStore interface {
	Init(ctx context.Context, db *db.Store) error

	Save(ctx context.Context, events []*eventsourcing.Event) error
	SafeSave(ctx context.Context, events []*eventsourcing.Event) error
	Load(ctx context.Context, aggregateID string) (*eventsourcing.Snapshot, []*eventsourcing.Event, error)

	GetAggregateWithoutSnapshot(ctx context.Context) ([]*eventsourcing.BaseAggregate, error)
	SaveSnapshot(ctx context.Context, snapshot *eventsourcing.Snapshot) error
}

EventStore saves the events from an aggregate

type Repository

type Repository struct {

	// Base interface
	EventStore

	// Observer interface for subscribe on system event
	notify.Subscriber // Observer interface for subscribe on system event
	// contains filtered or unexported fields
}

Store abstract type

func (*Repository) Use

func (s *Repository) Use(ctx context.Context, log logger.Logger, db *db.Store) (*Repository, error)

Use return implementation of db