activities

package
v0.19.1069 Latest Latest
Warning

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

Go to latest
Published: Jul 17, 2026 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	LimitQueueSize = 10
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Activities

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

func New

func New(params Params) *Activities

func (*Activities) PkgWorkflowsJobCancelJob

func (a *Activities) PkgWorkflowsJobCancelJob(ctx context.Context, req *CancelJobRequest) error

@temporal-gen-v2 activity @by-field ID

func (*Activities) PkgWorkflowsJobGetJob

func (a *Activities) PkgWorkflowsJobGetJob(ctx context.Context, req *GetJobRequest) (*app.RunnerJob, error)

@temporal-gen-v2 activity @by-field ID

func (*Activities) PkgWorkflowsJobGetRunnerJobGroupQueue added in v0.19.872

func (a *Activities) PkgWorkflowsJobGetRunnerJobGroupQueue(ctx context.Context, req *GetRunnerJobGroupQueueRequest) (*GetRunnerJobGroupQueueResponse, error)

GetRunnerJobGroupQueue returns the per-job-group queue ID for the given runner+job pair when the parallel-runner-jobs feature flag is enabled, or empty string otherwise.

@temporal-gen-v2 activity @start-to-close-timeout 1m

func (*Activities) PkgWorkflowsJobGetRunnerJobQueue

func (a *Activities) PkgWorkflowsJobGetRunnerJobQueue(ctx context.Context, req *GetRunnerJobQueueRequest) ([]*app.RunnerJob, error)

@temporal-gen-v2 activity @by-field JobID

type CancelJobRequest

type CancelJobRequest struct {
	ID string `validate:"required"`
}

type GetJobRequest

type GetJobRequest struct {
	ID string `validate:"required"`
}

type GetRunnerJobGroupQueueRequest added in v0.19.872

type GetRunnerJobGroupQueueRequest struct {
	RunnerID string `validate:"required"`
	JobID    string `validate:"required"`
}

type GetRunnerJobGroupQueueResponse added in v0.19.872

type GetRunnerJobGroupQueueResponse struct {
	// QueueID is the ID of the job-group queue to use, or empty string if the
	// parallel-runner-jobs feature is not enabled or no queue exists for the group.
	QueueID string
}

type GetRunnerJobQueueRequest

type GetRunnerJobQueueRequest struct {
	JobID string `validate:"required"`
}

type Params

type Params struct {
	fx.In

	DB *gorm.DB `name:"psql"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL