memory

Documentation

Overview

Package memory is an in-memory Store, for tests and for the M6 vertical slice.

An adapter, so the constructs the domain forbids are legitimate here: `sync`, `context`, mutable state. That asymmetry is the architecture working — a purity rule that fired in this package would be a rule nobody kept.

It is deliberately not a general-purpose store. There is no query language, no index and no persistence, because the slice exists to prove the boundaries hold, not to be a database.

Index

• type Store
  • func NewStore() *Store
  • func (s *Store) Append(_ context.Context, name string, expect app.Expectation, ...) (domain.Ref, error)
  • func (s *Store) Load(_ context.Context, name string) (domain.Stream, error)
  • func (s *Store) Serialise(ctx context.Context, name string, fn func(context.Context, app.Store) error) error

Types

type Store

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

Store keeps streams in memory.

func NewStore

func NewStore() *Store

NewStore creates an empty store.

func (*Store) Append

func (s *Store) Append(
	_ context.Context,
	name string,
	expect app.Expectation,
	envelope domain.Envelope,
	kind domain.Kind,
	payload domain.Payload,
) (domain.Ref, error)

Append records one fact against the authoritative stream and returns the ref the store assigned (ADR-0034).

This is the whole point of the port change. The sequence comes from the length of the stream *held here*, under the lock, rather than from whatever length a caller happened to read — so two concurrent appends receive consecutive refs instead of the same one.

The stream is created on first append: a stream is the facts in it, and there is nothing to declare in advance.

func (*Store) Load

func (s *Store) Load(_ context.Context, name string) (domain.Stream, error)

Load returns a stream, or app.ErrStreamNotFound.

func (*Store) Serialise

func (s *Store) Serialise(
	ctx context.Context,
	name string,
	fn func(context.Context, app.Store) error,
) error

Serialise runs fn holding the write region for `name` (ADR-0041).

For an in-memory store, "every writer holding this store" is every writer that shares the process, because a second process cannot reach this map. That makes the guarantee complete here rather than partial — the same sentence that is a limitation for a durable adapter.