Help us shape the future of Go! Take the 2026 Go Developer Survey

services

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2026 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Service 

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

func New 

func New(l model.Ledger, a model.Authorizer, e model.EvidenceStore) (*Service, error)

func NewWithAudit 

func NewWithAudit(l model.Ledger, a model.Authorizer, e model.EvidenceStore, options model.AuditOptions) (*Service, error)

func NewWithOptions 

func NewWithOptions(l model.Ledger, a model.Authorizer, e model.EvidenceStore, o model.EngineOptions) (*Service, error)

func NewWithReads 

func NewWithReads(l model.Ledger, a model.Authorizer, e model.EvidenceStore, options model.ReadOptions) (*Service, error)

func NewWithRetrieval 

func NewWithRetrieval(l model.Ledger, a model.Authorizer, e model.EvidenceStore, options model.RetrievalOptions) (*Service, error)

func (*Service) AcceptFact 

func (s *Service) AcceptFact(ctx context.Context, c model.Caller, r model.Approval) (observationResult model.CommitResult, observationErr error)

func (*Service) AcceptMemory 

func (s *Service) AcceptMemory(ctx context.Context, c model.Caller, r model.Approval) (observationResult model.CommitResult, observationErr error)

func (*Service) ApproveFact 

func (s *Service) ApproveFact(ctx context.Context, c model.Caller, r model.Approval) (observationResult model.CommitResult, observationErr error)

func (*Service) ApproveMemory 

func (s *Service) ApproveMemory(ctx context.Context, c model.Caller, r model.Approval) (observationResult model.CommitResult, observationErr error)

func (*Service) CleanupProjection 

func (s *Service) CleanupProjection(ctx context.Context, c model.Caller, r model.ProjectionCleanupRequest) (model.CommitResult, error)

func (*Service) CreateFactSnapshot 

func (s *Service) CreateFactSnapshot(ctx context.Context, c model.Caller, r model.FactSnapshotRequest) (model.FactSnapshot, error)

func (*Service) DisposeAttestation 

func (s *Service) DisposeAttestation(ctx context.Context, c model.Caller, r model.AttestationDisposalRequest) (model.CommitResult, error)

func (*Service) DisposeBatch 

func (s *Service) DisposeBatch(ctx context.Context, c model.Caller, r model.DisposalBatchRequest) (model.CommitResult, error)

func (*Service) DisposeContext 

func (s *Service) DisposeContext(ctx context.Context, c model.Caller, r model.ContextDisposalRequest) (model.CommitResult, error)

func (*Service) DisposeConversation 

func (s *Service) DisposeConversation(ctx context.Context, c model.Caller, r model.ConversationDisposalRequest) (model.CommitResult, error)

func (*Service) DisposeEvidence 

func (s *Service) DisposeEvidence(ctx context.Context, c model.Caller, r model.EvidenceDisposalRequest) (model.CommitResult, error)

func (*Service) DisposeExtraction 

func (s *Service) DisposeExtraction(ctx context.Context, c model.Caller, r model.ExtractionDisposalRequest) (model.CommitResult, error)

func (*Service) DisposeOrphanEvidence 

func (s *Service) DisposeOrphanEvidence(ctx context.Context, c model.Caller, r model.OrphanEvidenceDisposalRequest) (model.CommitResult, error)

func (*Service) DisposeSnapshot 

func (s *Service) DisposeSnapshot(ctx context.Context, c model.Caller, r model.SnapshotDisposalRequest) (model.CommitResult, error)

func (*Service) DisposeVersion 

func (s *Service) DisposeVersion(ctx context.Context, c model.Caller, r model.VersionDisposalRequest) (model.CommitResult, error)

func (*Service) DisputeFact 

func (s *Service) DisputeFact(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) DisputeMemory 

func (s *Service) DisputeMemory(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) GetAuditExport 

func (s *Service) GetAuditExport(ctx context.Context, c model.Caller, q model.AuditExportQuery) (model.AuditExportResult, error)

