river

package
v0.78.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 22, 2025 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New 

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

Types

type BillingReporterArgs added in v0.78.0 

type BillingReporterArgs struct{}

func (BillingReporterArgs) Kind added in v0.78.0 

func (BillingReporterArgs) Kind() string

type BillingReporterWorker added in v0.78.0 

type BillingReporterWorker struct {
	river.WorkerDefaults[BillingReporterArgs]
	// contains filtered or unexported fields
}

func (*BillingReporterWorker) Work added in v0.78.0 

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

NewBillingReporterWorker creates a new worker that reports billing information.

type CheckProvisionersArgs added in v0.78.0 

type CheckProvisionersArgs struct{}

func (CheckProvisionersArgs) Kind added in v0.78.0 

func (CheckProvisionersArgs) Kind() string

type CheckProvisionersWorker added in v0.78.0 

type CheckProvisionersWorker struct {
	river.WorkerDefaults[CheckProvisionersArgs]
	// contains filtered or unexported fields
}

func (*CheckProvisionersWorker) Work added in v0.78.0 

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

type Client 

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

func (*Client) BillingReporter added in v0.78.0 

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

func (*Client) CancelJob 

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

func (*Client) CheckProvisioners added in v0.78.0 

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

func (*Client) Close 

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

func (*Client) CustomerAddressUpdated added in v0.50.0 

func (c *Client) CustomerAddressUpdated(ctx context.Context, paymentCustomerID string, eventTime time.Time) (*jobs.InsertResult, error)

func (*Client) DeleteExpiredAuthCodes added in v0.78.0 

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

func (*Client) DeleteExpiredDeviceAuthCodes added in v0.78.0 

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

func (*Client) DeleteExpiredTokens added in v0.78.0 

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

func (*Client) DeleteExpiredVirtualFiles added in v0.78.0 

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

func (*Client) DeleteOrg added in v0.55.2 

func (c *Client) DeleteOrg(ctx context.Context, orgID string) (*jobs.InsertResult, error)

func (*Client) DeleteUnusedAssets added in v0.78.0 

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

func (*Client) DeploymentsHealthCheck added in v0.78.0 

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

func (*Client) EnqueueByKind added in v0.78.0 

func (c *Client) EnqueueByKind(ctx context.Context, kind string) (*jobs.InsertResult, error)

func (*Client) HibernateExpiredDeployments added in v0.78.0 

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

func (*Client) HibernateInactiveOrgs added in v0.57.0 

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

func (*Client) InitOrgBilling added in v0.50.0 

func (c *Client) InitOrgBilling(ctx context.Context, orgID string) (*jobs.InsertResult, error)

func (*Client) PaymentFailed added in v0.50.0 

func (c *Client) PaymentFailed(ctx context.Context, billingCustomerID, invoiceID, invoiceNumber, invoiceURL, amount, currency string, dueDate, failedAt time.Time) (*jobs.InsertResult, error)

func (*Client) PaymentMethodAdded added in v0.50.0 

func (c *Client) PaymentMethodAdded(ctx context.Context, paymentMethodID, paymentCustomerID, paymentType string, eventTime time.Time) (*jobs.InsertResult, error)

func (*Client) PaymentMethodRemoved added in v0.50.0 

func (c *Client) PaymentMethodRemoved(ctx context.Context, paymentMethodID, paymentCustomerID string, eventTime time.Time) (*jobs.InsertResult, error)

func (*Client) PaymentSuccess added in v0.50.0 

func (c *Client) PaymentSuccess(ctx context.Context, billingCustomerID, invoiceID string) (*jobs.InsertResult, error)

func (*Client) PlanChanged added in v0.56.0 

func (c *Client) PlanChanged(ctx context.Context, billingCustomerID string) (*jobs.InsertResult, error)

func (*Client) ReconcileDeployment added in v0.78.0 

func (c *Client) ReconcileDeployment(ctx context.Context, deploymentID string) (*jobs.InsertResult, error)

func (*Client) RepairOrgBilling added in v0.50.0 

func (c *Client) RepairOrgBilling(ctx context.Context, orgID string) (*jobs.InsertResult, error)

func (*Client) ResetAllDeployments 

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

