workqueue

package

Go to main page

Versions in this module

v0

v0.91.7

Oct 9, 2026

Changes in this version

type ClaimState

+ IssueComment string

+ type IssueCommentOperation struct

+ AuthorityClaimID string

+ ClaimID string

+ CommentID string

+ Kind string

+ ProjectorRef string

+ WorkID string

+ type IssueLinkOperation struct

+ ClaimID string

+ Kind string

+ ProjectorRef string

+ Resource Resource

+ WorkID string

type Policy

+ Projectors []ProjectorRule

+ type ProjectorRule struct

+ BackingIssues []Resource

+ CompletionPolicy string

+ Pools []string

+ Principal string

+ Ref string

+ Repositories []string

+ Workflow string

type WorkDefinition

+ BackingIssue *Resource

type WorkState

+ IssueLink *Resource

+ IssueSummary string

v0.91.6

Oct 8, 2026

Changes in this version

+ const MaxClaimsPerDispatch

+ const MaxTimestamp

+ const Version

+ func AuthorizeEffect(state Projection, actor Actor, target EffectResource) error

+ func BuildCandidate(commits []QueueCommit, actor Actor, request Request, at int64) ([]QueueCommit, *QueueCommit, Decision, error)

+ func Canonical(data []byte) ([]byte, error)

+ func CanonicalValue(value any) ([]byte, error)

+ func Fingerprint(actor Actor, kind string, parameters json.RawMessage) (string, error)

+ func IndependentGraphID(payload []byte) (string, error)

+ func NodeID(graphID, nodeKey string) string

+ func NormalizeClaimHandle(assignment Assignment, selector *string) (string, error)

+ func ObservationRefreshBudget(state Projection, requested int) (int, error)

+ func ProposedCommitID(state Projection, request Request) string

+ func RecoveryHeadroom(state Projection) int64

+ func ValidateAssignment(state Projection, assignment Assignment) error

+ func ValidateCommit(commit QueueCommit) error

+ func ValidatePolicy(policy Policy) error

+ type Actor struct

+ ClaimHandle string

+ DispatchID string

+ Principal string

+ Repository string

+ Role string

+ RunAttempt int

+ RunID string

+ Workflow string

+ type Assignment struct

+ Claims []AssignmentClaim

+ CommitID string

+ DispatchID string

+ PolicyEpoch string

+ Pool string

+ RequestID string

+ Version int

+ WorkerProfile string

+ func ParseAssignment(data []byte) (Assignment, error)

+ type AssignmentClaim struct

+ ClaimID string

+ Handle string

+ ResultRefs []ResultReference

+ Work json.RawMessage

+ WorkID string

type Branch

+ DeliveryVerifier DeliveryVerifier

+ DependencyClients map[string]*api.RESTClient

+ RemediationVerifier RemediationVerifier

+ func (b Branch) Authenticate(ctx context.Context, role string) (Actor, error)

+ func (b Branch) CancelReserved(ctx context.Context, dispatchID, requestID string) (Reconciliation, error)

+ func (b Branch) Compact(ctx context.Context) (Compaction, error)

+ func (b Branch) InspectEvidence(ctx context.Context, dispatchID string) (Reconciliation, error)

+ func (b Branch) Publish(ctx context.Context, actor Actor, request Request) (Publication, error)

+ func (b Branch) Reconcile(ctx context.Context, dispatchID, requestID string) (Reconciliation, error)

+ func (b Branch) RecoverDelivery(ctx context.Context, workID, requestID string) (DeliveryRecovery, error)

+ type Capacity struct

+ Account int

+ Logical int

+ Native int

+ type ClaimExplanation struct

+ At int64

+ BeforeTip string

+ CapacityAfter Capacity

+ CapacityBefore Capacity

+ ClaimID string

+ ClassPassPrior string

+ CommitID string

+ DispatchID string

+ FairnessKey string

+ Handle string

+ KeyPassPrior string

+ PolicyEpoch string

+ Pool string

+ Position Position

+ Priority int

+ RequestID string

+ Selection Selection

+ Status string

+ Tip string

+ WorkID string

+ WorkPosition Position

+ func ExplainBeforeClaim(commits []QueueCommit, claimID string) (ClaimExplanation, error)

+ type ClaimOperation struct

+ ClaimID string

+ DispatchID string

