store

type AggregateMetadata[K eventsourcing.ID] struct {
	Type      eventsourcing.Kind
	ID        K
	Version   uint32
	UpdatedAt time.Time
}

type EventBus[K eventsourcing.ID] struct {
	// contains filtered or unexported fields
}

type EventBusMW[K eventsourcing.ID] func(Subscription[K]) Subscription[K]

type Filter struct {
	AggregateKinds []eventsourcing.Kind
	// Metadata filters on top of metadata. Every key of the map is ANDed with every OR of the values
	// eg: [{"geo": "EU"}, {"geo": "USA"}, {"membership": "prime"}] equals to:  geo IN ("EU", "USA") AND membership = "prime"
	Metadata MetadataFilter
	Splits   uint32
	SplitIDs []uint32
}

type FilterOption func(*Filter)

type InTxHandler[K eventsourcing.ID] func(context.Context, *eventsourcing.Event[K]) error

type KVRStore interface {
	// Get retrieves the stored value for a key.
	// If the a resume key is not found it return ErrResumeTokenNotFound as an error
	Get(ctx context.Context, key string) (string, error)
}

type KVStore interface {
	KVRStore
	KVWStore
}

type KVWStore interface {
	Put(ctx context.Context, key string, token string) error
}

type Metadata struct {
	Key   string
	Value string
}

type MetadataFilter []*MetadataKVs

type MetadataHook[K eventsourcing.ID] func(context.Context) eventsourcing.Metadata

type MetadataKVs struct {
	Key    string
	Values []string
}

type NilString string

type Row map[string]interface{}

type Subscriber[K eventsourcing.ID] interface {
	Subscribe(string, Subscription[K])
}

type Subscription[K eventsourcing.ID] func(context.Context, *eventsourcing.Event[K]) error