func (*Client) RunAutoscaler added in v0.78.0 

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

func (*Client) StartOrgTrial added in v0.50.0 

func (c *Client) StartOrgTrial(ctx context.Context, orgID string) (*jobs.InsertResult, error)

func (*Client) Work 

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

type CustomerAddressUpdatedArgs added in v0.50.0 

type CustomerAddressUpdatedArgs struct {
	PaymentCustomerID string
	EventTime         time.Time
}

func (CustomerAddressUpdatedArgs) Kind added in v0.50.0 

func (CustomerAddressUpdatedArgs) Kind() string

type CustomerAddressUpdatedWorker added in v0.50.0 

type CustomerAddressUpdatedWorker struct {
	river.WorkerDefaults[CustomerAddressUpdatedArgs]
	// contains filtered or unexported fields
}

func (*CustomerAddressUpdatedWorker) Work added in v0.50.0 

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

type DeleteExpiredAuthCodesArgs added in v0.78.0 

type DeleteExpiredAuthCodesArgs struct{}

func (DeleteExpiredAuthCodesArgs) Kind added in v0.78.0 

func (DeleteExpiredAuthCodesArgs) Kind() string

type DeleteExpiredAuthCodesWorker added in v0.78.0 

type DeleteExpiredAuthCodesWorker struct {
	river.WorkerDefaults[DeleteExpiredAuthCodesArgs]
	// contains filtered or unexported fields
}

func (*DeleteExpiredAuthCodesWorker) Work added in v0.78.0 

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

type DeleteExpiredDeviceAuthCodesArgs added in v0.78.0 

type DeleteExpiredDeviceAuthCodesArgs struct{}

func (DeleteExpiredDeviceAuthCodesArgs) Kind added in v0.78.0 

func (DeleteExpiredDeviceAuthCodesArgs) Kind() string

type DeleteExpiredDeviceAuthCodesWorker added in v0.78.0 

type DeleteExpiredDeviceAuthCodesWorker struct {
	river.WorkerDefaults[DeleteExpiredDeviceAuthCodesArgs]
	// contains filtered or unexported fields
}

func (*DeleteExpiredDeviceAuthCodesWorker) Work added in v0.78.0 

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

type DeleteExpiredTokensArgs added in v0.78.0 

type DeleteExpiredTokensArgs struct{}

func (DeleteExpiredTokensArgs) Kind added in v0.78.0 

func (DeleteExpiredTokensArgs) Kind() string

type DeleteExpiredTokensWorker added in v0.78.0 

type DeleteExpiredTokensWorker struct {
	river.WorkerDefaults[DeleteExpiredTokensArgs]
	// contains filtered or unexported fields
}

func (*DeleteExpiredTokensWorker) Work added in v0.78.0 

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

type DeleteExpiredVirtualFilesArgs added in v0.78.0 

type DeleteExpiredVirtualFilesArgs struct{}

func (DeleteExpiredVirtualFilesArgs) Kind added in v0.78.0 

func (DeleteExpiredVirtualFilesArgs) Kind() string

type DeleteExpiredVirtualFilesWorker added in v0.78.0 

type DeleteExpiredVirtualFilesWorker struct {
	river.WorkerDefaults[DeleteExpiredVirtualFilesArgs]
	// contains filtered or unexported fields
}

func (*DeleteExpiredVirtualFilesWorker) Work added in v0.78.0 

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

type DeleteOrgArgs added in v0.55.2 

type DeleteOrgArgs struct {
	OrgID string
}

func (DeleteOrgArgs) Kind added in v0.55.2 

func (DeleteOrgArgs) Kind() string

type DeleteOrgWorker added in v0.55.2 

type DeleteOrgWorker struct {
	river.WorkerDefaults[DeleteOrgArgs]
	// contains filtered or unexported fields
}

func (*DeleteOrgWorker) Work added in v0.55.2 

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

Work This worker handles the deletion of an organization and cancels all subscriptions related to it

type DeleteUnusedAssetsArgs added in v0.78.0 

type DeleteUnusedAssetsArgs struct{}

func (DeleteUnusedAssetsArgs) Kind added in v0.78.0 

func (DeleteUnusedAssetsArgs) Kind() string