func (*Service) GetCalculationReceipt 

func (s *Service) GetCalculationReceipt(ctx context.Context, c model.Caller, q model.CalculationQuery) (model.CalculationRecord, error)

func (*Service) GetContextManifest 

func (s *Service) GetContextManifest(ctx context.Context, c model.Caller, q model.ContextQuery) (model.ContextManifest, error)

func (*Service) GetConversation 

func (s *Service) GetConversation(ctx context.Context, c model.Caller, q model.ConversationQuery) (model.ConversationRecord, error)

func (*Service) GetDecisionReceipt 

func (s *Service) GetDecisionReceipt(ctx context.Context, c model.Caller, q model.DecisionQuery) (model.DecisionRecord, error)

func (*Service) GetEvidenceContent 

func (s *Service) GetEvidenceContent(ctx context.Context, c model.Caller, q model.EvidenceQuery) (observationResult model.EvidenceContent, observationErr error)

func (*Service) GetEvidenceMetadata 

func (s *Service) GetEvidenceMetadata(ctx context.Context, c model.Caller, q model.EvidenceQuery) (model.Evidence, error)

func (*Service) GetExtractionRun 

func (s *Service) GetExtractionRun(ctx context.Context, c model.Caller, q model.ExtractionRunQuery) (model.ExtractionRun, error)

func (*Service) GetFact 

func (s *Service) GetFact(ctx context.Context, c model.Caller, q model.FactQuery) (model.FactResult, error)

func (*Service) GetFactHistory 

func (s *Service) GetFactHistory(ctx context.Context, c model.Caller, q model.HistoryQuery) (model.HistoryResult, error)

func (*Service) GetFactSnapshot 

func (s *Service) GetFactSnapshot(ctx context.Context, c model.Caller, q model.SnapshotQuery) (model.FactSnapshot, error)

func (*Service) GetJob 

func (s *Service) GetJob(ctx context.Context, c model.Caller, q model.JobQuery) (model.JobStatus, error)

func (*Service) GetMemory 

func (s *Service) GetMemory(ctx context.Context, c model.Caller, q model.MemoryQuery) (model.MemoryResult, error)

func (*Service) GetMemoryHistory 

func (s *Service) GetMemoryHistory(ctx context.Context, c model.Caller, q model.HistoryPageQuery) (model.HistoryPage, error)

func (*Service) GetMemoryVersion 

func (s *Service) GetMemoryVersion(ctx context.Context, c model.Caller, q model.MemoryVersionQuery) (model.MemoryVersion, error)

func (*Service) GetProjectionStatus 

func (s *Service) GetProjectionStatus(ctx context.Context, c model.Caller, q model.ProjectionStatusQuery) (model.ProjectionStatus, error)

func (*Service) GetRetentionStatus 

func (s *Service) GetRetentionStatus(ctx context.Context, c model.Caller, q model.RetentionStatusQuery) (model.RetentionStatus, error)

func (*Service) GetScope 

func (s *Service) GetScope(ctx context.Context, c model.Caller, q model.IdentityQuery) (model.ScopeVersion, error)

func (*Service) GetSubject 

func (s *Service) GetSubject(ctx context.Context, c model.Caller, q model.IdentityQuery) (model.SubjectVersion, error)

func (*Service) IngestConversation 

func (s *Service) IngestConversation(ctx context.Context, c model.Caller, r model.ConversationRequest) (observationResult model.ConversationRecord, observationErr error)

func (*Service) ListChanges 

func (s *Service) ListChanges(ctx context.Context, c model.Caller, q model.ChangesQuery) (model.ChangesResult, error)

ListChanges is scope-authorized replay, not a consumer acknowledgement API.

func (*Service) ListFactHistory 

func (s *Service) ListFactHistory(ctx context.Context, c model.Caller, q model.HistoryPageQuery) (model.HistoryPage, error)

func (*Service) ListFacts 

func (s *Service) ListFacts(ctx context.Context, c model.Caller, q model.FactsQuery) (model.FactsPage, error)

