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 ¶
- type ApplyJournal
- func (j *ApplyJournal) ListUnapplied(_ context.Context) ([]store.ApplyUnit, error)
- func (j *ApplyJournal) MarkApplied(_ context.Context, unitID string) error
- func (j *ApplyJournal) PruneOld(_ context.Context, keepCount int) error
- func (j *ApplyJournal) PutUnit(_ context.Context, unit store.ApplyUnit) error
- func (j *ApplyJournal) WithinTransaction(ctx context.Context, fn func(ctx context.Context, tx store.ApplyJournal) error) error
- type BundleStore
- type DocStore
- func (s *DocStore) Append(_ context.Context, docID string, data []byte) (int64, error)
- func (s *DocStore) Compact(_ context.Context, docID string, snapshot []byte, upTo int64) error
- func (s *DocStore) Create(_ context.Context, kind, id, docID string, snapshot []byte) (string, bool, error)
- func (s *DocStore) DocumentFor(_ context.Context, kind, id string) (string, error)
- func (s *DocStore) Load(_ context.Context, docID string) ([]byte, []store.Chunk, error)
- func (s *DocStore) ManifestFor(_ context.Context, docID string) (string, string, error)
- func (s *DocStore) Since(_ context.Context, docID string, after int64) ([]store.Chunk, error)
- type ManifestStore
- func (m *ManifestStore) Counts(_ context.Context) (map[string]int, error)
- func (m *ManifestStore) Exclude(_ context.Context, kind, id, name, reason, operator string) error
- func (m *ManifestStore) GetCurrent(_ context.Context, kind, id string) (store.Version, bool, error)
- func (m *ManifestStore) GetVersion(_ context.Context, kind, id string, number int) (store.Version, bool, error)
- func (m *ManifestStore) GetWorking(_ context.Context, kind, id string) ([]byte, bool, error)
- func (m *ManifestStore) IndexReferences(_ context.Context, fromKind, fromID string, refs []store.Ref) error
- func (m *ManifestStore) ListAllVersions(_ context.Context, limit int, cursor string) ([]store.Version, string, error)
- func (m *ManifestStore) ListExcluded(_ context.Context) ([]store.Exclusion, error)
- func (m *ManifestStore) ListIDs(_ context.Context, kind string) ([]string, error)
- func (m *ManifestStore) ListReferencedBy(_ context.Context, fromKind, fromID string) ([]store.Ref, error)
- func (m *ManifestStore) ListReferencing(_ context.Context, toKind, toID string) ([]store.Summary, error)
- func (m *ManifestStore) ListSummaries(_ context.Context, kind, query string, refs []store.RefFilter) ([]store.Summary, error)
- func (m *ManifestStore) ListVersions(_ context.Context, kind, id string) ([]store.Version, error)
- func (m *ManifestStore) PutVersion(_ context.Context, v store.Version) error
- func (m *ManifestStore) PutWorking(_ context.Context, kind, id string, yamlBytes []byte) error
- func (m *ManifestStore) Recover(_ context.Context, kind, id, reason, operator string) error
- func (m *ManifestStore) WithinTransaction(ctx context.Context, ...) error
- type OperationalStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 ¶
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) 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.
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 (*DocStore) Compact ¶
Compact ignores a compaction older than the stored one, whose snapshot lacks chunks that are already gone.
func (*DocStore) DocumentFor ¶
func (*DocStore) ManifestFor ¶
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) 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 (*ManifestStore) GetVersion ¶
func (*ManifestStore) GetWorking ¶
GetWorking returns a manifest's working copy (autosave without versioning). Returns found=false when none exists.
func (*ManifestStore) IndexReferences ¶
func (*ManifestStore) ListAllVersions ¶
func (*ManifestStore) ListExcluded ¶
ListExcluded returns every excluded manifest, newest first.
func (*ManifestStore) ListReferencedBy ¶
func (*ManifestStore) ListReferencing ¶
func (*ManifestStore) ListSummaries ¶
func (*ManifestStore) ListVersions ¶
func (*ManifestStore) PutVersion ¶
func (*ManifestStore) PutWorking ¶
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