Versions in this module Expand all Collapse all v1 v1.0.0 Aug 25, 2026 Changes in this version + const DefaultDefaultConcurrency + const DefaultDeployConcurrency + const DefaultJobTimeout + const DefaultMaxAttempts + const DefaultStopTimeout + const KindBackup + const KindDeploy + const KindScan + const QueueDefault + const QueueDeploy + func AddWorker[T river.JobArgs](w *river.Workers, worker river.Worker[T]) + func NewWorkers() *river.Workers + type BackupArgs struct + BackupID string + func (BackupArgs) Kind() string + func (a BackupArgs) Validate() error + type Client struct + func New(ctx context.Context, st *store.Store, workers *river.Workers, ...) (*Client, error) + func (c *Client) Close() error + func (c *Client) Enqueue(ctx context.Context, args river.JobArgs, opts *river.InsertOpts) (int64, error) + func (c *Client) EnqueueDeployTx(ctx context.Context, tx *sql.Tx, args DeployArgs) (int64, error) + func (c *Client) EnqueueTx(ctx context.Context, tx *sql.Tx, args river.JobArgs, opts *river.InsertOpts) (int64, error) + func (c *Client) Start(ctx context.Context) error + func (c *Client) Stop(ctx context.Context) error + type DeployArgs struct + DeploymentID string + func (DeployArgs) InsertOpts() river.InsertOpts + func (DeployArgs) Kind() string + func (a DeployArgs) Validate() error + type Option func(*options) + func WithDeployConcurrency(n int) Option + func WithRedactor(r *secrets.Redactor) Option + func WithStopTimeout(d time.Duration) Option + type ScanArgs struct + ReleaseID string + func (ScanArgs) Kind() string + func (a ScanArgs) Validate() error
Go to main page