storage

package

v0.0.2 Latest Latest Go to latest Published: Aug 6, 2025 License: MIT Imports: 6 Imported by: 0

Details

Package storage provides event storage implementations.

This section is empty.

This section is empty.

This section is empty.

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

MemoryStorage implements EventSink using in-memory storage. This is suitable for development and small-scale deployments.

func NewMemoryStorage() *MemoryStorage

NewMemoryStorage creates a new in-memory event storage.

func (s *MemoryStorage) Cleanup(maxAge time.Duration)

Cleanup removes old events (for memory management).

func (s *MemoryStorage) Count(ctx context.Context, query core.Query) (int, error)

Count returns the number of events matching the criteria.

func (s *MemoryStorage) Query(ctx context.Context, query core.Query) ([]core.Event, error)

Query retrieves events matching the criteria.

func (s *MemoryStorage) Store(ctx context.Context, event core.Event) error

Store saves an event to memory.

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

StorageWithSink wraps a storage implementation and automatically stores events from a stream.

func NewStorageWithSink(storage core.EventSink, stream core.EventStream) *StorageWithSink

NewStorageWithSink creates storage that automatically consumes from an event stream.

func (s *StorageWithSink) Close() error

Close stops consuming events.

func (s *StorageWithSink) Count(ctx context.Context, query core.Query) (int, error)

Count implements EventSink.

func (s *StorageWithSink) Query(ctx context.Context, query core.Query) ([]core.Event, error)

Query implements EventSink.

func (s *StorageWithSink) Store(ctx context.Context, event core.Event) error

Store implements EventSink.