Documentation
¶
Index ¶
- Constants
- type Activities
- func (a *Activities) PkgWorkflowsJobCancelJob(ctx context.Context, req *CancelJobRequest) error
- func (a *Activities) PkgWorkflowsJobGetJob(ctx context.Context, req *GetJobRequest) (*app.RunnerJob, error)
- func (a *Activities) PkgWorkflowsJobGetRunnerJobGroupQueue(ctx context.Context, req *GetRunnerJobGroupQueueRequest) (*GetRunnerJobGroupQueueResponse, error)
- func (a *Activities) PkgWorkflowsJobGetRunnerJobQueue(ctx context.Context, req *GetRunnerJobQueueRequest) ([]*app.RunnerJob, error)
- type CancelJobRequest
- type GetJobRequest
- type GetRunnerJobGroupQueueRequest
- type GetRunnerJobGroupQueueResponse
- type GetRunnerJobQueueRequest
- type Params
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 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"`
}
Click to show internal directories.
Click to hide internal directories.