physalis

type Event[EV any] struct {
	Payload   EV    `cbor:"1,keyasint"`
	Timestamp int64 `cbor:"2,keyasint"`
}

type KType interface {
	~int32 | ~int64 | ~uint32 | ~uint64 | ~string
}

type Physalis[EV any] struct {
	// contains filtered or unexported fields
}

type Reducer[ST any, EV any] interface {
	Version() string
	// Возвращает
	// 1. ключ группы событий, если он пустой то событие пропускается (SkipEvent)
	// 2. опционально может вернуть другое событие, которое будет использовано вместо текущего. Менять исходное нельзя! Оно шариться между всеми редюссерами!
	Prepare(*Event[EV]) (string, *Event[EV])
	Apply(runtime *ReducerRuntime, state *ST, groupKey string,
		evs iter.Seq2[uint64, *Event[EV]]) *ST
}

type ReducerReader[ST any] struct {
	// contains filtered or unexported fields
}

type ReducerRegistry[EV any] struct {
	// contains filtered or unexported fields
}

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

type SortedKV[K KType, V any] interface {
	Get(key K) *V
	Delete(key K)
	Put(key K, data *V)
	AscendRange(greaterOrEqual, lessThan K) iter.Seq2[K, *V]
	Ascend() iter.Seq2[K, *V]
	Descend() iter.Seq2[K, *V]
	AscendGreaterOrEqual(greaterOrEqual K) iter.Seq2[K, *V]
	AscendLessThan(lessThan K) iter.Seq2[K, *V]
	DescendRange(lessOrEqual, greaterThan K) iter.Seq2[K, *V]
	DescendGreaterThan(greaterThan K) iter.Seq2[K, *V]
	DescendLessOrEqual(lessOrEqual K) iter.Seq2[K, *V]
}

type SortedKVView[K KType, V any] interface {
	Get(key K) *V
	AscendRange(greaterOrEqual, lessThan K) iter.Seq2[K, *V]
	Ascend() iter.Seq2[K, *V]
	Descend() iter.Seq2[K, *V]
	AscendGreaterOrEqual(greaterOrEqual K) iter.Seq2[K, *V]
	AscendLessThan(lessThan K) iter.Seq2[K, *V]
	DescendRange(lessOrEqual, greaterThan K) iter.Seq2[K, *V]
	DescendGreaterThan(greaterThan K) iter.Seq2[K, *V]
	DescendLessOrEqual(lessOrEqual K) iter.Seq2[K, *V]
}

type Transaction[EV any] struct {
	Events      []*Event[EV]
	BlobStorage map[string][]byte // nil - для удаления
}