+ Handle string

+ Kind string

+ Observations []string

+ WorkID string

type ClaimState

+ CancellationReason string

+ CommitID string

+ RequestID string

+ RetryNotBefore int64

+ TerminalCommitID string

+ type Clock struct

+ Active map[string]bool

+ Pass map[string]string

+ V string

+ type Compaction struct

+ AcknowledgmentRecovered bool

+ At int64

+ BytesAfter int

+ BytesBefore int

+ Changed bool

+ Commits int

+ DuplicatesRemoved int

+ Tip string

+ type Decision struct

+ Assignments []Assignment

+ Next Selection

+ Operations []Operation

+ Reason string

+ Tip string

+ func PlanDispatch(state Projection, params DispatchParameters, requestID, commitID string, ...) (Decision, error)

+ type DeliveryRecovery struct

+ Attempts int

+ Publication *Publication

+ Reason string

+ WorkID string

+ type DeliveryVerification struct

+ Descriptor json.RawMessage

+ Disposition string

+ PositiveNoEffects bool

+ Receipt string

+ Verified bool

+ type DeliveryVerifier func(context.Context, Projection, ClaimState) (DeliveryVerification, error)

+ type Dependency struct

+ Condition string

+ Kind string

+ Resource *Resource

+ WorkID string

+ type DispatchParameters struct

+ MaxBytes int64

+ MaxClaims int

+ MaxDispatches int

+ Pool string

+ type DispatchState struct

+ LifecycleWrites int

+ Profile WorkerProfile

+ Reason string

+ Released bool

+ Run *RunBinding

+ Sender *Actor

+ State string

+ type EffectResource map[string]string

+ type Evidence struct

+ Attempts int

+ CheckedAt int64

+ Conclusion string

+ Effects string

+ Kind string

+ Principal string

+ Receipt string

+ Ref string

+ Repository string

+ RunAttempt int

+ RunID string

+ Source string

+ Status string

+ Workflow string

+ type FinishParameters struct

+ ClaimHandle string

+ DispatchID string

+ Outcome string

+ func NormalizeFinishIntent(assignment Assignment, data []byte) (FinishParameters, error)

+ type Limits struct

+ AssignmentBytes int64

+ EvidenceBytes int64

+ GraphNodes int

+ LedgerBytes int64

+ ObservationWrites int

+ Operations int

+ PayloadBytes int64

+ PendingNodes int

+ Predecessors int

+ RecoveryBytes int64

+ ResultBytes int64

+ type NativeDeliveryHost struct

+ func NewNativeDeliveryHost(options NativeDeliveryHostOptions) *NativeDeliveryHost

+ func (host *NativeDeliveryHost) Verifier(branch Branch) DeliveryVerifier

+ type NativeDeliveryHostOptions struct

+ Builtin map[string]NativeOutputVerifier

+ Credentials func(context.Context, NativeDeliveryScope, EffectResource) error

+ Declared map[string]NativeOutputVerifier

+ Inventory func(context.Context, NativeDeliveryScope) (NativeDeliveryInventory, error)

+ type NativeDeliveryInventory struct

+ Closed bool

+ Outputs []NativeDeliveryOutput

+ type NativeDeliveryOutput struct

+ Intent json.RawMessage

+ RequestID string

+ Target EffectResource

+ Type string

+ type NativeDeliveryScope struct

+ CompletionID string

+ CredentialGeneration string

+ Member AssignmentClaim

+ Run RunBinding

+ type NativeOutputVerifier func(context.Context, NativeDeliveryScope, NativeDeliveryOutput, json.RawMessage) (json.RawMessage, bool, error)

+ type NativeRun struct

+ Actor struct{ ... }

+ Conclusion string

+ DisplayTitle string

+ Event string

+ HeadSHA string

+ ID json.Number

+ Path string

+ Repository struct{ ... }

+ RunAttempt int

+ Status string

+ TriggeringActor struct{ ... }

+ type Observation struct

+ Condition string

+ CredentialGeneration string

+ Kind string

+ MergeCommit string

+ Merged *bool

+ ObservationID string

+ ObservedAt int64

+ ReadStatus string

+ Resource Resource

+ ResourceState string

+ SourceUpdatedAt *int64

+ State string

+ StateReason string

+ type Operation = json.RawMessage

