esdb

README

esdb event store

The esdb event store is supporting the EventStoreDB database.

It's based on the module github.com/EventStore/EventStore-Client-Go/v3 for reading and writing events.

Documentation

Index

• type ESDB
  • func Open(client *esdb.Client, jsonSerializer bool) *ESDB
  • func (es *ESDB) Get(ctx context.Context, id string, aggregateType string, ...) (core.Iterator, error)
  • func (es *ESDB) Save(events []core.Event) error

Types

type ESDB

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

ESDB is the event store handler

func Open

func Open(client *esdb.Client, jsonSerializer bool) *ESDB

Open binds the event store db client

func (*ESDB) Get

func (es *ESDB) Get(ctx context.Context, id string, aggregateType string, afterVersion core.Version) (core.Iterator, error)

func (*ESDB) Save

func (es *ESDB) Save(events []core.Event) error

Save persists events to the database