tasktypes

package
v0.52.4 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckTenantQueueToTask added in v0.42.0 

func CheckTenantQueueToTask(tenantId, queueName string, isStepQueued bool, isSlotReleased bool) *msgqueue.Message

func JobRunCancelledToTask added in v0.25.0 

func JobRunCancelledToTask(tenantId, jobRunId string, reason *string) *msgqueue.Message

func JobRunQueuedToTask 

func JobRunQueuedToTask(tenantId, jobRunId string) *msgqueue.Message

func StepRunCancelToTask added in v0.19.0 

func StepRunCancelToTask(stepRun *dbsqlc.GetStepRunForEngineRow, reason string, propagateToChildren bool) *msgqueue.Message

func StepRunFailedToTask added in v0.48.2 

func StepRunFailedToTask(stepRun *dbsqlc.GetStepRunForEngineRow, errorReason string, failedAt *time.Time) *msgqueue.Message

func StepRunQueuedToTask 

func StepRunQueuedToTask(stepRun *dbsqlc.GetStepRunForEngineRow) *msgqueue.Message

func StepRunReplayToTask added in v0.28.1 

func StepRunReplayToTask(stepRun *dbsqlc.GetStepRunForEngineRow, inputData []byte) *msgqueue.Message

func StepRunRetryToTask added in v0.11.0 

func StepRunRetryToTask(stepRun *dbsqlc.GetStepRunForEngineRow, inputData []byte, err string) *msgqueue.Message

func TenantToGroupKeyActionRequeueTask added in v0.8.0 

func TenantToGroupKeyActionRequeueTask(tenant db.TenantModel) *msgqueue.Message

func WorkflowRunFinishedToTask added in v0.10.2 

func WorkflowRunFinishedToTask(tenantId, workflowRunId, status string) *msgqueue.Message

func WorkflowRunQueuedToTask added in v0.8.0 

func WorkflowRunQueuedToTask(tenantId, workflowRunId string) *msgqueue.Message

func WorkflowRunReplayToTask added in v0.39.0 

func WorkflowRunReplayToTask(tenantId, workflowRunId string) *msgqueue.Message

Types

type CancelCronTaskMetadata 

type CancelCronTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type CancelCronTaskPayload 

type CancelCronTaskPayload struct {
	CronParentId      string `json:"cron_parent_id" validate:"required,uuid"`
	Cron              string `json:"cron" validate:"required"`
	WorkflowVersionId string `json:"workflow_version_id" validate:"required,uuid"`
}

type CancelGetGroupKeyRunTimeoutTaskMetadata added in v0.8.0 

type CancelGetGroupKeyRunTimeoutTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type CancelGetGroupKeyRunTimeoutTaskPayload added in v0.8.0 

type CancelGetGroupKeyRunTimeoutTaskPayload struct {
	GetGroupKeyRunId string `json:"get_group_key_run_id" validate:"required,uuid"`
}

type CancelStepRunTimeoutTaskMetadata 

type CancelStepRunTimeoutTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type CancelStepRunTimeoutTaskPayload 

type CancelStepRunTimeoutTaskPayload struct {
	StepRunId string `json:"step_run_id" validate:"required,uuid"`
}

type CancelWorkflowTaskMetadata 

type CancelWorkflowTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type CancelWorkflowTaskPayload 

type CancelWorkflowTaskPayload struct {
	ScheduledWorkflowId string `json:"scheduled_workflow_id" validate:"required,uuid"`
	TriggerAt           string `json:"trigger_at" validate:"required"`
	WorkflowVersionId   string `json:"workflow_version_id" validate:"required,uuid"`
}

type CheckTenantQueueMetadata added in v0.42.0 

type CheckTenantQueueMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type CheckTenantQueuePayload added in v0.50.0 

type CheckTenantQueuePayload struct {
	IsStepQueued   bool   `json:"is_step_queued"`
	IsSlotReleased bool   `json:"is_slot_released"`
	QueueName      string `json:"queue_name"`
}

type EventTaskMetadata 