+ func Op(value any) (Operation, error)

+ type OperationsParameters struct

+ Operations []Operation

+ type Policy struct

+ AccountingWeights map[string]int

+ ClassWeights []int

+ Limits Limits

+ Mode string

+ Pools map[string]PoolPolicy

+ Producers map[string]ProducerRule

+ func DefaultPolicy(principal, repository string) Policy

+ type PoolClocks struct

+ Classes Clock

+ Keys map[int]Clock

+ type PoolPolicy struct

+ AllowedRepositories []string

+ DefaultProfile string

+ LogicalLimit int

+ MaxObservationAgeMS int64

+ NativeLimit int

+ PerAccountLimit int

+ Profiles map[string]WorkerProfile

+ Reconciliation ReconciliationPolicy

+ Retry RetryPolicy

+ type Position struct

+ Commit int

+ Operation int

+ type ProducerRule struct

+ FairnessKeys []string

+ Pools []string

+ Priorities []int

type Projection

+ AdmissionPaused bool

+ Claims map[string]*ClaimState

+ Clocks map[string]PoolClocks

+ CredentialGeneration string

+ Dispatches map[string]*DispatchState

+ GrantsPaused bool

+ LedgerBytes int64

+ ObservationWrites map[string]int

+ Observations map[string]*Observation

+ Policy *Policy

+ PolicyEpoch string

+ Repository string

+ Requests map[string]QueueCommit

+ Tip string

+ type ProtocolError struct

+ Code string

+ Message string

+ func (e *ProtocolError) Error() string

+ type Publication struct

+ Changed bool

+ Commit *QueueCommit

+ Decision Decision

+ type QueueCommit struct

+ Actor Actor

+ At int64

+ ID string

+ Operations []Operation

+ PolicyEpoch string

+ Previous *string

+ Request Request

+ Trace *Trace

+ Version int

+ func Genesis(actor Actor, policy Policy, requestID, epoch string, at int64) (QueueCommit, error)

+ type Reconciliation struct

+ DispatchID string

+ Evidence *Evidence

+ Publication *Publication

+ Reason string

+ State string

+ type ReconciliationPolicy struct

+ DeadlineMS int64

+ MaxAttempts int

+ type RemediationVerifier func(context.Context, Projection, WorkDefinition) error

+ type Replacement struct

+ Disposition string

+ Evidence string

+ WorkID string

+ type Request struct

+ Fingerprint string

+ ID string

+ Kind string

+ Parameters json.RawMessage

+ func NewRequest(id, kind string, actor Actor, parameters any) (Request, error)

+ type RequestExplanation struct

+ At int64

+ Claims []ClaimExplanation

+ CommitID string

+ Kind string

+ PolicyEpoch string

+ RequestID string

+ Status string

+ Tip string

+ func ExplainRequest(commits []QueueCommit, requestID string) (RequestExplanation, error)

+ type Resource struct

+ Host string

+ Kind string

+ Number string

+ Repository string

+ RepositoryID string

+ ResourceID string

+ type ResultReference struct

+ Descriptor json.RawMessage

+ ResultCommitID string

+ WorkID string

+ type RetryPolicy struct

+ BackoffMS int64

+ MaxAttempts int

+ type RunBinding struct

+ Event string

+ Principal string

+ Ref string

+ Repository string

+ RunAttempt int

+ RunID string

+ Workflow string

+ type Selection struct

+ ClassPass string

+ KeyPass string

+ Observations []string

+ Reason string

+ WorkID string

+ func PlanNext(state Projection, pool string, at int64) (Selection, error)

type Stats

+ Dispatches int

+ Nodes int

+ type SubmitParameters struct

+ Nodes []WorkDefinition

+ type Trace struct

+ PublisherAttempt int

+ SpanID string

+ TraceID string

+ type TraceEvent struct

+ Actor Actor

+ At int64

+ ClaimHandle string

+ ClaimID string

+ CommitID string

+ CompletionID string

+ Control string

+ DispatchID string

+ Disposition string

+ Evidence *TraceEvidence

+ Kind string

+ ObservationID string

+ Observations []string

+ PolicyEpoch string

+ Position Position

+ Previous *string

+ Reason string

+ RequestID string

+ RequestKind string

+ Run *RunBinding

+ RunAttempt int

+ RunID string

+ State string

