Versions in this module Expand all Collapse all v1 v1.10.4 Nov 4, 2026 v1.10.3 Oct 30, 2026 v1.9.0 Oct 27, 2026 Changes in this version + const PrefixActivation + const PrefixAttempt + const PrefixCandidate + const PrefixDecision + const PrefixEvent + const PrefixExperiment + const PrefixHarness + const PrefixLesson + const PrefixTrial + const PrefixValidation + const PrefixVersion + var ErrBudgetExceeded = errors.New("cortex: optimization: budget exceeded") + var ErrConflict = errors.New("cortex: optimization: conflicting revision or content") + var ErrInactiveActivation = errors.New("cortex: optimization: activation is disabled") + var ErrIncompleteEvidence = errors.New("cortex: optimization: incomplete evidence") + var ErrInvalidSpec = errors.New("cortex: optimization: invalid specification") + var ErrNoEnvironment = errors.New("cortex: optimization: no trial environment") + var ErrNotFound = errors.New("cortex: optimization: resource not found") + var ErrPolicyDenied = errors.New("cortex: optimization: edit denied by policy") + var ErrStaleVersion = errors.New("cortex: optimization: stale version") + var ErrUnavailable = errors.New("cortex: optimization: capability unavailable") + var ErrUnknownAttempt = errors.New("cortex: optimization: attempt outcome unknown") + func ActivationChannel(channel string) (string, error) + func CanonicalVersion(version HarnessVersion) ([]byte, error) + func CriterionFailureKey(caseID string, repetition int, criterionID string) string + func DiscoveryLessonsDigest(value DiscoveryLessons) (string, error) + func ExecutionCompleted(record ExecutionRecord) bool + func ExecutionRunIDs(record ExecutionRecord) []id.ID + func LessonDigest(lesson Lesson) (string, error) + func ParseID(value string, prefix id.Prefix) (id.ID, error) + func ResolveIdentity(ctx context.Context, resolver IdentityResolver, actor IdentityRef, ...) (context.Context, context.CancelFunc, error) + func ScopeKey(scope cortex.Scope) (string, error) + func TrialEvidenceReady(trial Trial) bool + func ValidOpaqueKey(value string) bool + func ValidateActivationEvidence(change ActivationChange, experiment Experiment, decision Decision, ...) error + func ValidateControllerDecisionEvidence(parent Experiment, allocation ValidationAllocation, decision Decision, ...) error + func ValidateCreationBundle(selection CreationSelection, bundle ExperimentBundle) error + func ValidateDecisionEvidence(experiment Experiment, decision Decision, evidence []DecisionEvidence) error + func ValidateExecutionVersion(record ExecutionRecord, version HarnessVersion) error + func ValidateLessonDraft(lesson Lesson) error + func ValidateSpec(spec ExperimentSpec) error + func ValidateTaskDecision(experiment Experiment, decision Decision, evidence []DecisionEvidence) error + func ValidateTrialCapabilities(c IsolationCapabilities, reproducible bool) error + type Action string + const ActionActivate + const ActionAdoptArtifacts + const ActionCancel + const ActionCreate + const ActionDeactivate + const ActionDelete + const ActionPublishLesson + const ActionRead + const ActionReadArtifact + const ActionReconcileUsage + const ActionResolveController + const ActionResume + const ActionRetain + const ActionRetryPublication + const ActionRevokeLesson + const ActionRollback + const ActionRunActive + const ActionStart + type Activation struct + Actor IdentityRef + AgentID id.AgentID + Channel string + CreatedAt time.Time + Deactivated bool + DecisionID id.ID + ExpectedGeneration int64 + Generation int64 + ID id.ID + Kind HarnessKind + PolicyDigest string + Reason string + RollbackTo id.ID + Scope cortex.Scope + Version VersionRef + type ActivationChange struct + Actor IdentityRef + AgentID id.AgentID + Channel string + DecisionID id.ID + ExpectedGeneration int64 + ID id.ID + Kind HarnessKind + PolicyDigest string + Reason string + RollbackTo id.ID + Version VersionRef + type ActivationQuery struct + AgentID id.AgentID + Channel string + Kind HarnessKind + type ActivationRequest struct + AgentID id.AgentID + Channel string + DecisionID id.ID + ExpectedGeneration int64 + ID id.ID + Kind HarnessKind + Reason string + Version VersionRef + type ActiveControllerRequest struct + AgentID id.AgentID + Channel string + type ActiveOrchestrationRequest struct + AgentID id.AgentID + Channel string + Input string + type ActiveRunRequest struct + AgentID id.AgentID + Channel string + Input string + SessionID id.SessionID + type ApprovedCatalog struct + func NewApprovedCatalog(config ApprovedCatalogConfig) (*ApprovedCatalog, error) + func (c *ApprovedCatalog) Authorize(ctx context.Context, selection CreationSelection) error + func (c *ApprovedCatalog) AuthorizeChoice(ctx context.Context, choice CatalogChoice) error + func (c *ApprovedCatalog) List(ctx context.Context, target CatalogTarget) (CatalogResult, error) + func (c *ApprovedCatalog) Prepare(ctx context.Context, target CreationTarget) (ExperimentBundle, error) + type ApprovedCatalogConfig struct + Authorize func(context.Context, CatalogChoice) error + Choices []CatalogChoice + Prepare func(context.Context, CreationTarget) (ExperimentBundle, error) + type Artifact struct + CreatedAt time.Time + Data []byte + ExpiresAt time.Time + Ref ArtifactRef + func (artifact Artifact) Validate() error + type ArtifactAdopter interface + AdoptArtifacts func(context.Context, ArtifactAdoption) (ArtifactAdoptionReceipt, error) + type ArtifactAdoption struct + Actor IdentityRef + Request ArtifactAdoptionRequest + RequestDigest string + Scope cortex.Scope + type ArtifactAdoptionReceipt struct + AdoptedAt time.Time + Evidence ContentRef + ID string + RequestDigest string + type ArtifactAdoptionRequest struct + Artifacts []ArtifactRef + DecisionID id.ID + Destination ContentRef + ExperimentID id.ID + Key string + Policy ContentRef + TrialID id.ID + type ArtifactDeletion struct + Actor IdentityRef + Reason string + Ref ArtifactRef + RequestID string + type ArtifactReader interface + Get func(context.Context, ArtifactRef) (Artifact, error) + type ArtifactRef struct + AccessPolicy string + Digest string + ExperimentID id.ID + Kind string + MediaType string + Scope cortex.Scope + Size int64 + func ExecutionArtifactRefs(record ExecutionRecord) []ArtifactRef + func TrialArtifactRefs(trial Trial) []ArtifactRef + func (ref ArtifactRef) BindingDigest() (string, error) + func (ref ArtifactRef) Validate() error + type ArtifactRegistration struct + Actor IdentityRef + CreatedAt time.Time + ExpiresAt time.Time + Lease WorkLease + Ref ArtifactRef + type ArtifactRetention struct + CreatedAt time.Time + DeletedAt time.Time + Deletion *ArtifactDeletion + ExpiresAt time.Time + InvalidatedAt time.Time + Ref ArtifactRef + RegisteredAt time.Time + RegisteredBy IdentityRef + Revision int64 + type ArtifactStore interface + Delete func(context.Context, ArtifactRef) error + Put func(context.Context, Artifact) (ArtifactRef, error) + type ArtifactVerifier struct + func NewArtifactVerifier(reader ArtifactReader, maxBytes int64, now func() time.Time) (*ArtifactVerifier, error) + func (v *ArtifactVerifier) Verify(ctx context.Context, experimentID id.ID, ref ArtifactRef) (Artifact, error) + type Attempt struct + CompletedAt time.Time + Error string + Execution *ExecutionRecord + Fence Fence + ID id.ID + Receipt *EnvironmentReceipt + Replaces id.ID + RetryApproval *ContentRef + Revision int64 + StartedAt time.Time + State TrialState + Stop *StopReceipt + Usage Usage + type AttemptStatus struct + AttemptID id.ID + Execution *ExecutionRecord + ObservedAt time.Time + State TrialState + type Authorizer interface + Authorize func(context.Context, Action, Resource) error + type Budget struct + MaxTokens int64 + MaxUSDMicros int64 + PricingRevision string + TokenOnly bool + type CallMeter interface + BeginCall func(context.Context, UsageReservation, string) (Reservation, error) + type CallerIdentity interface + Current func(context.Context) (IdentityRef, error) + type Candidate struct + Accepted bool + CreatedAt time.Time + ExperimentID id.ID + ID id.ID + Origin CandidateOrigin + Parents []id.ID + PredictedEffects []string + Proposal Proposal + Rejection string + Round int + Version VersionRef + type CandidateOrigin string + const OriginComposed + const OriginDomain + const OriginGeneral + type Capability string + const CapabilityAccounting + const CapabilityController + const CapabilityControllerRouting + const CapabilityDurableStorage + const CapabilityEnvironment + const CapabilityEvaluation + const CapabilityLessons + const CapabilityProductionRouting + const CapabilityPublication + const CapabilityScopeMapping + const CapabilityStorage + const CapabilityWorker + func CapabilityNames() []Capability + type CapabilityProbe interface + Inspect func(context.Context, CapabilityTarget) (HostCapabilities, error) + type CapabilitySnapshot struct + EditableDimensions []EditKind + ObservedAt time.Time + Permissions map[Action]bool + TrialsReady bool + type CapabilityTarget struct + AgentID id.AgentID + Baseline VersionRef + Controller VersionRef + Evaluation ContentRef + ExperimentID id.ID + Mode Mode + Scope cortex.Scope + type CaseDelta struct + CaseDigest string + CaseID string + Criteria map[string]float64 + Delta float64 + Repetitions int + type CatalogChoice struct + Description string + Kind CatalogKind + Name string + Ref ContentRef + Scope cortex.Scope + type CatalogKind string + const CatalogAgent + const CatalogController + const CatalogEnvironment + const CatalogEvaluation + type CatalogProvider interface + AuthorizeChoice func(context.Context, CatalogChoice) error + List func(context.Context, CatalogTarget) (CatalogResult, error) + type CatalogQuery struct + Kind CatalogKind + type CatalogResult struct + Page Page[CatalogChoice] + Target CatalogTarget + type CatalogTarget struct + Actor IdentityRef + Cursor string + Kind CatalogKind + Limit int + Scope cortex.Scope + type ClaimRequest struct + Duration time.Duration + ExperimentID id.ID + Owner string + type CommandRequest struct + ExpectedRevision int64 + ExperimentID id.ID + IdempotencyKey string + type Comparison struct + BaselineIDs []string + BootstrapSamples int + BootstrapSeed uint64 + CandidateIDs []string + Cases []CaseDelta + Complete bool + Confidence float64 + CostRatio *float64 + LatencyRatio *float64 + LowerBound float64 + MeanDelta float64 + MissingReasons []string + PlanDigest string + Plans []ContentRef + ProtectedRegressions map[string]float64 + RequiredFailures []string + UpperBound float64 + func BuildControllerInconclusive(parent Experiment, allocation ValidationAllocation, ...) (*Comparison, error) + type ComparisonDetail struct + Decision *Decision + Evaluations ResourcePage[Evaluation] + ExperimentID id.ID + RetainedBaseline *RetainedBaseline + Revision int64 + type ComparisonRequest struct + BaselineIDs []string + CandidateIDs []string + Objective Objective + Plan EvaluationPlan + type Compatibility interface + Check func(context.Context, HarnessVersion) (CompatibilityReport, error) + type CompatibilityReport struct + Compatible bool + PolicyDigest string + Version VersionRef + type CompositionInput struct + Candidates []Candidate + type ContentRef struct + Digest string + Ref string + Revision string + func (ref ContentRef) Validate() error + type Controller interface + Compose func(context.Context, CompositionInput) (Proposal, error) + Propose func(context.Context, ProposalInput) ([]Proposal, error) + Reflect func(context.Context, ReflectionInput) ([]LessonDraft, error) + type ControllerComparisonGroup struct + BaselineIDs []string + CandidateIDs []string + Plan EvaluationPlan + type ControllerComparisonRequest struct + AllocationID id.ID + ExperimentID id.ID + Groups []ControllerComparisonGroup + Objective Objective + SpecDigest string + func BuildControllerComparison(parent Experiment, allocation ValidationAllocation, ...) (ControllerComparisonRequest, error) + type ControllerCompatibility struct + func NewControllerCompatibility(config ControllerCompatibilityConfig) (*ControllerCompatibility, error) + func (c *ControllerCompatibility) Check(ctx context.Context, version HarnessVersion) (CompatibilityReport, error) + type ControllerCompatibilityConfig struct + Controllers *ControllerFactory + Host Compatibility + type ControllerEvaluator interface + CompareControllers func(context.Context, ControllerComparisonRequest) (Comparison, error) + type ControllerEvidence struct + Experiment Experiment + Trials []DecisionEvidence + func ReadControllerEvidence(ctx context.Context, repo Repository, parent Experiment, ...) ([]ControllerEvidence, error) + type ControllerFactory struct + func NewControllerFactory(repo Repository, auth Authorizer, resolver IdentityResolver, ...) (*ControllerFactory, error) + func (f *ControllerFactory) ForWork(ctx context.Context, item WorkItem) (Controller, error) + type ControllerLimits struct + MaxInputBytes int + MaxLessons int + MaxOutputTokens int + MaxProposals int + MaxResponseBytes int + type ControllerPhaseHandler struct + func NewControllerPhaseHandler(repo Repository, models *ControllerFactory, trials PhaseHandler, domain string) (*ControllerPhaseHandler, error) + func (h *ControllerPhaseHandler) Execute(ctx context.Context, item WorkItem) (Transition, error) + type ControllerSelection struct + Activation Activation + Version HarnessVersion + type ControllerSpec struct + Model string + ModelRevision string + Sections []prompt.Section + Temperature float64 + Tools []string + type CreationCatalog interface + Authorize func(context.Context, CreationSelection) error + Prepare func(context.Context, CreationTarget) (ExperimentBundle, error) + type CreationCommand struct + Actor IdentityRef + Bundle ExperimentBundle + Key string + Selection CreationSelection + type CreationReceipt struct + Actor IdentityRef + CreatedAt time.Time + ExperimentID id.ID + InputDigest string + Key string + Scope cortex.Scope + Selection CreationSelection + SpecDigest string + func SealCreationReceipt(receipt CreationReceipt) (CreationReceipt, error) + type CreationRequest struct + IdempotencyKey string + Selection CreationSelection + type CreationSelection struct + Agent ContentRef + Budget *Budget + Controller ContentRef + Environment ContentRef + Evaluation ContentRef + Limits *Limits + Mode Mode + Objective *Objective + TaskSplits map[string]Split + type CreationTarget struct + Actor IdentityRef + ExperimentID id.ID + Scope cortex.Scope + Selection CreationSelection + type CriterionDefinition struct + ID string + Required bool + RequiresExpected *bool + type CriterionValue struct + Error string + ID string + Passed bool + Required bool + Score *float64 + type DeactivationChange struct + Actor IdentityRef + type DeactivationRequest struct + AgentID id.AgentID + Channel string + ExpectedGeneration int64 + ID id.ID + Kind HarnessKind + Reason string + type Decision struct + AllocationID id.ID + Baseline VersionRef + Candidate VersionRef + Comparison Comparison + CreatedAt time.Time + EvaluationIDs []string + EvidenceClass EvidenceClass + ExperimentID id.ID + ID id.ID + Outcome DecisionOutcome + PolicyDigest string + Reasons []string + SelectionKind string + SpecDigest string + TaskSelection *TaskSelection + func BuildTaskDecision(experiment Experiment, evidence []DecisionEvidence) (Decision, error) + type DecisionEvidence struct + Evaluation *Evaluation + Trial Trial + type DecisionOutcome string + const DecisionInconclusive + const DecisionRecommend + const DecisionReject + const DecisionRetain + const DecisionSelect + type DiscoveryEvidence struct + Evaluation Evaluation + Trial Trial + type DiscoveryLessons struct + Arm int + Controller VersionRef + CreatedAt time.Time + Digest string + Domain string + ExperimentID id.ID + Lessons []LessonDraft + ParentExperimentID id.ID + Sequence int + type DiscoveryLessonsRequest struct + Domain string + ExperimentID id.ID + Lease WorkLease + Lessons []LessonDraft + func (request DiscoveryLessonsRequest) Validate() error + type DiscoveryRef struct + Digest string + ExperimentID id.ID + type Edit struct + Kind EditKind + Number *float64 + Participant string + Target string + Text string + Tools *[]string + type EditKind string + const EditOrchestrationPreset + const EditParticipantGuidance + const EditSectionBody + const EditTemperature + const EditToolDescription + const EditToolSubset + type EditPolicy struct + AllowToolSubset bool + MaxBodyBytes int + MaxEdits int + MaxPatchBytes int + MutableSections []string + MutableToolDescriptions []string + OrchestrationPresets []OrchestrationPreset + TemperatureMax *float64 + TemperatureMin *float64 + type EngineCompatibility struct + func NewEngineCompatibility(config EngineCompatibilityConfig) (*EngineCompatibility, error) + func (c *EngineCompatibility) Check(ctx context.Context, version HarnessVersion) (CompatibilityReport, error) + type EngineCompatibilityConfig struct + Engine *engine.Engine + Host Compatibility + RuntimeVersion string + type EnvironmentFactory interface + Open func(context.Context, TrialRequest) (TrialEnvironment, error) + Recover func(context.Context, EnvironmentReceipt) (TrialEnvironment, error) + Stop func(context.Context, EnvironmentReceipt, Fence) (StopReceipt, error) + type EnvironmentReceipt struct + AttemptID id.ID + Capabilities IsolationCapabilities + CreatedAt time.Time + EnvironmentID string + Fence Fence + ID string + Provider string + Scope cortex.Scope + Snapshot ContentRef + func (receipt EnvironmentReceipt) Validate() error + type Evaluation struct + CaseDigest string + CaseID string + Complete bool + CompletedAt time.Time + Criteria []CriterionValue + Errors []string + ExecutionDigest string + ExperimentID id.ID + ID string + JudgeUsage Usage + PlanDigest string + RecordedAt time.Time + Repetition int + ReportID string + Score *float64 + Scorers []run.Revision + StartedAt time.Time + TrialID id.ID + func (evaluation Evaluation) ValidateCaptured(experiment Experiment, trial Trial) error + type EvaluationPlan struct + CaseDigests map[string]string + Criteria []CriterionDefinition + FrozenAt time.Time + Ref ContentRef + Scorers []run.Revision + func (plan EvaluationPlan) Validate(spec ExperimentSpec) error + type EvaluationRequest struct + CandidateID id.ID + CaseDigest string + CaseID string + Execution ExecutionRecord + ExperimentID id.ID + IdempotencyKey string + Lease WorkLease + Plan EvaluationPlan + Repetition int + TrialID id.ID + type EvaluationSpec struct + RequiredCriteria []string + Source ContentRef + Tasks []TaskCase + type Evaluator interface + Compare func(context.Context, ComparisonRequest) (Comparison, error) + Evaluate func(context.Context, EvaluationRequest) (Evaluation, error) + Freeze func(context.Context, EvaluationSpec) (EvaluationPlan, error) + type Event struct + Actor IdentityRef + CreatedAt time.Time + ExperimentID id.ID + ID id.ID + Payload json.RawMessage + Resources []id.ID + Sequence int64 + Type string + type EvidenceClass = learning.EvidenceClass + const EvidenceContrastive + const EvidenceExploratory + const EvidenceValidated + type ExecutionRecord struct + Artifacts []ArtifactRef + CompletedAt time.Time + Digest string + Duration time.Duration + Environment EnvironmentReceipt + InputDigest string + Orchestration *OrchestrationExecution + Outcome run.Outcome + PreparedDigest string + RunID id.AgentRunID + StartedAt time.Time + State run.State + StepIDs []id.ID + ToolCallIDs []id.ID + Usage Usage + func CaptureOrchestration(ctx context.Context, source OrchestrationCaptureSource, version HarnessVersion, ...) (ExecutionRecord, error) + func SealExecution(record ExecutionRecord) (ExecutionRecord, error) + func (record ExecutionRecord) ExecutionID() id.ID + type Experiment struct + CreatedAt time.Time + Deadline time.Time + DecisionID id.ID + Discoveries []DiscoveryRef + EvaluationPlan EvaluationPlan + Failure string + FrozenLessons []LessonRef + ID id.ID + Lease WorkLease + LessonIDs []id.ID + Phase Phase + Plan TrialPlan + RetainedBaseline *RetainedBaseline + Revision int64 + Round int + Spec ExperimentSpec + SpecDigest string + State State + UpdatedAt time.Time + type ExperimentBundle struct + ExpectedLessons []LessonRef + Experiment Experiment + ParentLease *WorkLease + Versions []HarnessVersion + type ExperimentSpec struct + AgentID id.AgentID + Baseline VersionRef + Budget Budget + Controller VersionRef + Evaluation ContentRef + Improvement *ImprovementPlan + LessonCutoff time.Time + Limits Limits + Mode Mode + Objective Objective + Parent *ParentExperiment + Requester IdentityRef + SchemaVersion int + Scope cortex.Scope + Task *TaskPolicy + Tasks []TaskCase + func DecodeSpec(data []byte) (ExperimentSpec, error) + type Fence struct + Generation int64 + Owner string + type Harness struct + AgentID id.AgentID + CreatedAt time.Time + CreatedBy IdentityRef + ID id.ID + Kind HarnessKind + Name string + Revision int64 + Scope cortex.Scope + type HarnessKind string + const HarnessExecution + const HarnessImprovement + func ActivationKind(kind HarnessKind) (HarnessKind, error) + type HarnessVersion struct + AgentID id.AgentID + Controller *ControllerSpec + CreatedAt time.Time + CreatedBy string + Digest string + HarnessID id.ID + ID id.ID + Kind HarnessKind + Name string + Orchestration *OrchestrationSelection + ParentID id.ID + Policy EditPolicy + PolicyDigest string + Prepared *engine.PreparedAgent + RuntimeVersion string + SchemaVersion int + Scope cortex.Scope + Sources []run.Revision + func SealVersion(version HarnessVersion) (HarnessVersion, error) + func ValidateProposal(base HarnessVersion, proposal Proposal, policy EditPolicy) (HarnessVersion, error) + type HostCapabilities struct + Checks map[Capability]ReadinessState + Environment IsolationCapabilities + PricingQuality UsageQuality + PricingRevision string + Target CapabilityTarget + type IdentityRef struct + Subject string + type IdentityResolver interface + Resolve func(context.Context, IdentityRef, cortex.Scope) (context.Context, error) + type ImprovementChild struct + EvaluationPlan EvaluationPlan + ExperimentID id.ID + Spec ExperimentSpec + type ImprovementPhaseHandler struct + func NewImprovementPhaseHandler(config OptimizerConfig) (*ImprovementPhaseHandler, error) + func (h *ImprovementPhaseHandler) Execute(ctx context.Context, item WorkItem) (Transition, error) + type ImprovementPlan struct + Children []ImprovementChild + Controllers [2]VersionRef + type ImprovementSpec struct + Bundle ExperimentBundle + type InputTokenBound struct + Bounded bool + Model string + ModelRevision string + Tokens int64 + type InputTokenCounter interface + Bound func(context.Context, *llm.Request) (InputTokenBound, error) + type IsolationCapabilities struct + AtomicSources bool + DeterministicApproval bool + FrozenRetrieval bool + IdempotentEffects bool + Isolated bool + ReadOnly bool + Recoverable bool + Resettable bool + Stoppable bool + type LedgerMeter struct + func NewLedgerMeter(repository MeterRepository, authorizer Authorizer, resolver IdentityResolver) (*LedgerMeter, error) + func (m *LedgerMeter) BeginCall(ctx context.Context, request UsageReservation, digest string) (Reservation, error) + func (m *LedgerMeter) Reserve(ctx context.Context, request UsageReservation) (Reservation, error) + func (m *LedgerMeter) Settle(ctx context.Context, settlement UsageSettlement) error + type Lesson = learning.Lesson + type LessonDraft struct + Applicability []string + Contraindications []string + Domain string + EvidenceIDs []id.ID + Statement string + type LessonPage = Page[Lesson] + type LessonQuery struct + Domain string + EligibleOnly bool + EvidenceClass EvidenceClass + type LessonRef = learning.Ref + type LessonRevocation struct + Actor IdentityRef + CommandKey string + ExpectedRevision int64 + LessonID id.ID + Reason string + type LessonStore interface + Publish func(context.Context, Lesson) (PublicationReceipt, error) + Recall func(context.Context, RecallQuery) (LessonPage, error) + Revoke func(context.Context, id.ID, int64) error + type Limits struct + Concurrency int + ExperimentTimeout time.Duration + MaxCandidates int + MaxOutputTokens int + MaxRounds int + MaxSteps int + MaxTrials int + Repetitions int + TrialTimeout time.Duration + func DefaultLimits() Limits + type ListQuery struct + AgentID id.AgentID + Cursor string + Limit int + State State + type Meter interface + Reserve func(context.Context, UsageReservation) (Reservation, error) + Settle func(context.Context, UsageSettlement) error + type MeterRepository interface + GetExperiment func(context.Context, id.ID) (Experiment, error) + Transact func(context.Context, func(Transaction) error) error + type MeteredClient struct + func NewMeteredClient(provider llm.Client, meter CallMeter, estimator UsageEstimator, ...) (*MeteredClient, error) + func (c *MeteredClient) Complete(ctx context.Context, request *llm.Request) (*llm.Response, error) + func (c *MeteredClient) CompleteStream(ctx context.Context, request *llm.Request) (llm.Stream, error) + type MeteredClientConfig struct + AttemptID id.ID + ExperimentID id.ID + MaxRequestBytes int + MaxResponseBytes int + Model string + ModelRevision string + Operation OperationClass + Scope cortex.Scope + type Mode string + const ModeParallel + const ModeSequential + const ModeTaskLocal + type ModelBinding struct + Counter InputTokenCounter + Model string + Pricing Pricing + Provider llm.Client + Reporter ModelUsageReporter + Revision string + type ModelObservation struct + Completed bool + Err error + Model string + ModelRevision string + ReportedModel string + RequestDigest string + Reservation UsageReservation + Streaming bool + Usage llm.Usage + UsagePresent bool + type ModelUsageReport struct + Complete bool + Usage Usage + type ModelUsageReporter interface + Observe func(context.Context, ModelObservation) (ModelUsageReport, error) + type MoneyEstimate struct + PricingRevision string + Quality UsageQuality + USDMicros int64 + type Objective struct + BootstrapSamples int + BootstrapSeed uint64 + Confidence float64 + MaxCostRatio *float64 + MaxLatencyRatio *float64 + MaxProtectedRegression float64 + MinImprovement float64 + MinValidationCases int + ProtectedCriteria []string + RequireReproducibility bool + RequiredCriteria []string + func DefaultObjective() Objective + type OperationClass string + const OperationBaseline + const OperationComposition + const OperationEmbedding + const OperationJudge + const OperationProbe + const OperationProposal + const OperationReflection + const OperationRetrieval + const OperationTool + const OperationValidation + type Optimizer struct + func NewOptimizer(config OptimizerConfig, options ...Option) (*Optimizer, error) + func (o *Optimizer) Activate(ctx context.Context, request ActivationRequest) (*Activation, error) + func (o *Optimizer) AdoptArtifacts(ctx context.Context, request ArtifactAdoptionRequest) (ArtifactAdoptionReceipt, error) + func (o *Optimizer) Cancel(ctx context.Context, experimentID id.ID, revision int64) (Experiment, error) + func (o *Optimizer) CancelCommand(ctx context.Context, request CommandRequest) (Experiment, error) + func (o *Optimizer) Capabilities(ctx context.Context, experimentID id.ID) (CapabilitySnapshot, error) + func (o *Optimizer) Create(ctx context.Context, bundle ExperimentBundle) (Experiment, error) + func (o *Optimizer) CreateCommand(ctx context.Context, request CreationRequest) (Experiment, error) + func (o *Optimizer) CreateImprovementExperiment(ctx context.Context, request ImprovementSpec) (*Experiment, error) + func (o *Optimizer) CreateWithLessons(ctx context.Context, bundle ExperimentBundle, query RecallQuery) (Experiment, error) + func (o *Optimizer) Deactivate(ctx context.Context, request DeactivationRequest) (*Activation, error) + func (o *Optimizer) Get(ctx context.Context, experimentID id.ID) (Experiment, error) + func (o *Optimizer) GetCandidate(ctx context.Context, experimentID, key id.ID) (Candidate, error) + func (o *Optimizer) GetComparison(ctx context.Context, experimentID id.ID, query PageQuery) (ComparisonDetail, error) + func (o *Optimizer) GetLesson(ctx context.Context, key id.ID) (Lesson, error) + func (o *Optimizer) GetTaskResult(ctx context.Context, experimentID id.ID) (*TaskResult, error) + func (o *Optimizer) GetTrial(ctx context.Context, experimentID, key id.ID) (Trial, error) + func (o *Optimizer) GetVersion(ctx context.Context, key id.ID) (HarnessVersion, error) + func (o *Optimizer) List(ctx context.Context, query ListQuery) (Page[Experiment], error) + func (o *Optimizer) ListActivations(ctx context.Context, query ActivationQuery) (ResourcePage[Activation], error) + func (o *Optimizer) ListCandidates(ctx context.Context, experimentID id.ID, query PageQuery) (ResourcePage[Candidate], error) + func (o *Optimizer) ListCatalog(ctx context.Context, query CatalogQuery) (ResourcePage[CatalogChoice], error) + func (o *Optimizer) ListEvents(ctx context.Context, experimentID id.ID, query PageQuery) (ResourcePage[Event], error) + func (o *Optimizer) ListExperiments(ctx context.Context, query ListQuery) (ResourcePage[Experiment], error) + func (o *Optimizer) ListLessons(ctx context.Context, query LessonQuery) (ResourcePage[Lesson], error) + func (o *Optimizer) ListPublications(ctx context.Context, query PublicationQuery) (ResourcePage[Publication], error) + func (o *Optimizer) ListTrials(ctx context.Context, experimentID id.ID, query TrialQuery) (ResourcePage[Trial], error) + func (o *Optimizer) ListVersions(ctx context.Context, query VersionQuery) (ResourcePage[HarnessVersion], error) + func (o *Optimizer) OptimizeTask(ctx context.Context, request TaskSpec) (*TaskResult, error) + func (o *Optimizer) Pause(ctx context.Context, experimentID id.ID, revision int64) (Experiment, error) + func (o *Optimizer) ResolveActiveController(ctx context.Context, request ActiveControllerRequest) (*ControllerSelection, error) + func (o *Optimizer) Resume(ctx context.Context, experimentID id.ID, revision int64) (Experiment, error) + func (o *Optimizer) ResumeCommand(ctx context.Context, request CommandRequest) (Experiment, error) + func (o *Optimizer) RetainCommand(ctx context.Context, request RetainRequest) (Experiment, error) + func (o *Optimizer) RetryLessonCommand(ctx context.Context, request RetryLessonRequest) (Publication, error) + func (o *Optimizer) RevokeLessonCommand(ctx context.Context, request RevokeLessonRequest) (Lesson, error) + func (o *Optimizer) Rollback(ctx context.Context, request RollbackRequest) (*Activation, error) + func (o *Optimizer) RunActive(ctx context.Context, request ActiveRunRequest) (*run.Run, error) + func (o *Optimizer) RunActiveOrchestration(ctx context.Context, request ActiveOrchestrationRequest) (*orchestration.Run, error) + func (o *Optimizer) Start(ctx context.Context, experimentID id.ID, revision int64) (Experiment, error) + func (o *Optimizer) StartCommand(ctx context.Context, request CommandRequest) (Experiment, error) + func (o *Optimizer) Work(ctx context.Context) error + func (o *Optimizer) WorkOnce(ctx context.Context, experimentID id.ID) error + type OptimizerConfig struct + ArtifactVerifier *ArtifactVerifier + Authorizer Authorizer + Caller CallerIdentity + Capabilities CapabilityProbe + Catalog CatalogProvider + Compatibility Compatibility + ControllerCompatibility Compatibility + CreationCatalog CreationCatalog + Handler PhaseHandler + IdentityResolver IdentityResolver + ImprovementEvaluator Evaluator + Lessons LessonStore + Repository Repository + TaskEvaluator Evaluator + UsageRecovery *UsageRecovery + Worker WorkerConfig + type Option func(*Optimizer) error + func WithActiveEngine(runtime *engine.Engine) Option + func WithArtifactAdopter(adopter ArtifactAdopter) Option + type OrchestrationCaptureSource interface + GetOrchestrationBudgetSnapshot func(context.Context, id.OrchestrationID) (orchestration.BudgetSnapshot, error) + GetOrchestrationRun func(context.Context, id.OrchestrationID) (*orchestration.Run, error) + GetRun func(context.Context, id.AgentRunID) (*run.Run, error) + ListOrchestrationReservations func(context.Context, execution.ReservationListRequest) ([]execution.Reservation, error) + ListSteps func(context.Context, id.AgentRunID) ([]*run.Step, error) + ListToolCalls func(context.Context, id.StepID) ([]*run.ToolCall, error) + type OrchestrationChildExecution struct + Execution *ExecutionRecord + Reservation execution.Reservation + type OrchestrationExecution struct + Budget orchestration.BudgetSnapshot + Children []OrchestrationChildExecution + Run orchestration.Run + type OrchestrationPreset struct + Digest string + Guidance map[string][]string + Limits execution.Resources + Name string + Prepared *engine.PreparedOrchestration + func SealOrchestrationPreset(preset OrchestrationPreset) (OrchestrationPreset, error) + type OrchestrationSelection struct + Guidance map[string]map[string]string + Prepared *engine.PreparedOrchestration + Preset string + type OrchestrationTrialEnvironment interface + ExecuteOrchestration func(context.Context, *engine.PreparedOrchestration, string, ...) (*ExecutionRecord, error) + type Page struct + Items []T + NextCursor string + type PageQuery struct + Cursor string + Limit int + type ParentExperiment struct + Arm int + ExperimentID id.ID + Sequence int + type Phase string + const PhaseBaseline + const PhaseCompose + const PhaseDecide + const PhaseProbe + const PhasePropose + const PhaseReflect + const PhaseValidate + type PhaseHandler interface + Execute func(context.Context, WorkItem) (Transition, error) + type Pricing interface + Price func(context.Context, UsageEstimate) (MoneyEstimate, error) + type Proposal struct + Edits []Edit + EvidenceIDs []id.ID + Rationale string + func DecodeProposal(data []byte) (Proposal, error) + type ProposalInput struct + Baseline HarnessVersion + Discoveries []DiscoveryLessons + Evidence []DiscoveryEvidence + Lessons []Lesson + Policy EditPolicy + Round int + type Publication struct + Attempts int + CompletedAt time.Time + CreatedAt time.Time + DeliveryActor IdentityRef + DeliveryLease PublicationLease + ExperimentID id.ID + LastErrorCode string + LastRetry *PublicationRetry + LessonID id.ID + LocalRevision int64 + NextRetry time.Time + Operation PublicationOperation + Payload Lesson + PayloadDigest string + Receipt *PublicationReceipt + RemoteAggregateID string + RemoteVersion int64 + RetriedAt time.Time + RetryAttemptBase int + SupersededAt time.Time + TerminalError string + type PublicationClaim struct + Actor IdentityRef + Duration time.Duration + LessonID id.ID + LocalRevision int64 + Owner string + type PublicationLease struct + ExpiresAt time.Time + Generation int64 + LessonID id.ID + LocalRevision int64 + Owner string + type PublicationOperation string + const PublicationPublish + const PublicationRevoke + type PublicationQuery struct + ExperimentID id.ID + LessonID id.ID + Operation PublicationOperation + PendingOnly bool + type PublicationReceipt struct + AcknowledgedAt time.Time + AggregateID string + LessonID id.ID + PayloadDigest string + Version int64 + type PublicationRequest struct + Actor IdentityRef + ExperimentID id.ID + Lease WorkLease + Lesson Lesson + RemoteAggregateID string + type PublicationRetry struct + Actor IdentityRef + CommandKey string + ExpectedGeneration int64 + LessonID id.ID + LocalRevision int64 + Reason string + type PublicationSink interface + Deliver func(context.Context, Publication) (PublicationReceipt, error) + type Publisher struct + func NewPublisher(config PublisherConfig) (*Publisher, error) + func (p *Publisher) Retry(ctx context.Context, request PublicationRetry) (Publication, error) + func (p *Publisher) Work(ctx context.Context) error + func (p *Publisher) WorkOnce(ctx context.Context) error + type PublisherConfig struct + Authorizer Authorizer + Caller CallerIdentity + IdentityResolver IdentityResolver + Now func() time.Time + Repository Repository + Sink PublicationSink + type ReadinessState string + const ReadinessDenied + const ReadinessReady + const ReadinessUnavailable + const ReadinessUnknown + type RecallQuery struct + Cursor string + Cutoff time.Time + Domain string + HarnessSchema int + Limit int + Query string + Scope cortex.Scope + type RecoveryRepository interface + GetReservation func(context.Context, id.ID, string) (Reservation, error) + ListReservations func(context.Context, id.ID, PageQuery) (Page[Reservation], error) + type ReflectionInput struct + Candidates []Candidate + Domain string + Evidence []DiscoveryEvidence + type Repository interface + Close func() error + GetActivation func(context.Context, id.AgentID, string) (Activation, error) + GetActivationForKind func(context.Context, id.AgentID, string, HarnessKind) (Activation, error) + GetActivationGeneration func(context.Context, id.ID) (Activation, error) + GetArtifact func(context.Context, ArtifactRef) (ArtifactRetention, error) + GetCandidate func(context.Context, id.ID) (Candidate, error) + GetCreationReceipt func(context.Context, string) (CreationReceipt, error) + GetDecision func(context.Context, id.ID) (Decision, error) + GetDiscoveryLessons func(context.Context, id.ID) (DiscoveryLessons, error) + GetEvaluation func(context.Context, string) (Evaluation, error) + GetExperiment func(context.Context, id.ID) (Experiment, error) + GetLesson func(context.Context, id.ID) (Lesson, error) + GetPublication func(context.Context, id.ID, int64) (Publication, error) + GetReservation func(context.Context, id.ID, string) (Reservation, error) + GetTrial func(context.Context, id.ID) (Trial, error) + GetValidationAllocation func(context.Context, id.ID) (ValidationAllocation, error) + GetVersion func(context.Context, id.ID) (HarnessVersion, error) + ListActivationHistory func(context.Context, id.AgentID, string, PageQuery) (Page[Activation], error) + ListActivationHistoryForKind func(context.Context, id.AgentID, string, HarnessKind, PageQuery) (Page[Activation], error) + ListArtifactWork func(context.Context, time.Time, PageQuery) (Page[ArtifactRetention], error) + ListCandidates func(context.Context, id.ID, PageQuery) (Page[Candidate], error) + ListDecisions func(context.Context, id.ID, PageQuery) (Page[Decision], error) + ListEvaluations func(context.Context, id.ID, PageQuery) (Page[Evaluation], error) + ListEvents func(context.Context, id.ID, int64, int) (Page[Event], error) + ListExperiments func(context.Context, ListQuery) (Page[Experiment], error) + ListLessons func(context.Context, LessonQuery) (Page[Lesson], error) + ListPublications func(context.Context, PublicationQuery) (Page[Publication], error) + ListReservations func(context.Context, id.ID, PageQuery) (Page[Reservation], error) + ListTrials func(context.Context, id.ID, TrialQuery) (Page[Trial], error) + ListValidationAllocations func(context.Context, id.ID, PageQuery) (Page[ValidationAllocation], error) + ListVersions func(context.Context, VersionQuery) (Page[HarnessVersion], error) + Migrate func(context.Context) error + Ping func(context.Context) error + ResolveActivation func(context.Context, id.ID) (Activation, error) + ResolveDiscoveryLessons func(context.Context, id.ID, DiscoveryRef) (DiscoveryLessons, error) + ResolveLesson func(context.Context, LessonRef) (Lesson, error) + Transact func(context.Context, func(Transaction) error) error + type RequestEstimator struct + func NewRequestEstimator(counter InputTokenCounter, pricing Pricing, config RequestEstimatorConfig) (*RequestEstimator, error) + func (e *RequestEstimator) Estimate(ctx context.Context, req *llm.Request) (UsageReservation, error) + type RequestEstimatorConfig struct + MaxRequestBytes int + Model string + ModelRevision string + Reservation UsageReservation + Scope cortex.Scope + TokenOnly bool + type Reservation struct + Call *UsageCall + CreatedAt time.Time + DebitedTokens int64 + DebitedUSDMicros int64 + History []UsageSettlement + Request UsageReservation + Revision int64 + Settlement *UsageSettlement + State ReservationState + type ReservationState string + const ReservationHeld + const ReservationSettled + const ReservationUnknown + type Resource struct + AgentID id.AgentID + ID id.ID + Kind string + Scope cortex.Scope + type ResourcePage struct + Complete bool + Items []T + NextCursor string + type RetainDecision struct + DecisionID id.ID + Reason string + func (r RetainDecision) Validate() error + type RetainRequest struct + type RetainedBaseline struct + Actor IdentityRef + Baseline VersionRef + CreatedAt time.Time + DecisionID id.ID + Reason string + type RetryLessonRequest struct + ExpectedGeneration int64 + IdempotencyKey string + LessonID id.ID + LocalRevision int64 + Reason string + type RevokeLessonRequest struct + ExpectedRevision int64 + IdempotencyKey string + LessonID id.ID + Reason string + type RollbackRequest struct + AgentID id.AgentID + Channel string + ExpectedGeneration int64 + ID id.ID + Kind HarnessKind + Reason string + TargetID id.ID + type Split string + const SplitDiscovery + const SplitValidation + type State string + const StateBudgetExhausted + const StateCancelled + const StateCompleted + const StateDraft + const StateFailed + const StatePaused + const StateQueued + const StateReviewRequired + const StateRunning + type StopReceipt struct + AttemptID id.ID + EnvironmentReceiptID string + Evidence ContentRef + Fence Fence + ObservedAt time.Time + State StopState + func (receipt StopReceipt) Validate() error + type StopState string + const StopQuarantined + const StopTerminated + const StopUnknown + type TaskCase struct + Context []ContentRef + DatasetItem *ContentRef + Digest string + EnvironmentSnapshot ContentRef + ID string + Input string + InputDigest string + Split Split + func SealTaskCase(task TaskCase) (TaskCase, error) + type TaskPolicy struct + AdoptionPolicy *ContentRef + Deadline time.Time + Isolation IsolationCapabilities + type TaskResult struct + Artifacts []ArtifactRef + Decision Decision + Evidence []DecisionEvidence + EvidenceClass EvidenceClass + ExperimentID id.ID + Output string + Trial Trial + type TaskSelection struct + Score float64 + TrialID id.ID + type TaskSpec struct + AdoptionPolicy *ContentRef + Bundle ExperimentBundle + Isolation IsolationCapabilities + type TokenPrice struct + Model string + ModelRevision string + OutputUSDMicrosPerMillion int64 + PricingRevision string + PromptUSDMicrosPerMillion int64 + RequestUSDMicros int64 + type TokenPricing struct + func NewTokenPricing(rates TokenPrice) (*TokenPricing, error) + func (p *TokenPricing) Price(ctx context.Context, usage UsageEstimate) (MoneyEstimate, error) + type Transaction interface + AllocateValidation func(ValidationAllocationRequest) (ValidationAllocation, error) + BeginArtifactDeletion func(ArtifactDeletion) error + BeginUsageCall func(UsageReservation, string) (Reservation, error) + ClaimPublication func(PublicationClaim) (Publication, error) + ClaimWork func(ClaimRequest) (WorkLease, error) + CommitTransition func(Transition) error + CompareAndSwapActivation func(ActivationChange) (Activation, error) + CompleteArtifactDeletion func(ArtifactRef, string) error + CompletePublication func(PublicationLease, PublicationReceipt) error + CreateExperiment func(ExperimentBundle) error + CreateExperimentCommand func(CreationCommand) (CreationReceipt, error) + Deactivate func(DeactivationChange) (Activation, error) + ExposeValidation func(ValidationAccess) error + FailPublication func(PublicationLease, string, time.Time, bool) error + PutDiscoveryLessons func(DiscoveryLessonsRequest) (DiscoveryLessons, error) + PutPublication func(PublicationRequest) error + ReconcileUsage func(UsageReconciliation) error + RegisterArtifact func(ArtifactRegistration) error + ReleaseValidation func(ValidationAccess) error + RenewLease func(WorkLease) error + Reserve func(UsageReservation) (Reservation, error) + RetryPublication func(PublicationRetry) error + RevokeLesson func(LessonRevocation) error + Settle func(UsageSettlement) error + type Transition struct + Actor IdentityRef + Candidates []Candidate + CommandAction Action + Decision *Decision + Evaluations []Evaluation + ExpectedRevision int64 + ExperimentID id.ID + IdempotencyKey string + Lease WorkLease + NextPhase Phase + NextState State + Publications []PublicationRequest + Retain *RetainDecision + TrialUpdates []TrialUpdate + Trials []Trial + Versions []HarnessVersion + type Trial struct + AllocationID id.ID + Attempts []Attempt + CandidateID id.ID + CaseDigest string + CaseID string + CreatedAt time.Time + Error string + EvaluationID string + Execution *ExecutionRecord + ExperimentID id.ID + ID id.ID + Repetition int + Revision int64 + Split Split + State TrialState + Version VersionRef + type TrialAllowance struct + MaxTokens int64 + MaxUSDMicros int64 + PricingRevision string + type TrialConfig struct + Allowance TrialAllowance + Authorizer Authorizer + Environments EnvironmentFactory + Evaluator Evaluator + IdentityResolver IdentityResolver + Repository Repository + type TrialEnvironment interface + Close func(context.Context) error + Execute func(context.Context, *engine.PreparedAgent, string, engine.PreparedRunOptions) (*ExecutionRecord, error) + Inspect func(context.Context, id.ID) (AttemptStatus, error) + Receipt func() EnvironmentReceipt + type TrialPhaseHandler struct + func NewTrialPhaseHandler(config TrialConfig) (*TrialPhaseHandler, error) + func (h *TrialPhaseHandler) Execute(ctx context.Context, item WorkItem) (Transition, error) + type TrialPlan struct + DiscoveryTrials int + DistinctValidationCases int + TotalTrials int + ValidationTrials int + func Preflight(spec ExperimentSpec) (TrialPlan, error) + type TrialQuery struct + Split Split + State TrialState + VersionID id.ID + type TrialRequest struct + Allowance TrialAllowance + AttemptID id.ID + Deadline time.Time + ExperimentID id.ID + Fence Fence + Limits Limits + Scope cortex.Scope + Task TaskCase + TrialID id.ID + Version VersionRef + type TrialState string + const TrialBlocked + const TrialCancelled + const TrialCompleted + const TrialFailed + const TrialInvalidated + const TrialQueued + const TrialRunning + const TrialUnknown + type TrialUpdate struct + AttemptID id.ID + Error string + Execution *ExecutionRecord + ExpectedAttemptRevision int64 + ExpectedRevision int64 + Receipt *EnvironmentReceipt + RetryApproval *ContentRef + StartAttemptID id.ID + State TrialState + Stop *StopReceipt + TrialID id.ID + type Usage struct + MoneyQuality UsageQuality + PricingRevision string + Receipt string + TokenQuality UsageQuality + Tokens int64 + USDMicros int64 + func OrchestrationChildUsage(policy orchestration.BudgetPolicy, reservation execution.Reservation) (Usage, error) + func OrchestrationUsage(capture OrchestrationExecution) (Usage, error) + func (usage Usage) KnownCost() (int64, bool) + func (usage Usage) Validate() error + type UsageCall struct + Lease WorkLease + RequestDigest string + StartedAt time.Time + func (call UsageCall) Validate() error + type UsageEstimate struct + Model string + ModelRevision string + OutputTokens int64 + PricingRevision string + PromptTokens int64 + type UsageEstimator interface + Estimate func(context.Context, *llm.Request) (UsageReservation, error) + type UsageQuality string + const UsageEstimated + const UsageKnown + const UsageUnknown + type UsageReceiptProvider interface + Recover func(context.Context, Reservation) (VerifiedUsageReceipt, error) + type UsageReconciliation struct + Actor IdentityRef + ExpectedRevision int64 + RequestDigest string + Settlement UsageSettlement + type UsageRecovery struct + func NewUsageRecovery(repo RecoveryRepository, auth Authorizer, resolver IdentityResolver, ...) (*UsageRecovery, error) + func (r *UsageRecovery) Recover(ctx context.Context, experimentID id.ID, key string, actor IdentityRef) error + type UsageReservation struct + AttemptID id.ID + CallKey string + ExperimentID id.ID + ExpiresAt time.Time + Lease WorkLease + MaxTokens int64 + MaxUSDMicros int64 + Operation OperationClass + PricingRevision string + type UsageSettlement struct + AttemptID id.ID + CallKey string + Complete bool + ExperimentID id.ID + Lease WorkLease + ObservedAt time.Time + Receipt string + Usage Usage + type ValidationAccess struct + AllocationID id.ID + ExperimentID id.ID + Lease WorkLease + type ValidationAllocation struct + AgentID id.AgentID + CaseDigests []string + CreatedAt time.Time + DatasetItems []ContentRef + ExperimentID id.ID + ExposedAt time.Time + ID id.ID + InputDigests []string + PairedRoster []ValidationArm + ReleasedAt time.Time + Revision int64 + Scope cortex.Scope + type ValidationAllocationRequest struct + ExperimentID id.ID + ID id.ID + Lease WorkLease + PairedRoster []ValidationArm + type ValidationArm struct + Baseline VersionRef + CaseDigests []string + Controller VersionRef + ExperimentID id.ID + Finalist VersionRef + type VerifiedUsageReceipt struct + RequestDigest string + Settlement UsageSettlement + type VersionQuery struct + AgentID id.AgentID + Kind HarnessKind + type VersionRef struct + Digest string + ID id.ID + type WorkItem struct + Experiment Experiment + Lease WorkLease + type WorkLease struct + ExperimentID id.ID + ExpiresAt time.Time + Generation int64 + Owner string + ParentGeneration int64 + type WorkerConfig struct + HeartbeatInterval time.Duration + LeaseDuration time.Duration + PollInterval time.Duration + func DefaultWorkerConfig() WorkerConfig
Go to main page