repository

Documentation

Index

• type EventSourcing
  • func NewEventSourcing(eventStore eventstore.Store, publisher eventbus.Publisher, ...) *EventSourcing
  • func (r *EventSourcing) Load(ctx context.Context, st stream.Type, sid stream.ID, newStream MakeStream) (stream.Stream, error)
  • func (r *EventSourcing) Save(ctx context.Context, s stream.Stream, expected stream.Version) (err error)
• type MakeStream
• type Option
  • func IgnoreSnapshotError() Option
  • func WithTxn(tx txn.Txn) Option
• type Repository
• type State
  • func NewState(publisher eventbus.Publisher, snapshot snapshot.Snapshot, transaction txn.Txn) *State
  • func (r *State) Load(ctx context.Context, st stream.Type, sid stream.ID, newStream MakeStream) (stream.Stream, error)
  • func (r *State) Save(ctx context.Context, s stream.Stream, expected stream.Version) (err error)

Types

type EventSourcing

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

func NewEventSourcing

func NewEventSourcing(
	eventStore eventstore.Store,
	publisher eventbus.Publisher,
	snapshot snapshot.Snapshot,
	options ...Option,
) *EventSourcing

func (*EventSourcing) Load

func (r *EventSourcing) Load(ctx context.Context, st stream.Type,
	sid stream.ID, newStream MakeStream) (stream.Stream, error)

func (*EventSourcing) Save

func (r *EventSourcing) Save(ctx context.Context, s stream.Stream, expected stream.Version) (err error)

type MakeStream

type MakeStream func() stream.Stream

type Option

type Option func(r *EventSourcing)

func IgnoreSnapshotError

func IgnoreSnapshotError() Option

func WithTxn

func WithTxn(tx txn.Txn) Option

type Repository

type Repository interface {
	Save(context.Context, stream.Stream, stream.Version) error
	Load(context.Context, stream.Type, stream.ID, MakeStream) (stream.Stream, error)
}

type State

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

func NewState

func NewState(
	publisher eventbus.Publisher,
	snapshot snapshot.Snapshot,
	transaction txn.Txn,
) *State

func (*State) Load

func (r *State) Load(ctx context.Context, st stream.Type, sid stream.ID, newStream MakeStream) (stream.Stream, error)

func (*State) Save

func (r *State) Save(ctx context.Context, s stream.Stream, expected stream.Version) (err error)