river

Documentation

Index

• func New(ctx context.Context, dsn string, adm *admin.Service) (jobs.Client, error)
• type Client
  • func (c *Client) CancelJob(ctx context.Context, jobID int64) error
  • func (c *Client) Close(ctx context.Context) error
  • func (c *Client) ResetAllDeployments(ctx context.Context) (*jobs.InsertResult, error)
  • func (c *Client) Work(ctx context.Context) error
• type ErrorHandler
  • func (h *ErrorHandler) HandleError(ctx context.Context, job *rivertype.JobRow, err error) *river.ErrorHandlerResult
  • func (h *ErrorHandler) HandlePanic(ctx context.Context, job *rivertype.JobRow, panicVal any, trace string) *river.ErrorHandlerResult
• type ResetAllDeploymentsArgs
  • func (ResetAllDeploymentsArgs) Kind() string
• type ResetAllDeploymentsWorker
  • func (w *ResetAllDeploymentsWorker) Work(ctx context.Context, job *river.Job[ResetAllDeploymentsArgs]) error
• type ValidateDeploymentsArgs
  • func (ValidateDeploymentsArgs) Kind() string
• type ValidateDeploymentsWorker
  • func (w *ValidateDeploymentsWorker) Work(ctx context.Context, job *river.Job[ValidateDeploymentsArgs]) error

Functions

func New

func New(ctx context.Context, dsn string, adm *admin.Service) (jobs.Client, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func (*Client) CancelJob

func (c *Client) CancelJob(ctx context.Context, jobID int64) error

func (*Client) Close

func (c *Client) Close(ctx context.Context) error

func (*Client) ResetAllDeployments

func (c *Client) ResetAllDeployments(ctx context.Context) (*jobs.InsertResult, error)

NOTE: Add new job trigger functions here

func (*Client) Work

func (c *Client) Work(ctx context.Context) error

type ErrorHandler

type ErrorHandler struct {
	// contains filtered or unexported fields
}

func (*ErrorHandler) HandleError

func (h *ErrorHandler) HandleError(ctx context.Context, job *rivertype.JobRow, err error) *river.ErrorHandlerResult

func (*ErrorHandler) HandlePanic

func (h *ErrorHandler) HandlePanic(ctx context.Context, job *rivertype.JobRow, panicVal any, trace string) *river.ErrorHandlerResult

type ResetAllDeploymentsArgs

type ResetAllDeploymentsArgs struct{}

func (ResetAllDeploymentsArgs) Kind

func (ResetAllDeploymentsArgs) Kind() string

type ResetAllDeploymentsWorker

type ResetAllDeploymentsWorker struct {
	river.WorkerDefaults[ResetAllDeploymentsArgs]
	// contains filtered or unexported fields
}

func (*ResetAllDeploymentsWorker) Work

func (w *ResetAllDeploymentsWorker) Work(ctx context.Context, job *river.Job[ResetAllDeploymentsArgs]) error

type ValidateDeploymentsArgs

type ValidateDeploymentsArgs struct{}

func (ValidateDeploymentsArgs) Kind

func (ValidateDeploymentsArgs) Kind() string

type ValidateDeploymentsWorker

type ValidateDeploymentsWorker struct {
	river.WorkerDefaults[ValidateDeploymentsArgs]
	// contains filtered or unexported fields
}

func (*ValidateDeploymentsWorker) Work

func (w *ValidateDeploymentsWorker) Work(ctx context.Context, job *river.Job[ValidateDeploymentsArgs]) error