Get returns if the user is a member of the organization.

Error signals the task is done with an error.

Errorf implement ILogger.

Get returns the current value using a read lock, allowing multiple concurrent readers. Safe to call from multiple goroutines simultaneously.

Set replaces the current value using an exclusive write lock. Blocks until all ongoing reads/writes complete.

Debug implement ILogger.

Run starts the workflow, executes all stages sequentially, and tears down the workflow on exit. The runnerCtx must outlive workflow cancellation so th

WriteHeader writes the table header.

Is allows errors.Is to match against ErrExternal types.

Step builder helpers.

Info returns internal queue information.

newTestTracer creates a MockTracer that accepts any number of Trace calls.

Done signals the task is complete.

FromContext returns the Store associated with this context.

New returns a new Runtime for the given workflow spec and options.

WithTracer sets the tracer used to report step state changes.

WithLogger sets the function used to stream step logs.

TODO: refactor this big function into subfunctions in it's own subpackage Run executes a workflow using a backend, tracks its state and reports the st

Poll retrieves and removes a task head of this queue. The filter is applied to each candidate: returning false skips the task, the int is a match scor

Status sends workflow status updates to the forge. Provides visual feedback in forge UI (commit checks, PR status). Failures should be logged but not

newTestLogger creates a noop logger.

newTestStore creates a new database connection for testing purposes. The database driver and connection string are provided by environment variables,

NewClient returns a new client from the CLI context.

New returns a dummy backend.

metadataFileAndOverrideOrDefault will either use the flag default or if metadata file is set only overload if explicit set.

Copy makes a copy of the secret without the value.

HTTP request helper functions. Helper function for making an http GET request.

CreateRepo creates a new repository.

getTracerStates extracts all state.State values passed to Trace() calls on a mockery-generated MockTracer. Thread-safe because mock.Mock.Calls is appe

Write writes the entry to the log.

Name returns the unique identifier of this forge driver. Examples: "github", "gitlab", "gitea", "forgejo", "bitbucket" Must be unique and constant acr

Update performs an atomic read-modify-write operation under a single exclusive lock. The provided function receives the current value and returns the

PushAtOnce pushes multiple tasks to the tail of this queue.

Next blocks until the server provides the next workflow to execute from the queue. This is the primary work-polling mechanism. Agents call this repea

Warn implement ILogger.

newTestRPC creates an RPC instance with common test infrastructure.

String returns a string representation of an Axis as a comma-separated list of environment variables.

wrapGet return error if err not nil or if requested entry do not exist.

String returns the Version set at build time or "dev".

Done signals to the server that the workflow has completed execution. This is called once per workflow after all steps have finished (or workflow was

Users GetUser gets a user by unique ID.

newTestContext builds a gin test context wired to the given store. Configure it by applying the option helpers (withUser, withRepo, withParam, withReq

Hook parses incoming webhook and returns pipeline data. Webhook Processing Flow: 1. HTTP request arrives at /api/hook with forge-specific format 2. W

Load initializes the backend engine and returns metadata about its capabilities and configuration. This is called once after flags are parsed. The bac

ParseRepo parses the repository owner and name from a string.

FormatFlag return format flag with value set based on template if hidden value is set, flag will be hidden.

Wait waits until the task is complete. Also signals via error ErrCancel if workflow got canceled.

Workflow

Repos GetRepo gets a repo by unique ID.

defaultAgent returns a system agent (OrgID=-1) that can access any repo.

newDummyRuntime creates a Runtime backed by the dummy engine with a pre-setup workflow so individual step methods can be tested in isolation.

CreatePipeline creates a new pipeline and steps.