eventstore

Documentation

Index

• type Eventstore
  • func NewEventstore(client *database.DB) *Eventstore
  • func (es *Eventstore) FillFields(ctx context.Context, events ...eventstore.FillFieldsEvent) (err error)
  • func (es *Eventstore) Health(ctx context.Context) error
  • func (es *Eventstore) Push(ctx context.Context, commands ...eventstore.Command) (events []eventstore.Event, err error)
  • func (es *Eventstore) Search(ctx context.Context, conditions ...map[eventstore.FieldType]any) (result []*eventstore.SearchResult, err error)
• type Payload
  • func (data *Payload) Scan(value interface{}) error
  • func (data Payload) Value() (driver.Value, error)

Types

type Eventstore

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

func NewEventstore

func NewEventstore(client *database.DB) *Eventstore

func (*Eventstore) FillFields

func (es *Eventstore) FillFields(ctx context.Context, events ...eventstore.FillFieldsEvent) (err error)

func (*Eventstore) Health

func (es *Eventstore) Health(ctx context.Context) error

func (*Eventstore) Push

func (es *Eventstore) Push(ctx context.Context, commands ...eventstore.Command) (events []eventstore.Event, err error)

func (*Eventstore) Search

func (es *Eventstore) Search(ctx context.Context, conditions ...map[eventstore.FieldType]any) (result []*eventstore.SearchResult, err error)

Search implements the eventstore.Search method

type Payload

type Payload []byte

Payload represents a byte array that may be null. Payload implements the sql.Scanner interface

func (*Payload) Scan

func (data *Payload) Scan(value interface{}) error

Scan implements the Scanner interface.

func (Payload) Value

func (data Payload) Value() (driver.Value, error)

Value implements the driver Valuer interface.