type DeleteUnusedAssetsWorker added in v0.78.0 

type DeleteUnusedAssetsWorker struct {
	river.WorkerDefaults[DeleteUnusedAssetsArgs]
	// contains filtered or unexported fields
}

func (*DeleteUnusedAssetsWorker) Work added in v0.78.0 

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

type DeleteUnusedServiceTokenArgs added in v0.78.0 

type DeleteUnusedServiceTokenArgs struct{}

func (DeleteUnusedServiceTokenArgs) Kind added in v0.78.0 

func (DeleteUnusedServiceTokenArgs) Kind() string

type DeleteUnusedServiceTokenWorker added in v0.78.0 

type DeleteUnusedServiceTokenWorker struct {
	river.WorkerDefaults[DeleteUnusedServiceTokenArgs]
	// contains filtered or unexported fields
}

func (*DeleteUnusedServiceTokenWorker) Work added in v0.78.0 

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

NewDeleteUnusedServiceTokenWorker creates a new worker that deletes unused service tokens.

type DeleteUnusedUserTokenArgs added in v0.78.0 

type DeleteUnusedUserTokenArgs struct{}

func (DeleteUnusedUserTokenArgs) Kind added in v0.78.0 

func (DeleteUnusedUserTokenArgs) Kind() string

type DeleteUnusedUserTokenWorker added in v0.78.0 

type DeleteUnusedUserTokenWorker struct {
	river.WorkerDefaults[DeleteUnusedUserTokenArgs]
	// contains filtered or unexported fields
}

func (*DeleteUnusedUserTokenWorker) Work added in v0.78.0 

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

NewDeleteUnusedUserTokenWorker creates a new worker that deletes unused user tokens.

type DeploymentsHealthCheckArgs added in v0.78.0 

type DeploymentsHealthCheckArgs struct{}

func (DeploymentsHealthCheckArgs) Kind added in v0.78.0 

func (DeploymentsHealthCheckArgs) Kind() string

type DeploymentsHealthCheckWorker added in v0.78.0 

type DeploymentsHealthCheckWorker struct {
	river.WorkerDefaults[DeploymentsHealthCheckArgs]
	// contains filtered or unexported fields
}

func (*DeploymentsHealthCheckWorker) Work added in v0.78.0 

func (w *DeploymentsHealthCheckWorker) Work(ctx context.Context, job *river.Job[DeploymentsHealthCheckArgs]) 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 HibernateExpiredDeploymentsArgs added in v0.78.0 

type HibernateExpiredDeploymentsArgs struct{}

func (HibernateExpiredDeploymentsArgs) Kind added in v0.78.0 

func (HibernateExpiredDeploymentsArgs) Kind() string

type HibernateExpiredDeploymentsWorker added in v0.78.0 

type HibernateExpiredDeploymentsWorker struct {
	river.WorkerDefaults[HibernateExpiredDeploymentsArgs]
	// contains filtered or unexported fields
}

func (*HibernateExpiredDeploymentsWorker) Work added in v0.78.0 

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

type HibernateInactiveOrgsArgs added in v0.57.0 

type HibernateInactiveOrgsArgs struct{}

func (HibernateInactiveOrgsArgs) Kind added in v0.57.0 

func (HibernateInactiveOrgsArgs) Kind() string

type HibernateInactiveOrgsWorker added in v0.57.0 

type HibernateInactiveOrgsWorker struct {
	river.WorkerDefaults[HibernateInactiveOrgsArgs]
	// contains filtered or unexported fields
}

func (*HibernateInactiveOrgsWorker) Work added in v0.57.0 

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

type InitOrgBillingArgs added in v0.50.0 

type InitOrgBillingArgs struct {
	OrgID string
}

func (InitOrgBillingArgs) Kind added in v0.50.0 

func (InitOrgBillingArgs) Kind() string

type InitOrgBillingWorker added in v0.50.0 

type InitOrgBillingWorker struct {
	river.WorkerDefaults[InitOrgBillingArgs]
	// contains filtered or unexported fields
}

func (*InitOrgBillingWorker) Work added in v0.50.0 

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

Work This worker initializes the billing for an organization

type PaymentFailedArgs added in v0.50.0 

