eventsourcing

README

go-eventstore

How to use it

Documentation

Index

• Variables
• type Aggregate
• type AggregateID
• type Event
• type EventID
• type EventStore
  • func NewEventStore(l logrus.FieldLogger) *EventStore
  • func (es *EventStore) AddStorage(s Storage)
  • func (es *EventStore) Load(storage string, a Aggregate) error
  • func (es *EventStore) Persist(storage string, a Aggregate) error
• type Meta
  • func NewMeta(name string, version string) Meta
  • func NewMetaWithID(id EventID, name string, version string) Meta
• type Storage

Variables

var (
	ErrStorageNotAvailable = errors.New("storage not available")
	ErrNoAggregateID       = errors.New("no aggregate id")
)

Types

type Aggregate

type Aggregate interface {
	AggregateID() AggregateID
	On(e Event) error
	OnRaw(name string, version string, e []byte) error
	Events() []Event
}

type AggregateID

type AggregateID string

type Event

type Event interface {
	Meta() Meta
}

type EventID

type EventID string

type EventStore

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

func NewEventStore

func NewEventStore(l logrus.FieldLogger) *EventStore

func (*EventStore) AddStorage

func (es *EventStore) AddStorage(s Storage)

func (*EventStore) Load

func (es *EventStore) Load(storage string, a Aggregate) error

func (*EventStore) Persist

func (es *EventStore) Persist(storage string, a Aggregate) error

type Meta

type Meta struct {
	ID        EventID   `json:"id" yaml:"id"`
	Name      string    `json:"name" yaml:"name"`
	CreatedAt time.Time `json:"created_at" yaml:"created_at"`
	Version   string    `json:"version" yaml:"version"`
}

func NewMeta

func NewMeta(name string, version string) Meta

func NewMetaWithID

func NewMetaWithID(id EventID, name string, version string) Meta

type Storage

type Storage interface {
	Name() string
	Upsert(a Aggregate) error
	Load(a Aggregate) error
	Close() error
}