inmemory

Documentation

Index

• type Storage
  • func New() *Storage
  • func (s *Storage) GetEntityIDs(ctx context.Context, entityType string, storeEntityID string, limit int64) ([]string, string, error)
  • func (s *Storage) Read(ctx context.Context, entityType string, entityID string, eventNumber int64) iter.Seq2[es.Event, error]
  • func (s *Storage) Register(entityType string, contentTypes ...es.Content) error
  • func (s *Storage) StartPublish(ctx context.Context, writer es.Writer) error
  • func (s *Storage) Write(ctx context.Context, entityType string, events iter.Seq2[es.Event, error]) error
• type Writer

Types

type Storage

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

func New

func New() *Storage

func (*Storage) GetEntityIDs

func (s *Storage) GetEntityIDs(ctx context.Context, entityType string, storeEntityID string, limit int64) ([]string, string, error)

func (*Storage) Read

func (s *Storage) Read(ctx context.Context, entityType string, entityID string, eventNumber int64) iter.Seq2[es.Event, error]

func (*Storage) Register

func (s *Storage) Register(entityType string, contentTypes ...es.Content) error

func (*Storage) StartPublish

func (s *Storage) StartPublish(ctx context.Context, writer es.Writer) error

func (*Storage) Write

func (s *Storage) Write(ctx context.Context, entityType string, events iter.Seq2[es.Event, error]) error

type Writer

type Writer interface {
	Write(ctx context.Context, entityType string, events iter.Seq2[es.Event, error]) error
}