es

Documentation

Overview

Package es implements a common support for Event Sourcing.

To use, you should extend your Entity Aggregate from the AggregateBase struct.

Example:

package loans

import (
	"fmt"

	"github.com/AltScore/gothic/pkg/es"
)

const EntityType = "loans"

type Aggregate struct {
	es.AggregateBase[ID, Snapshot]
}

Your events should extend the Event struct:

type flowStarted struct {
	es.Metadata
	ClientID      ClientID
	TransactionID string
	TotalAmount   Money
}

Package samples contains sample code for using gothic.

Index

• func Reify[Agg Aggregate[SS], SS Snapshot](previousEvents []event.Event, factory func(AggregateBase[SS]) Agg, ...) (Agg, error)
• type Aggregate
• type AggregateBase
  • func NewAgg[SS Snapshot](id ids.ID, type_ string, events []event.Event, opts ...Option[SS]) AggregateBase[SS]
  • func (a *AggregateBase[SS]) Apply(e event.Event) error
  • func (a *AggregateBase[SS]) GetNewEvents() []event.Event
  • func (a *AggregateBase[SS]) HasEventsToSave() bool
  • func (a *AggregateBase[SS]) ID() ids.ID
  • func (a *AggregateBase[SS]) NewMetadata(eventType string) Metadata
  • func (a *AggregateBase[SS]) Raise(e event.Event) error
  • func (a *AggregateBase[SS]) Replay() error
  • func (a *AggregateBase[SS]) SetId(id ids.ID)
  • func (a *AggregateBase[SS]) Snapshot() SS
  • func (a *AggregateBase[SS]) Type() string
  • func (a *AggregateBase[SS]) Version() int
  • func (a *AggregateBase[SS]) WithEventsSaved() AggregateBase[SS]
• type EntityID
• type Metadata
  • func NewMetadata(entityType string, entityID ids.ID, type_ string, version int) Metadata
  • func (m *Metadata) Datetime() time.Time
  • func (m *Metadata) EntityID() ids.ID
  • func (m *Metadata) EntityType() string
  • func (m *Metadata) Type() string
  • func (m *Metadata) Version() int
• type Option
  • func WithSnapshot[SS Snapshot](snapshot SS) Option[SS]
• type Snapshot

Functions

func Reify

func Reify[Agg Aggregate[SS], SS Snapshot](previousEvents []event.Event, factory func(AggregateBase[SS]) Agg, opts ...Option[SS]) (Agg, error)

Reify recreates an aggregate from a list of events stored to its current state.

Types

type Aggregate

type Aggregate[SS Snapshot] interface {
	ID() ids.ID
	Type() string
	Version() int
	Snapshot() SS
	Apply(e event.Event) error
	Replay() error
}

type AggregateBase

type AggregateBase[SS Snapshot] struct {
	// contains filtered or unexported fields
}

func NewAgg

func NewAgg[SS Snapshot](
	id ids.ID,
	type_ string,
	events []event.Event,
	opts ...Option[SS],
) AggregateBase[SS]

func (*AggregateBase[SS]) Apply

func (a *AggregateBase[SS]) Apply(e event.Event) error

Apply process an already existent event to update the current Snapshot En error is returned in case the event is incorrect for this Snapshot

func (*AggregateBase[SS]) GetNewEvents

func (a *AggregateBase[SS]) GetNewEvents() []event.Event

func (*AggregateBase[SS]) HasEventsToSave

func (a *AggregateBase[SS]) HasEventsToSave() bool

func (*AggregateBase[SS]) ID

func (a *AggregateBase[SS]) ID() ids.ID

func (*AggregateBase[SS]) NewMetadata

func (a *AggregateBase[SS]) NewMetadata(eventType string) Metadata

func (*AggregateBase[SS]) Raise

func (a *AggregateBase[SS]) Raise(e event.Event) error

Raise process a new event to update the current Snapshot and append it to the past events

func (*AggregateBase[SS]) Replay

func (a *AggregateBase[SS]) Replay() error

func (*AggregateBase[SS]) SetId

func (a *AggregateBase[SS]) SetId(id ids.ID)

func (*AggregateBase[SS]) Snapshot

func (a *AggregateBase[SS]) Snapshot() SS

func (*AggregateBase[SS]) Type

func (a *AggregateBase[SS]) Type() string

func (*AggregateBase[SS]) Version

func (a *AggregateBase[SS]) Version() int

func (*AggregateBase[SS]) WithEventsSaved

func (a *AggregateBase[SS]) WithEventsSaved() AggregateBase[SS]

type EntityID

type EntityID = string

type Metadata

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

func NewMetadata

func NewMetadata(
	entityType string,
	entityID ids.ID,
	type_ string,
	version int) Metadata

func (*Metadata) Datetime

func (m *Metadata) Datetime() time.Time

func (*Metadata) EntityID

func (m *Metadata) EntityID() ids.ID

func (*Metadata) EntityType

func (m *Metadata) EntityType() string

func (*Metadata) Type

func (m *Metadata) Type() string

func (*Metadata) Version

func (m *Metadata) Version() int

type Option

type Option[SS Snapshot] func(*AggregateBase[SS])

func WithSnapshot

func WithSnapshot[SS Snapshot](snapshot SS) Option[SS]

type Snapshot

type Snapshot interface {
	Apply(event.Event) error
	SetVersion(int)
}