kurrent

Documentation

Index

• type Iterator
  • func (i *Iterator) Close()
  • func (i *Iterator) Next() bool
  • func (i *Iterator) Value() (core.Event, error)
• type Kurrent
  • func Open(client *kurrentdb.Client, jsonSerializer bool) *Kurrent
  • func (es *Kurrent) Get(ctx context.Context, id string, aggregateType string, ...) (core.Iterator, error)
  • func (es *Kurrent) Save(events []core.Event) error

Types

type Iterator

type Iterator struct {
	Stream *kurrentdb.ReadStream
	// contains filtered or unexported fields
}

func (*Iterator) Close

func (i *Iterator) Close()

Close closes the stream

func (*Iterator) Next

func (i *Iterator) Next() bool

Next steps to the next event in the stream

func (*Iterator) Value

func (i *Iterator) Value() (core.Event, error)

Value returns the event from the stream

type Kurrent

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

Kurrent is the event store handler

func Open

func Open(client *kurrentdb.Client, jsonSerializer bool) *Kurrent

Open binds the event store db client

func (*Kurrent) Get

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

func (*Kurrent) Save

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

Save persists events to the database