Versions in this module Expand all Collapse all v0 v0.2.0 Jul 14, 2026 Changes in this version + func EqualJSONObject(left, right []byte) bool + func IsPossiblePartial(err error) bool + func NormalizedResult(operation string, result json.RawMessage) json.RawMessage + func PlanRecord(plan grants.ImmutablePlan) state.PlanRecord + func RecoveredApprovalCommit(grant grants.Grant) (commit, valid bool) + type Adapter interface + Authorize func(P) A + Decode func(target, arguments json.RawMessage) (I, error) + Descriptor func() capability.Descriptor + Execute func(context.Context, P) (Outcome, error) + Present func(P) agentv1.Presentation + Reconcile func(context.Context, P) (Outcome, error) + Resolve func(context.Context, I) (P, error) + type ClientBoundAdapter interface + ValidateClient func(I, string, string) error + type Failure struct + Code string + Message string + type Options struct + ApprovalMessage func(grants.Grant, string) notify.ApprovalMessage + Authorization *authorization.Coordinator + AuthorizationGrace time.Duration + Broker string + Decide func(policy.Request, policy.DecisionOptions) policy.Decision + DefinitiveFailure func(error) bool + ExecutionFailure func(error, error) Failure + Grants *grants.Store + InputData func(I) (json.RawMessage, json.RawMessage) + Load func(agentv1.Operation, Adapter[I, P, A]) (P, error) + MapSubmissionError func(error) error + NotificationLease time.Duration + Notifier notify.Notifier + Now func() time.Time + Operations *agentops.Store + OperatorConfigured bool + PlanData func(P) (json.RawMessage, json.RawMessage) + PlanDigest func(grants.Grant) string + Prepare func(Preparation[P, A]) (authorization.GrantIntent, error) + Project func(A) policy.Request + RecordOutcome func(agentv1.Operation, P, string, string, int) + RecordPolicyRefusal func(agentv1.Operation, P, policy.Decision, string) + Registry *Registry[I, P, A] + SetClient func(*P, string) + StoredPlan func(string) (state.PlanRecord, error) + ValidateExecution func(grants.Grant) error + WorkerConcurrency int + WorkerInterval time.Duration + type Outcome struct + Proven bool + Result json.RawMessage + UpstreamStatus int + type PlanCleaner interface + Cleanup func(P) error + type PossiblePartialError struct + Err error + func (e *PossiblePartialError) Error() string + func (e *PossiblePartialError) Unwrap() error + type Preparation struct + Auth A + Client string + Core policy.Request + CreatedAt time.Time + Decision policy.Decision + DescriptorName string + Direct bool + OperationID string + Plan P + Reason string + type Registry struct + func NewRegistry[I, P, A any](options RegistryOptions, adapters ...Adapter[I, P, A]) (*Registry[I, P, A], error) + func (r *Registry[I, P, A]) Lookup(name string) (Adapter[I, P, A], bool) + func (r *Registry[I, P, A]) Names() []string + func (r *Registry[I, P, A]) ValidateCoverage(provider string, descriptors []capability.Descriptor) error + type RegistryOptions struct + Descriptor func(string) (capability.Descriptor, bool) + Provider string + RequiresAdapter func(capability.Descriptor) bool + type Runtime struct + func New[I, P, A any](options Options[I, P, A]) (*Runtime[I, P, A], error) + func (r *Runtime[I, P, A]) Advance(ctx context.Context, operation agentv1.Operation) + func (r *Runtime[I, P, A]) AdvanceAll(ctx context.Context) + func (r *Runtime[I, P, A]) Cancel(_ context.Context, client, id string) (agentv1.Operation, error) + func (r *Runtime[I, P, A]) CancelGrant(grant grants.Grant, client string) error + func (r *Runtime[I, P, A]) Execute(ctx context.Context, operation agentv1.Operation) + func (r *Runtime[I, P, A]) FailExecution(operation agentv1.Operation, plan P, executionErr, reconcileErr error) + func (r *Runtime[I, P, A]) Load(operation agentv1.Operation) (Adapter[I, P, A], P, error) + func (r *Runtime[I, P, A]) ReconcileInterrupted(ctx context.Context, operation agentv1.Operation) + func (r *Runtime[I, P, A]) Recover(ctx context.Context) + func (r *Runtime[I, P, A]) RecoverApproval(operation agentv1.Operation) agentv1.Operation + func (r *Runtime[I, P, A]) Start(ctx context.Context) + func (r *Runtime[I, P, A]) Submit(ctx context.Context, client string, request agentv1.SubmitRequest) (agentv1.Operation, bool, error) + func (r *Runtime[I, P, A]) Succeed(operation agentv1.Operation, plan P, result json.RawMessage, reserved bool, ...) + func (r *Runtime[I, P, A]) Wait()
Go to main page