memory

package

v0.9.1 Latest Latest Go to latest Published: Nov 29, 2025 License: MPL-2.0 Imports: 3 Imported by: 2

Details

This section is empty.

This section is empty.

This section is empty.

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

Memory is a handler for event streaming

func Create() *Memory

Create in memory event store

func (m *Memory) All(start core.Version, count uint64) core.Fetcher

All iterate over all events in GlobalEvents order

func (e *Memory) Close()

Close does nothing

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

Get aggregate events

func (e *Memory) Save(events []core.Event) error

Save an aggregate (its events)