Documentation
¶
Overview ¶
Package reflectionstore persists bounded learning proposals in a crash-safe, principal/project-partitioned document.
Index ¶
- type Store
- func (s *Store) ClaimDecision(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, ...) (learning.ProposalRecord, error)
- func (s *Store) ClaimPromotion(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, ...) (learning.ProposalRecord, error)
- func (s *Store) Finalize(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, ...) (learning.ProposalRecord, error)
- func (s *Store) Get(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID) (r learning.ProposalRecord, found bool, err error)
- func (s *Store) GetManifest(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID) (manifest learning.MaterializationManifest, found bool, err error)
- func (s *Store) LinkSkillDraft(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, ...) (learning.ProposalRecord, error)
- func (s *Store) List(ctx context.Context, p learning.ProposalPartition, o learning.ProposalList) (page learning.ProposalPage, err error)
- func (s *Store) Promoting(ctx context.Context) (records []learning.ProposalRecord, err error)
- func (s *Store) StageBatch(ctx context.Context, p learning.ProposalPartition, input string, ...) ([]learning.ProposalRecord, error)
- func (s *Store) StageBatchManifest(ctx context.Context, p learning.ProposalPartition, ...) ([]learning.ProposalRecord, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store is a flocked, crash-safe proposal repository.
func (*Store) ClaimDecision ¶
func (s *Store) ClaimDecision(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, v learning.ProposalVersion, x learning.Decision) (learning.ProposalRecord, error)
ClaimDecision records a bounded decision under proposal CAS.
func (*Store) ClaimPromotion ¶
func (s *Store) ClaimPromotion(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, v learning.ProposalVersion) (learning.ProposalRecord, error)
ClaimPromotion atomically moves a staged proposal to promoting.
func (*Store) Finalize ¶
func (s *Store) Finalize(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, v learning.ProposalVersion, status learning.ProposalStatus, receipt *learning.PromotionReceipt, x learning.Decision) (learning.ProposalRecord, error)
Finalize records a terminal promotion, reconciliation, or undo outcome.
func (*Store) Get ¶
func (s *Store) Get(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID) (r learning.ProposalRecord, found bool, err error)
Get returns one proposal from its exact partition.
func (*Store) GetManifest ¶ added in v0.0.26
func (s *Store) GetManifest(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID) (manifest learning.MaterializationManifest, found bool, err error)
GetManifest returns an owned copy of the immutable manifest for a staged v1 proposal.
func (*Store) LinkSkillDraft ¶
func (s *Store) LinkSkillDraft(ctx context.Context, p learning.ProposalPartition, id learning.ProposalID, v learning.ProposalVersion, skillID learning.SkillID, x learning.Decision) (learning.ProposalRecord, error)
LinkSkillDraft atomically links an explicitly materialized historical procedure.
func (*Store) List ¶
func (s *Store) List(ctx context.Context, p learning.ProposalPartition, o learning.ProposalList) (page learning.ProposalPage, err error)
List returns one bounded proposal page within a partition.
func (*Store) Promoting ¶
Promoting returns durable in-flight records for startup-only crash reconciliation.
func (*Store) StageBatch ¶
func (s *Store) StageBatch(ctx context.Context, p learning.ProposalPartition, input string, cs []learning.Candidate, signals []learning.Signal) ([]learning.ProposalRecord, error)
StageBatch atomically and idempotently stages bounded candidates.
func (*Store) StageBatchManifest ¶ added in v0.0.26
func (s *Store) StageBatchManifest(ctx context.Context, p learning.ProposalPartition, manifest learning.MaterializationManifest, cs []learning.Candidate, signals []learning.Signal) ([]learning.ProposalRecord, error)
StageBatchManifest atomically persists the complete selected-evidence manifest with every new proposal.
Source Files