type EventTaskMetadata struct {
	EventKey string `json:"event_key" validate:"required"`
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type EventTaskPayload 

type EventTaskPayload struct {
	EventId                 string `json:"event_id" validate:"required,uuid"`
	EventKey                string `json:"event_key" validate:"required"`
	EventData               string `json:"event_data" validate:"required"`
	EventAdditionalMetadata string `json:"event_additional_metadata"`
}

type GetGroupKeyRunFailedTaskMetadata added in v0.8.0 

type GetGroupKeyRunFailedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type GetGroupKeyRunFailedTaskPayload added in v0.8.0 

type GetGroupKeyRunFailedTaskPayload struct {
	GetGroupKeyRunId string `json:"get_group_key_run_id" validate:"required,uuid"`
	FailedAt         string `json:"failed_at" validate:"required"`
	Error            string `json:"error" validate:"required"`
}

type GetGroupKeyRunFinishedTaskMetadata added in v0.8.0 

type GetGroupKeyRunFinishedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type GetGroupKeyRunFinishedTaskPayload added in v0.8.0 

type GetGroupKeyRunFinishedTaskPayload struct {
	GetGroupKeyRunId string `json:"get_group_key_run_id" validate:"required,uuid"`
	FinishedAt       string `json:"finished_at" validate:"required"`
	GroupKey         string `json:"group_key"`
}

type GetGroupKeyRunStartedTaskMetadata added in v0.8.0 

type GetGroupKeyRunStartedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type GetGroupKeyRunStartedTaskPayload added in v0.8.0 

type GetGroupKeyRunStartedTaskPayload struct {
	GetGroupKeyRunId string `json:"get_group_key_run_id" validate:"required,uuid"`
	StartedAt        string `json:"started_at" validate:"required"`
}

type GetGroupKeyRunTimedOutTaskMetadata added in v0.8.0 

type GetGroupKeyRunTimedOutTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type GetGroupKeyRunTimedOutTaskPayload added in v0.8.0 

type GetGroupKeyRunTimedOutTaskPayload struct {
	GetGroupKeyRunId string `json:"get_group_key_run_id" validate:"required,uuid"`
}

type GroupKeyActionAssignedTaskMetadata added in v0.8.0 

type GroupKeyActionAssignedTaskMetadata struct {
	TenantId     string `json:"tenant_id" validate:"required,uuid"`
	DispatcherId string `json:"dispatcher_id" validate:"required,uuid"`
}

type GroupKeyActionAssignedTaskPayload added in v0.8.0 

type GroupKeyActionAssignedTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	WorkerId      string `json:"worker_id" validate:"required,uuid"`
}

type GroupKeyActionRequeueTaskMetadata added in v0.8.0 

type GroupKeyActionRequeueTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type GroupKeyActionRequeueTaskPayload added in v0.8.0 

type GroupKeyActionRequeueTaskPayload struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type JobRunCancelledTaskMetadata added in v0.25.0 

type JobRunCancelledTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type JobRunCancelledTaskPayload added in v0.25.0 

type JobRunCancelledTaskPayload struct {
	JobRunId string  `json:"job_run_id" validate:"required,uuid"`
	Reason   *string `json:"reason,omitempty"`
}

type JobRunQueuedTaskMetadata 

type JobRunQueuedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type JobRunQueuedTaskPayload 

type JobRunQueuedTaskPayload struct {
	JobRunId string `json:"job_run_id" validate:"required,uuid"`
}

type JobRunTimedOutTaskMetadata 

type JobRunTimedOutTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type JobRunTimedOutTaskPayload 

type JobRunTimedOutTaskPayload struct {
	JobRunId string `json:"job_run_id" validate:"required,uuid"`
}

type RemoveTickerTaskMetadata 

type RemoveTickerTaskMetadata struct{}

type RemoveTickerTaskPayload 

type RemoveTickerTaskPayload struct {
	TickerId string `json:"ticker_id" validate:"required,uuid"`
}

type ReplayWorkflowRunTaskMetadata added in v0.39.0 

type ReplayWorkflowRunTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type ReplayWorkflowRunTaskPayload added in v0.39.0 

type ReplayWorkflowRunTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
}

type ScheduleCronTaskMetadata 

type ScheduleCronTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type ScheduleCronTaskPayload 

type ScheduleCronTaskPayload struct {
	CronParentId      string `json:"cron_parent_id" validate:"required,uuid"`
	Cron              string `json:"cron" validate:"required"`
	WorkflowVersionId string `json:"workflow_version_id" validate:"required,uuid"`
}

type ScheduleGetGroupKeyRunTimeoutTaskMetadata added in v0.8.0 

type ScheduleGetGroupKeyRunTimeoutTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type ScheduleGetGroupKeyRunTimeoutTaskPayload added in v0.8.0 

type ScheduleGetGroupKeyRunTimeoutTaskPayload struct {
	GetGroupKeyRunId string `json:"get_group_key_run_id" validate:"required,uuid"`
	WorkflowRunId    string `json:"workflow_run_id" validate:"required,uuid"`
	TimeoutAt        string `json:"timeout_at" validate:"required"`
}

