xevent

Documentation

Index

• func FilterAggregate(events []event.Event, a aggregate.Aggregate) []event.Event
• func Make(name string, data any, n int, opts ...MakeOption) []event.Event
• func Shuffle[D any](events []event.Of[D]) []event.Of[D]
• type MakeOption
  • func ForAggregate(as ...aggregate.Aggregate) MakeOption
  • func SkipVersion(v ...int) MakeOption

Functions

func FilterAggregate

func FilterAggregate(events []event.Event, a aggregate.Aggregate) []event.Event

FilterAggregate filters events and returns only those that belong to the Aggregate a.

func Make

func Make(name string, data any, n int, opts ...MakeOption) []event.Event

Make returns n events with the specified name and data.

func Shuffle

func Shuffle[D any](events []event.Of[D]) []event.Of[D]

Shuffle shuffles events and returns the shuffled slice.

Types

type MakeOption

type MakeOption func(*makeConfig)

MakeOption is an option for Make.

func ForAggregate

func ForAggregate(as ...aggregate.Aggregate) MakeOption

ForAggregate returns a MakeOption that sets the aggregate for events returne by Make.

func SkipVersion

func SkipVersion(v ...int) MakeOption

SkipVersion returns a MakeOption that emulates a consistency error by skipping the specified aggregate versions when creating the events. This option only has an effect when used together with ForAggregate.