memory

package
v2.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 2, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package memory is the in-memory ManifestStore and OperationalStore adapter used by tests and by the conformance suite. It has no persistence: state lives only as long as the process.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessStore added in v2.2.0 

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

AccessStore is the in-memory adapter for store.AccessStore. One lock covers the list, which is all the atomicity the port asks for.

func NewAccessStore added in v2.2.0 

func NewAccessStore() *AccessStore

NewAccessStore returns an empty access list.

func (*AccessStore) DeletePerson added in v2.2.0 

func (s *AccessStore) DeletePerson(_ context.Context, email string) error

func (*AccessStore) GetPerson added in v2.2.0 

func (s *AccessStore) GetPerson(_ context.Context, email string) (store.Person, error)

func (*AccessStore) GrantPerson added in v2.2.0 

func (s *AccessStore) GrantPerson(_ context.Context, p store.Person) (store.Person, error)

func (*AccessStore) ListPeople added in v2.2.0 

func (s *AccessStore) ListPeople(context.Context) ([]store.Person, error)

func (*AccessStore) RecordSignIn added in v2.2.0 

func (s *AccessStore) RecordSignIn(_ context.Context, in store.SignIn) (store.Person, error)

type ApplyJournal 

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

ApplyJournal is the in-memory adapter for store.ApplyJournal.

func NewApplyJournal 

func NewApplyJournal() *ApplyJournal

NewApplyJournal creates a new in-memory ApplyJournal.

func (*ApplyJournal) ListUnapplied 

func (j *ApplyJournal) ListUnapplied(_ context.Context) ([]store.ApplyUnit, error)

ListUnapplied returns every unit with applied=false, oldest first.

func (*ApplyJournal) MarkApplied 

func (j *ApplyJournal) MarkApplied(_ context.Context, unitID string) error

MarkApplied marks a unit as applied.

func (*ApplyJournal) PruneOld 

func (j *ApplyJournal) PruneOld(_ context.Context, keepCount int) error

PruneOld removes applied units older than keepCount (keeps the most recent). A keepCount of 0 or less means unlimited (no pruning).

func (*ApplyJournal) PutUnit 

func (j *ApplyJournal) PutUnit(_ context.Context, unit store.ApplyUnit) error

PutUnit writes a new unit with applied=false.

func (*ApplyJournal) WithinTransaction 

func (j *ApplyJournal) WithinTransaction(ctx context.Context, fn func(ctx context.Context, tx store.ApplyJournal) error) error

WithinTransaction runs fn. Memory adapter doesn't need true transactions.

type BundleStore 

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

BundleStore keeps handoff bundles in memory: what a test needs to prove a handoff recorded what it rendered, without a directory.

func NewBundleStore 

func NewBundleStore() *BundleStore

NewBundleStore returns an empty BundleStore.

func (*BundleStore) Get 

func (b *BundleStore) Get(location, name string) ([]byte, bool)

Get returns one stored file, for tests.

func (*BundleStore) PutBundle 

func (b *BundleStore) PutBundle(_ context.Context, projectID string, version int, files map[string][]byte) (store.Bundle, error)

PutBundle stores files under "handoff/<project>/v<n>".

type DocStore 

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

DocStore is the in-memory adapter for store.DocStore. One lock covers every document, which is all the atomicity the port asks for.

func NewDocStore 

func NewDocStore() *DocStore

NewDocStore returns an empty DocStore.

func (*DocStore) Append 

func (s *DocStore) Append(_ context.Context, docID string, data []byte) (int64, error)

func (*DocStore) Compact 

func (s *DocStore) Compact(_ context.Context, docID string, snapshot []byte, upTo int64) error

Compact ignores a compaction older than the stored one, whose snapshot lacks chunks that are already gone.

func (*DocStore) Create 

func (s *DocStore) Create(_ context.Context, kind, id, docID string, snapshot []byte) (string, bool, error)

func (*DocStore) DocumentFor 

func (s *DocStore) DocumentFor(_ context.Context, kind, id string) (string, error)

func (*DocStore) Load 

func (s *DocStore) Load(_ context.Context, docID string) ([]byte, []store.Chunk, error)

