Documentation
¶
Overview ¶
Package cloudrun implements the CloudDispatcher interface using the Cloud Run Jobs Admin API v2. It triggers job executions with per-execution environment variable overrides.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher implements coordinator.CloudDispatcher using Cloud Run Jobs API.
func NewDispatcher ¶
func NewDispatcher(ctx context.Context, projectID, region, prefix string) (*Dispatcher, error)
NewDispatcher creates a new Cloud Run Jobs dispatcher. It creates a gRPC client to the Cloud Run Admin API.
func (*Dispatcher) Dispatch ¶
func (d *Dispatcher) Dispatch(ctx context.Context, params coordinator.DispatchParams) error
Dispatch triggers a Cloud Run Job execution with per-execution env var overrides. The job is identified by the pattern: projects/{project}/locations/{region}/jobs/{prefix}-agent-executor This matches the Terraform-defined job name in cloud_run_jobs.tf.
Source Files
Click to show internal directories.
Click to hide internal directories.