repository

Documentation

Index

• type EventSourcing
  • func NewEventSourcing(c codec.Codec) *EventSourcing
  • func (b *EventSourcing) Build() *repository.EventSourcing
  • func (b *EventSourcing) EventStorePostgres() eventstore.Store
  • func (b *EventSourcing) SetEventStorePostgres(p *pgxpool.Pool) *EventSourcing
  • func (b *EventSourcing) SetPublisher(p eventbus.Publisher) *EventSourcing
  • func (b *EventSourcing) SetSnapshotPostgres(p *pgxpool.Pool, threshold int, c snapshot.Codec) *EventSourcing
  • func (b *EventSourcing) SetTxnPostgres(p *pgxpool.Pool) *EventSourcing
  • func (b *EventSourcing) SnapshotPostgres() snapshot.Snapshot
  • func (b *EventSourcing) TxnPostgres() txn.Txn

Types

type EventSourcing

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

func NewEventSourcing

func NewEventSourcing(c codec.Codec) *EventSourcing

func (*EventSourcing) Build

func (b *EventSourcing) Build() *repository.EventSourcing

func (*EventSourcing) EventStorePostgres

func (b *EventSourcing) EventStorePostgres() eventstore.Store

func (*EventSourcing) SetEventStorePostgres

func (b *EventSourcing) SetEventStorePostgres(p *pgxpool.Pool) *EventSourcing

func (*EventSourcing) SetPublisher

func (b *EventSourcing) SetPublisher(p eventbus.Publisher) *EventSourcing

func (*EventSourcing) SetSnapshotPostgres

func (b *EventSourcing) SetSnapshotPostgres(p *pgxpool.Pool, threshold int, c snapshot.Codec) *EventSourcing

func (*EventSourcing) SetTxnPostgres

func (b *EventSourcing) SetTxnPostgres(p *pgxpool.Pool) *EventSourcing

func (*EventSourcing) SnapshotPostgres

func (b *EventSourcing) SnapshotPostgres() snapshot.Snapshot

func (*EventSourcing) TxnPostgres

func (b *EventSourcing) TxnPostgres() txn.Txn