func (*Service) ListMemories 

func (s *Service) ListMemories(ctx context.Context, c model.Caller, q model.MemoriesQuery) (model.MemoriesPage, error)

ListMemories pages through one scope's memory records in record-ID order and returns each one as GetMemory would resolve it at the pinned revision. Records without a version selected at ValidAt (pending, rejected, expired) and retracted memories are skipped, so a page may hold fewer than Limit items, or none, and still carry a NextPageToken.

func (*Service) LookupSubject 

func (s *Service) LookupSubject(ctx context.Context, c model.Caller, q model.SubjectLookupQuery) (model.SubjectVersion, error)

func (*Service) PlaceLegalHold 

func (s *Service) PlaceLegalHold(ctx context.Context, c model.Caller, r model.LegalHoldRequest) (model.CommitResult, error)

func (*Service) PlanExtractionChunks 

func (s *Service) PlanExtractionChunks(ctx context.Context, c model.Caller, q model.ExtractionChunkQuery) (model.ExtractionChunkPlan, error)

func (*Service) PrepareContext 

func (s *Service) PrepareContext(ctx context.Context, c model.Caller, r model.ContextRequest) (observationResult model.ContextManifest, observationErr error)

func (*Service) ProposeFact 

func (s *Service) ProposeFact(ctx context.Context, c model.Caller, r model.FactProposal) (observationResult model.CommitResult, observationErr error)

func (*Service) ProposeMemory 

func (s *Service) ProposeMemory(ctx context.Context, c model.Caller, r model.MemoryProposal) (observationResult model.CommitResult, observationErr error)

func (*Service) PutScope 

func (s *Service) PutScope(ctx context.Context, c model.Caller, r model.ScopeRequest) (model.CommitResult, error)

func (*Service) PutSubject 

func (s *Service) PutSubject(ctx context.Context, c model.Caller, r model.SubjectRequest) (model.CommitResult, error)

func (*Service) RebuildIndex 

func (s *Service) RebuildIndex(ctx context.Context, c model.Caller, r model.RebuildRequest) (model.RebuildStatus, error)

func (*Service) Recall 

func (s *Service) Recall(ctx context.Context, c model.Caller, q model.RecallRequest) (observationResult model.RecallResult, observationErr error)

func (*Service) RecallMemories 

func (s *Service) RecallMemories(ctx context.Context, c model.Caller, q model.RecallRequest) (observationResult model.MemoryRecallResult, observationErr error)

RecallMemories returns only ledger-revalidated eligible memory versions. Index bodies, dependency metadata and eligibility claims are never authoritative.

func (*Service) RecordAttestation 

func (s *Service) RecordAttestation(ctx context.Context, c model.Caller, r model.AttestationRequest) (model.CommitResult, error)

func (*Service) RecordCalculation 

func (s *Service) RecordCalculation(ctx context.Context, c model.Caller, r model.CalculationReceipt) (model.CalculationRecord, error)

func (*Service) RecordDecision 

func (s *Service) RecordDecision(ctx context.Context, c model.Caller, r model.DecisionReceipt) (model.DecisionRecord, error)

func (*Service) RecordDelegatedAttestation 

func (s *Service) RecordDelegatedAttestation(ctx context.Context, c model.Caller, r model.DelegatedAttestationRequest) (model.CommitResult, error)

func (*Service) RegisterAcceptancePolicy 

func (s *Service) RegisterAcceptancePolicy(ctx context.Context, c model.Caller, r model.PolicyRequest) (model.CommitResult, error)

func (*Service) RegisterEvidence 

func (s *Service) RegisterEvidence(ctx context.Context, c model.Caller, r model.EvidenceRequest) (model.CommitResult, error)

func (*Service) RegisterMemoryType 

func (s *Service) RegisterMemoryType(ctx context.Context, c model.Caller, r model.MemoryTypeRequest) (model.CommitResult, error)

func (*Service) RegisterPredicateVersion 