func (*DocStore) ManifestFor 

func (s *DocStore) ManifestFor(_ context.Context, docID string) (string, string, error)

func (*DocStore) Since 

func (s *DocStore) Since(_ context.Context, docID string, after int64) ([]store.Chunk, error)

type ManifestStore 

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

ManifestStore is the in-memory adapter for store.ManifestStore.

func NewManifestStore 

func NewManifestStore() *ManifestStore

func (*ManifestStore) Counts 

func (m *ManifestStore) Counts(_ context.Context) (map[string]int, error)

func (*ManifestStore) Exclude 

func (m *ManifestStore) Exclude(_ context.Context, kind, id, name, reason, operator string) error

Exclude records an exclusion for a manifest.

func (*ManifestStore) GetCurrent 

func (m *ManifestStore) GetCurrent(_ context.Context, kind, id string) (store.Version, bool, error)

func (*ManifestStore) GetVersion 

func (m *ManifestStore) GetVersion(_ context.Context, kind, id string, number int) (store.Version, bool, error)

func (*ManifestStore) GetWorking 

func (m *ManifestStore) GetWorking(_ context.Context, kind, id string) ([]byte, bool, error)

GetWorking returns a manifest's working copy (autosave without versioning). Returns found=false when none exists.

func (*ManifestStore) IndexReferences 

func (m *ManifestStore) IndexReferences(_ context.Context, fromKind, fromID string, refs []store.Ref) error

func (*ManifestStore) ListAllVersions 

func (m *ManifestStore) ListAllVersions(_ context.Context, limit int, cursor string) ([]store.Version, string, error)

func (*ManifestStore) ListExcluded 

func (m *ManifestStore) ListExcluded(_ context.Context) ([]store.Exclusion, error)

ListExcluded returns every excluded manifest, newest first.

func (*ManifestStore) ListIDs 

func (m *ManifestStore) ListIDs(_ context.Context, kind string) ([]string, error)

func (*ManifestStore) ListReferencedBy 

func (m *ManifestStore) ListReferencedBy(_ context.Context, fromKind, fromID string) ([]store.Ref, error)

func (*ManifestStore) ListReferencing 

func (m *ManifestStore) ListReferencing(_ context.Context, toKind, toID string) ([]store.Summary, error)

func (*ManifestStore) ListSummaries 

func (m *ManifestStore) ListSummaries(_ context.Context, kind, query string, refs []store.RefFilter) ([]store.Summary, error)

func (*ManifestStore) ListVersions 

func (m *ManifestStore) ListVersions(_ context.Context, kind, id string) ([]store.Version, error)

func (*ManifestStore) PutVersion 

func (m *ManifestStore) PutVersion(_ context.Context, v store.Version) error

func (*ManifestStore) PutWorking 

func (m *ManifestStore) PutWorking(_ context.Context, kind, id string, yamlBytes []byte) error

PutWorking stores a manifest's working copy (autosave without versioning).

func (*ManifestStore) Recover 

func (m *ManifestStore) Recover(_ context.Context, kind, id, reason, operator string) error

Recover deletes an exclusion record.

func (*ManifestStore) WithinTransaction 

func (m *ManifestStore) WithinTransaction(ctx context.Context, fn func(ctx context.Context, tx store.ManifestStore) error) error

WithinTransaction is a best-effort transaction: the in-memory store holds one global lock for the duration of fn, and rolls back by snapshotting and restoring state if fn returns an error. This gives the same all-or-nothing guarantee the SQLite adapter gives, without needing a real transaction manager for a map.

type OperationalStore 

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

OperationalStore is the in-memory adapter for store.OperationalStore.

func NewOperationalStore 

func NewOperationalStore() *OperationalStore

func (*OperationalStore) ListProjectStateHistory 

func (o *OperationalStore) ListProjectStateHistory(_ context.Context, projectID string) ([]store.ProjectStateEntry, error)

func (*OperationalStore) PutProjectStateTransition 

func (o *OperationalStore) PutProjectStateTransition(_ context.Context, e store.ProjectStateEntry) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.