type PaymentFailedArgs struct {
	BillingCustomerID string
	InvoiceID         string
	InvoiceNumber     string
	InvoiceURL        string
	Amount            string
	Currency          string
	DueDate           time.Time
	FailedAt          time.Time
}

func (PaymentFailedArgs) Kind added in v0.50.0 

func (PaymentFailedArgs) Kind() string

type PaymentFailedGracePeriodCheckArgs added in v0.50.0 

type PaymentFailedGracePeriodCheckArgs struct{}

func (PaymentFailedGracePeriodCheckArgs) Kind added in v0.50.0 

func (PaymentFailedGracePeriodCheckArgs) Kind() string

type PaymentFailedGracePeriodCheckWorker added in v0.50.0 

type PaymentFailedGracePeriodCheckWorker struct {
	river.WorkerDefaults[PaymentFailedGracePeriodCheckArgs]
	// contains filtered or unexported fields
}

func (*PaymentFailedGracePeriodCheckWorker) Work added in v0.50.0 

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

type PaymentFailedWorker added in v0.50.0 

type PaymentFailedWorker struct {
	river.WorkerDefaults[PaymentFailedArgs]
	// contains filtered or unexported fields
}

func (*PaymentFailedWorker) Work added in v0.50.0 

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

type PaymentMethodAddedArgs added in v0.50.0 

type PaymentMethodAddedArgs struct {
	PaymentMethodID   string
	PaymentCustomerID string
	PaymentType       string
	EventTime         time.Time
}

func (PaymentMethodAddedArgs) Kind added in v0.50.0 

func (PaymentMethodAddedArgs) Kind() string

type PaymentMethodAddedWorker added in v0.50.0 

type PaymentMethodAddedWorker struct {
	river.WorkerDefaults[PaymentMethodAddedArgs]
	// contains filtered or unexported fields
}

func (*PaymentMethodAddedWorker) Work added in v0.50.0 

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

type PaymentMethodRemovedArgs added in v0.50.0 

type PaymentMethodRemovedArgs struct {
	PaymentMethodID   string
	PaymentCustomerID string
	EventTime         time.Time
}

func (PaymentMethodRemovedArgs) Kind added in v0.50.0 

func (PaymentMethodRemovedArgs) Kind() string

type PaymentMethodRemovedWorker added in v0.50.0 

type PaymentMethodRemovedWorker struct {
	river.WorkerDefaults[PaymentMethodRemovedArgs]
	// contains filtered or unexported fields
}

func (*PaymentMethodRemovedWorker) Work added in v0.50.0 

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

type PaymentSuccessArgs added in v0.50.0 

type PaymentSuccessArgs struct {
	BillingCustomerID string
	InvoiceID         string
}

func (PaymentSuccessArgs) Kind added in v0.50.0 

func (PaymentSuccessArgs) Kind() string

type PaymentSuccessWorker added in v0.50.0 

type PaymentSuccessWorker struct {
	river.WorkerDefaults[PaymentSuccessArgs]
	// contains filtered or unexported fields
}

func (*PaymentSuccessWorker) Work added in v0.50.0 

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

type PlanChangedArgs added in v0.56.0 

type PlanChangedArgs struct {
	BillingCustomerID string
}

func (PlanChangedArgs) Kind added in v0.56.0 

func (PlanChangedArgs) Kind() string

type PlanChangedWorker added in v0.56.0 

type PlanChangedWorker struct {
	river.WorkerDefaults[PlanChangedArgs]
	// contains filtered or unexported fields
}

func (*PlanChangedWorker) Work added in v0.56.0 

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

type ReconcileDeploymentArgs added in v0.78.0 

type ReconcileDeploymentArgs struct {
	DeploymentID string
}

func (ReconcileDeploymentArgs) Kind added in v0.78.0 

func (ReconcileDeploymentArgs) Kind() string

type ReconcileDeploymentWorker added in v0.78.0 

type ReconcileDeploymentWorker struct {
	river.WorkerDefaults[ReconcileDeploymentArgs]
	// contains filtered or unexported fields
}

func (*ReconcileDeploymentWorker) Work added in v0.78.0 

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