func (s *Service) RegisterPredicateVersion(ctx context.Context, c model.Caller, r model.PredicateRequest) (model.CommitResult, error)

func (*Service) RegisterRedactedEvidence 

func (s *Service) RegisterRedactedEvidence(ctx context.Context, c model.Caller, r model.RedactedEvidenceRequest) (model.CommitResult, error)

func (*Service) RegisterRetentionPolicy 

func (s *Service) RegisterRetentionPolicy(ctx context.Context, c model.Caller, r model.RetentionPolicyRequest) (model.CommitResult, error)

func (*Service) RejectFact 

func (s *Service) RejectFact(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) RejectMemory 

func (s *Service) RejectMemory(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) ReleaseLegalHold 

func (s *Service) ReleaseLegalHold(ctx context.Context, c model.Caller, r model.ReleaseLegalHoldRequest) (model.CommitResult, error)

func (*Service) ResolveDispute 

func (s *Service) ResolveDispute(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) ResolveMemoryDispute 

func (s *Service) ResolveMemoryDispute(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) RetractFact 

func (s *Service) RetractFact(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) RetractMemory 

func (s *Service) RetractMemory(ctx context.Context, c model.Caller, r model.LifecycleChange) (model.CommitResult, error)

func (*Service) RetryJob 

func (s *Service) RetryJob(ctx context.Context, c model.Caller, r model.JobRetryRequest) (model.JobStatus, error)

func (*Service) RunAuditExport 

func (s *Service) RunAuditExport(ctx context.Context, c model.Caller, q model.AuditExportQuery) (observationResult model.AuditExportResult, observationErr error)

RunAuditExport processes one durable request. The trusted worker must supply the original requester identity; permissions are checked again at execution. Failed/cancelled attempts are retried after the lease expires. No worker starts implicitly.

func (*Service) RunExtraction 

func (s *Service) RunExtraction(ctx context.Context, c model.Caller, r model.ExtractionRunRequest) (observationResult model.JobStatus, observationErr error)

func (*Service) ScanMemoryRefresh 

func (s *Service) ScanMemoryRefresh(ctx context.Context, c model.Caller, q model.MemoryRefreshScan) (model.MemoryRefreshScanResult, error)

ScanMemoryRefresh is a bounded operational scan over the immutable event-time dependency inventory. Each page independently authorizes source and target.

func (*Service) ScanOrphanEvidence 

func (s *Service) ScanOrphanEvidence(ctx context.Context, c model.Caller, q model.OrphanEvidenceQuery) ([]model.ObjectRef, error)

func (*Service) StartAuditExport 

func (s *Service) StartAuditExport(ctx context.Context, c model.Caller, r model.AuditExportRequest) (model.AuditExportResult, error)

func (*Service) StartExtraction 

func (s *Service) StartExtraction(ctx context.Context, c model.Caller, r model.ExtractionRequest) (model.JobStatus, error)

func (*Service) StartMemoryRefresh 

func (s *Service) StartMemoryRefresh(ctx context.Context, c model.Caller, r model.MemoryRefreshRequest) (model.JobStatus, error)

func (*Service) StartMemoryRefreshSweep 

func (s *Service) StartMemoryRefreshSweep(ctx context.Context, c model.Caller, r model.MemoryRefreshSweepRequest) (model.CommitResult, error)

func (*Service) SupersedeFact 

func (s *Service) SupersedeFact(ctx context.Context, c model.Caller, r model.Supersession) (model.CommitResult, error)

func (*Service) SupersedeMemory 

func (s *Service) SupersedeMemory(ctx context.Context, c model.Caller, r model.Supersession) (model.CommitResult, error)

func (*Service) WaitForProjection 

func (s *Service) WaitForProjection(ctx context.Context, c model.Caller, q model.ProjectionWaitRequest) (model.ProjectionReceipt, error)

func (*Service) WithdrawAttestation 

func (s *Service) WithdrawAttestation(ctx context.Context, c model.Caller, r model.Withdrawal) (model.CommitResult, 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.