Join completes broker registration using a join token. Returns the HMAC secret key for future authentication.

tid deterministically maps a human-readable test identifier (e.g. "user-1") to a stable UUID string. The Ent-backed store uses UUID primary keys, so t

Set creates or updates an environment variable.

SetField sets the value of a field with the given name. It returns an error if the field is not defined in the schema, or if the type mismatched the f

MkdirAll creates the directory tree for the mountpoint.

Get returns a specific environment variable by key.

doRequest performs an HTTP request against the test server. It automatically includes the dev auth token for authenticated endpoints.

writeError writes a JSON error response. For 5xx errors, it logs the error details for debugging.

Info returns broker information.

Len returns the number of registered channels.

testServer creates a test server with an in-memory SQLite store. The server is configured with dev auth enabled using testDevToken.

String returns a human-readable label for the mode.

get performs an HTTP GET request with fallback.

Debug returns a new debug-client. It's used to get verbose logging on specific operations. client.Debug(). AccessPolicy. Query(). Count(ctx)

Query calls tx.Query.

setContextOp returns a new context with the given QueryContext attached (including its op) in case it does not exist.

writeErrorFromErr writes an error response based on a Go error. For 5xx errors, it logs the underlying error for debugging.

ReadFile reads a harness config file through the Hub API.

ClearField clears the value of the field with the given name. It returns an error if the field is not defined in the schema.

Where adds a new predicate for the UserQuery builder.

Helper functions writeJSON writes a JSON response.

Lifecycle

Save writes the given key-value map to the integration configuration store.

String implements the fmt.Stringer.

Run executes the operation. The context is cancelled if the server shuts down. The logger captures output that is stored in the run/operation's log fi

CreateProject creates a new project record. Returns ErrAlreadyExists if a project with the same slug exists.

Close flushes any pending message buffers. Must be called before the process exits to ensure buffered messages are delivered.

Debugf prints a debug message to stderr if debug mode is enabled. The message is prefixed with a timestamp and [DEBUG].

Dialect returns the dialect of the driver we started the transaction from.

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

MethodNotAllowed writes a 405 Method Not Allowed response.

CreateRuntimeBroker creates a new runtime broker record.

CreateAgent creates an agent on a remote runtime broker. brokerID is used for HMAC authentication lookup.

ValidationError writes a 400 Bad Request response for validation failures.

parseUUID parses a string UUID, returning store.ErrInvalidInput on failure.

mapError converts Ent errors to store errors.

Stop terminates an agent

Done returns a channel that is closed when the child process exits.

Dir returns the directory path of the store.

Scan applies the selector query and scans the result into the given value.

isJSONOutput returns true if the output format is set to JSON.

Handler returns the HTTP handler for the server. This is useful for testing without starting a listener.

Create creates a new skill.

GetAgent returns an agent by ID or slug within a project.

withHooks invokes the builder operation with the given hooks, if any.

BadRequest writes a 400 Bad Request response.

Start launches a new agent with the given configuration

Created returns the value of the "created" field in the mutation.

NewAuthenticatedUser creates a new AuthenticatedUser.

Write sends data to the stream.

NotFound writes a 404 Not Found response.

Close releases any resources held by the storage client.

NewUUID generates a new UUID string.

Handler returns the HTTP handler for the server. This is useful for testing without starting a listener.

IsNotFound returns a boolean indicating whether the error is a not found error.

GetUserIdentityFromContext returns the user identity if present.

DefaultServerConfig returns the default server configuration.

Clone creates a copy of a template.

CreateUser creates a new user record.

Close shuts down the event bus and releases resources.

readJSON reads JSON from request body.

contextWithIdentity returns a new context with the identity set.

Parse parses raw input data into a normalized Event.

CheckAccess evaluates whether the given identity is allowed to perform the specified action on the resource.

Load reads the integration configuration and returns its contents as a flat key-value map suitable for merging into a plugin's Config map.

New creates a new Hub API client.

New creates a new Runtime Broker API server.

Query returns log entries matching the given options.

Status returns the value of the "status" field in the mutation.

doRequestAsUser creates a user token and performs an HTTP request as that user.

GetProject retrieves a project by ID. Returns ErrNotFound if the project doesn't exist.

NewInstruction creates a new instruction message with standard defaults.

outputJSON pretty-prints a value as JSON to stdout.

CreateGroup creates a new group record. Returns ErrAlreadyExists if a group with the same slug exists.

List returns active agents

Updated returns the value of the "updated" field in the mutation.

AddProjectProvider adds a broker as a provider to a project.

Update allows overriding fields `UPDATE` values. See the AgentCreate.OnConflict documentation for more info.

Update allows overriding fields `UPDATE` values. See the AgentCreateBulk.OnConflict documentation for more info.

LoadSettings loads and merges settings from the hierarchy using Koanf. Priority: Env vars > Project > Global > Defaults Supports both YAML (.yaml/.yml

InternalError writes a 500 Internal Server Error response.

RuntimeError writes a 502 Bad Gateway response for runtime broker errors.

Result returns the value of the "result" field in the mutation.