ReconcileDeploymentWorker is a state machine, it reconciles the state of a deployment based on its desired and current status. This job is responsible for transitioning deployments through their lifecycle states, such as starting, updating, stopping, and deleting deployments. We handle all deployment state transitions in this job to ensure consistency and to avoid concurrent conflicting operations on the same deployment.

type RepairOrgBillingArgs added in v0.50.0 

type RepairOrgBillingArgs struct {
	OrgID string
}

func (RepairOrgBillingArgs) Kind added in v0.50.0 

func (RepairOrgBillingArgs) Kind() string

type RepairOrgBillingWorker added in v0.50.0 

type RepairOrgBillingWorker struct {
	river.WorkerDefaults[RepairOrgBillingArgs]
	// contains filtered or unexported fields
}

func (*RepairOrgBillingWorker) Work added in v0.50.0 

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

Work This worker repairs the billing for an organization

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 RunAutoscalerArgs added in v0.78.0 

type RunAutoscalerArgs struct{}

func (RunAutoscalerArgs) Kind added in v0.78.0 

func (RunAutoscalerArgs) Kind() string

type RunAutoscalerWorker added in v0.78.0 

type RunAutoscalerWorker struct {
	river.WorkerDefaults[RunAutoscalerArgs]
	// contains filtered or unexported fields
}

func (*RunAutoscalerWorker) Work added in v0.78.0 

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

type StartTrialArgs added in v0.50.0 

type StartTrialArgs struct {
	OrgID string
}

func (StartTrialArgs) Kind added in v0.50.0 

func (StartTrialArgs) Kind() string

type StartTrialWorker added in v0.50.0 

type StartTrialWorker struct {
	river.WorkerDefaults[StartTrialArgs]
	// contains filtered or unexported fields
}

func (*StartTrialWorker) Work added in v0.50.0 

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

Work This worker starts the trial for an organization

type SubscriptionCancellationCheckArgs added in v0.50.0 

type SubscriptionCancellationCheckArgs struct{}

func (SubscriptionCancellationCheckArgs) Kind added in v0.50.0 

func (SubscriptionCancellationCheckArgs) Kind() string

type SubscriptionCancellationCheckWorker added in v0.50.0 

type SubscriptionCancellationCheckWorker struct {
	river.WorkerDefaults[SubscriptionCancellationCheckArgs]
	// contains filtered or unexported fields
}

func (*SubscriptionCancellationCheckWorker) Work added in v0.50.0 

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

Work This worker runs at end of the current subscription term after subscription cancellation

type TrialEndCheckArgs added in v0.50.0 

type TrialEndCheckArgs struct{}

func (TrialEndCheckArgs) Kind added in v0.50.0 

func (TrialEndCheckArgs) Kind() string

type TrialEndCheckWorker added in v0.50.0 

type TrialEndCheckWorker struct {
	river.WorkerDefaults[TrialEndCheckArgs]
	// contains filtered or unexported fields
}

func (*TrialEndCheckWorker) Work added in v0.50.0 

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

type TrialEndingSoonArgs added in v0.50.0 

type TrialEndingSoonArgs struct{}

func (TrialEndingSoonArgs) Kind added in v0.50.0 

func (TrialEndingSoonArgs) Kind() string

type TrialEndingSoonWorker added in v0.50.0 

type TrialEndingSoonWorker struct {
	river.WorkerDefaults[TrialEndingSoonArgs]
	// contains filtered or unexported fields
}

func (*TrialEndingSoonWorker) Work added in v0.50.0 

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

type TrialGracePeriodCheckArgs added in v0.50.0 

type TrialGracePeriodCheckArgs struct{}

func (TrialGracePeriodCheckArgs) Kind added in v0.50.0 

func (TrialGracePeriodCheckArgs) Kind() string

type TrialGracePeriodCheckWorker added in v0.50.0 

type TrialGracePeriodCheckWorker struct {
	river.WorkerDefaults[TrialGracePeriodCheckArgs]
	// contains filtered or unexported fields
}

func (*TrialGracePeriodCheckWorker) Work added in v0.50.0 

func (w *TrialGracePeriodCheckWorker) Work(ctx context.Context, job *river.Job[TrialGracePeriodCheckArgs]) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.