type ScheduleStepRunTimeoutTaskMetadata 

type ScheduleStepRunTimeoutTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type ScheduleStepRunTimeoutTaskPayload 

type ScheduleStepRunTimeoutTaskPayload struct {
	StepRunId string `json:"step_run_id" validate:"required,uuid"`
	JobRunId  string `json:"job_run_id" validate:"required,uuid"`
	TimeoutAt string `json:"timeout_at" validate:"required"`
}

type ScheduleWorkflowTaskMetadata 

type ScheduleWorkflowTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type ScheduleWorkflowTaskPayload 

type ScheduleWorkflowTaskPayload struct {
	ScheduledWorkflowId string `json:"scheduled_workflow_id" validate:"required,uuid"`
	TriggerAt           string `json:"trigger_at" validate:"required"`
	WorkflowVersionId   string `json:"workflow_version_id" validate:"required,uuid"`
}

type StepRunAssignedBulkTaskMetadata added in v0.50.0 

type StepRunAssignedBulkTaskMetadata struct {
	TenantId     string `json:"tenant_id" validate:"required,uuid"`
	DispatcherId string `json:"dispatcher_id" validate:"required,uuid"`
}

type StepRunAssignedBulkTaskPayload added in v0.50.0 

type StepRunAssignedBulkTaskPayload struct {
	WorkerIdToStepRunIds map[string][]string `json:"worker_id_to_step_run_id" validate:"required"`
}

type StepRunAssignedTaskMetadata 

type StepRunAssignedTaskMetadata struct {
	TenantId     string `json:"tenant_id" validate:"required,uuid"`
	DispatcherId string `json:"dispatcher_id" validate:"required,uuid"`
}

type StepRunAssignedTaskPayload 

type StepRunAssignedTaskPayload struct {
	StepRunId string `json:"step_run_id" validate:"required,uuid"`
	WorkerId  string `json:"worker_id" validate:"required,uuid"`
}

type StepRunCancelTaskMetadata added in v0.42.0 

type StepRunCancelTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunCancelTaskPayload added in v0.42.0 

type StepRunCancelTaskPayload struct {
	StepRunId           string `json:"step_run_id" validate:"required,uuid"`
	CancelledReason     string `json:"cancelled_reason" validate:"required"`
	StepRetries         *int32 `json:"step_retries,omitempty"`
	RetryCount          *int32 `json:"retry_count,omitempty"`
	PropagateToChildren bool   `json:"propagate_to_children"`
}

type StepRunCancelledTaskMetadata 

type StepRunCancelledTaskMetadata struct {
	TenantId     string `json:"tenant_id" validate:"required,uuid"`
	DispatcherId string `json:"dispatcher_id" validate:"required,uuid"`
}

type StepRunCancelledTaskPayload 

type StepRunCancelledTaskPayload struct {
	WorkflowRunId   string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId       string `json:"step_run_id" validate:"required,uuid"`
	WorkerId        string `json:"worker_id" validate:"required,uuid"`
	CancelledReason string `json:"cancelled_reason" validate:"required"`
	StepRetries     *int32 `json:"step_retries,omitempty"`
	RetryCount      *int32 `json:"retry_count,omitempty"`
}

type StepRunFailedTaskMetadata 

type StepRunFailedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunFailedTaskPayload 

type StepRunFailedTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId     string `json:"step_run_id" validate:"required,uuid"`
	FailedAt      string `json:"failed_at" validate:"required"`
	Error         string `json:"error" validate:"required"`
	StepRetries   *int32 `json:"step_retries,omitempty"`
	RetryCount    *int32 `json:"retry_count,omitempty"`
}

type StepRunFinishedTaskMetadata 

type StepRunFinishedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunFinishedTaskPayload 

type StepRunFinishedTaskPayload struct {
	WorkflowRunId  string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId      string `json:"step_run_id" validate:"required,uuid"`
	FinishedAt     string `json:"finished_at" validate:"required"`
	StepOutputData string `json:"step_output_data"`
	StepRetries    *int32 `json:"step_retries,omitempty"`
	RetryCount     *int32 `json:"retry_count,omitempty"`
}

type StepRunReplayTaskMetadata added in v0.28.1 

type StepRunReplayTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunReplayTaskPayload added in v0.28.1 

type StepRunReplayTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId     string `json:"step_run_id" validate:"required,uuid"`
	JobRunId      string `json:"job_run_id" validate:"required,uuid"`

	// optional - if not provided, the step run will be retried with the same input
	InputData   string `json:"input_data,omitempty"`
	StepRetries *int32 `json:"step_retries,omitempty"`
	RetryCount  *int32 `json:"retry_count,omitempty"`
}

type StepRunRequeueTaskMetadata 

type StepRunRequeueTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunRequeueTaskPayload 

type StepRunRequeueTaskPayload struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunRetryTaskMetadata added in v0.11.0 

type StepRunRetryTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunRetryTaskPayload added in v0.11.0 

type StepRunRetryTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId     string `json:"step_run_id" validate:"required,uuid"`
	JobRunId      string `json:"job_run_id" validate:"required,uuid"`

	Error *string `json:"error,omitempty"`

	// optional - if not provided, the step run will be retried with the same input
	InputData string `json:"input_data,omitempty"`

	StepRetries *int32 `json:"step_retries,omitempty"`
	RetryCount  *int32 `json:"retry_count,omitempty"`
}

type StepRunStartedTaskMetadata 

type StepRunStartedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunStartedTaskPayload 

type StepRunStartedTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId     string `json:"step_run_id" validate:"required,uuid"`
	StartedAt     string `json:"started_at" validate:"required"`
	StepRetries   *int32 `json:"step_retries,omitempty"`
	RetryCount    *int32 `json:"retry_count,omitempty"`
}

type StepRunStreamEventTaskMetadata added in v0.19.0 

type StepRunStreamEventTaskMetadata struct {
	TenantId      string `json:"tenant_id" validate:"required,uuid"`
	StreamEventId string `json:"stream_event_id" validate:"required,integer"`
}

type StepRunStreamEventTaskPayload added in v0.19.0 

type StepRunStreamEventTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId     string `json:"step_run_id" validate:"required,uuid"`
	CreatedAt     string `json:"created_at" validate:"required"`
	StreamEventId string `json:"stream_event_id"`
	StepRetries   *int32 `json:"step_retries,omitempty"`
	RetryCount    *int32 `json:"retry_count,omitempty"`
}

type StepRunTaskMetadata 

type StepRunTaskMetadata struct {
	TenantId          string `json:"tenant_id" validate:"required,uuid"`
	StepId            string `json:"step_id" validate:"required,uuid"`
	ActionId          string `json:"action_id" validate:"required,actionId"`
	JobId             string `json:"job_id" validate:"required,uuid"`
	JobName           string `json:"job_name" validate:"required,hatchetName"`
	WorkflowVersionId string `json:"workflow_version_id" validate:"required,uuid"`
}

type StepRunTaskPayload 

type StepRunTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId     string `json:"step_run_id" validate:"required,uuid"`
	JobRunId      string `json:"job_run_id" validate:"required,uuid"`
	StepRetries   *int32 `json:"step_retries,omitempty"`
	RetryCount    *int32 `json:"retry_count,omitempty"`
}

type StepRunTimedOutTaskMetadata 

type StepRunTimedOutTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type StepRunTimedOutTaskPayload 

type StepRunTimedOutTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	StepRunId     string `json:"step_run_id" validate:"required,uuid"`
	StepRetries   *int32 `json:"step_retries,omitempty"`
	RetryCount    *int32 `json:"retry_count,omitempty"`
}

type WorkflowRunFailedTask added in v0.50.0 

type WorkflowRunFailedTask struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
	FailedAt      string `json:"failed_at" validate:"required"`
	Reason        string `json:"reason" validate:"required"`
}

type WorkflowRunFailedTaskMetadata added in v0.50.0 

type WorkflowRunFailedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type WorkflowRunFinishedTask added in v0.10.2 

type WorkflowRunFinishedTask struct {
	WorkflowRunId      string                 `json:"workflow_run_id" validate:"required,uuid"`
	Status             string                 `json:"status" validate:"required"`
	AdditionalMetadata map[string]interface{} `json:"additional_metadata"`
}

type WorkflowRunFinishedTaskMetadata added in v0.10.2 

type WorkflowRunFinishedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type WorkflowRunQueuedTaskMetadata added in v0.8.0 

type WorkflowRunQueuedTaskMetadata struct {
	TenantId string `json:"tenant_id" validate:"required,uuid"`
}

type WorkflowRunQueuedTaskPayload added in v0.8.0 

type WorkflowRunQueuedTaskPayload struct {
	WorkflowRunId string `json:"workflow_run_id" validate:"required,uuid"`
}

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.