+ Trace *Trace

+ Value json.RawMessage

+ WorkID string

+ type TraceEvidence struct

+ Attempts int

+ CheckedAt int64

+ Conclusion string

+ Effects string

+ Kind string

+ Principal string

+ Ref string

+ Repository string

+ RunAttempt int

+ RunID string

+ Source string

+ Status string

+ Workflow string

+ type TraceOptions struct

+ ClaimID string

+ Limit int

+ Offset int

+ RequestID string

+ type TracePage struct

+ At int64

+ ClaimID string

+ Events []TraceEvent

+ Limit int

+ NextOffset *int

+ Offset int

+ RequestID string

+ Status string

+ Tip string

+ TotalEvents int

+ TraceAvailability string

+ func TraceQueue(commits []QueueCommit, options TraceOptions, at int64) (TracePage, error)

+ type WorkDefinition struct

+ BatchTrustDomain string

+ DependsOn []Dependency

+ Enqueued int64

+ FairnessKey string

+ GraphID string

+ Kind string

+ NodeKey string

+ Payload json.RawMessage

+ Pool string

+ Priority int

+ ReplacementOf *Replacement

+ Subject *Resource

+ WorkID string

+ WorkerProfile string

+ func NewChildWork(state Projection, actor Actor, payload []byte, nodeKey string, at int64) (WorkDefinition, error)

+ type WorkExplanation struct

+ Barrier string

+ Observations []string

+ Path []string

+ Ready bool

+ Reason string

+ SchedulingEligible bool

+ State string

+ WorkID string

+ func ExplainWork(state Projection, id string, at int64) (WorkExplanation, error)

type WorkState

+ Attempts int

+ Barrier string

+ CancellationClaimID string

+ CancellationCommitID string

+ CancellationReason string

+ ClaimID string

+ CompletionID string

+ Disposition string

+ EffectivePriority int

+ Position Position

+ Result json.RawMessage

+ ResultCommitID string

+ RetryNotBefore int64

+ func (work *WorkState) SchedulingPriority() int

+ type WorkerProfile struct

+ CredentialScope string

+ EffectScope string

+ MaxClaims int

+ Principal string

+ Ref string

+ ShareKeys bool

+ TrustDomain string

+ Workflow string

v0.91.5

Oct 7, 2026

v0.91.4

Oct 6, 2026

v0.91.3

Oct 6, 2026

v0.91.2

Oct 6, 2026

v0.91.1

Oct 6, 2026

v0.91.0

Oct 5, 2026

v0.90.4

Oct 5, 2026

Changes in this version

+ const MaxEnqueued

+ func OldestAvailable(transactions []Transaction) (string, error)

type Projection

+ Available []string

type Transaction

+ Enqueued int64

+ func NewWork(payload []byte) (Transaction, error)

type WorkState

+ Enqueued int64

v0.90.3

Oct 3, 2026

v0.90.2

Oct 2, 2026

Changes in this version

+ const DefaultBranch

+ const FileName

+ func Serialize(transactions []Transaction) ([]byte, error)

+ func WorkID(payload []byte) (string, json.RawMessage, error)

+ type Branch struct

+ Name string

+ Remote string

+ func (b Branch) Read(ctx context.Context) ([]Transaction, error)

+ func (b Branch) Update(ctx context.Context, change func([]Transaction) ([]Transaction, bool, error)) ([]Transaction, bool, error)

+ type ClaimState struct

+ ClaimID string

+ RunID string

+ State string

+ type Projection struct

+ Stats Stats

+ Works []WorkState

+ func Replay(transactions []Transaction) (Projection, error)

+ type Stats struct

+ Available int

+ Cancelled int

+ Claimed int

+ Claims int

+ Completed int

+ Transactions int

+ Work int

+ type Transaction struct

+ AttemptID string

+ ClaimID string

+ Kind string

+ Outcome string

+ RunID string

+ Work json.RawMessage

+ WorkID string

+ func Apply(transactions []Transaction, tx Transaction) ([]Transaction, bool, error)

+ func Compact(transactions []Transaction) ([]Transaction, error)

+ func Parse(data []byte) ([]Transaction, error)

+ type WorkState struct

+ Claims []ClaimState

+ Outcome string

+ State string

+ Winner string

+ Work json.RawMessage

+ WorkID string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL