tasktypes

package
v0.4.0-alpha.0 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2024 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func JobRunQueuedToTask 

func JobRunQueuedToTask(job *db.JobModel, jobRun *db.JobRunModel) *taskqueue.Task

func StepRunQueuedToTask 

func StepRunQueuedToTask(job *db.JobModel, stepRun *db.StepRunModel) *taskqueue.Task

func TenantToStepRunRequeueTask 

func TenantToStepRunRequeueTask(tenant db.TenantModel) *taskqueue.Task

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 CancelJobRunTimeoutTaskMetadata 

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

type CancelJobRunTimeoutTaskPayload 

type CancelJobRunTimeoutTaskPayload struct {
	JobRunId string `json:"job_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 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"`
}

type JobRunQueuedTaskMetadata 

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

	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 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 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 ScheduleJobRunTimeoutTaskMetadata 

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

type ScheduleJobRunTimeoutTaskPayload 

type ScheduleJobRunTimeoutTaskPayload struct {
	JobRunId  string `json:"job_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 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 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 {
	StepRunId       string `json:"step_run_id" validate:"required,uuid"`
	WorkerId        string `json:"worker_id" validate:"required,uuid"`
	CancelledReason string `json:"cancelled_reason" validate:"required"`
}

type StepRunFailedTaskMetadata 

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

type StepRunFailedTaskPayload 

type StepRunFailedTaskPayload struct {
	StepRunId string `json:"step_run_id" validate:"required,uuid"`
	FailedAt  string `json:"failed_at" validate:"required"`
	Error     string `json:"error" validate:"required"`
}

type StepRunFinishedTaskMetadata 

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

type StepRunFinishedTaskPayload 

type StepRunFinishedTaskPayload struct {
	StepRunId      string `json:"step_run_id" validate:"required,uuid"`
	FinishedAt     string `json:"finished_at" validate:"required"`
	StepOutputData string `json:"step_output_data"`
}

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 StepRunStartedTaskMetadata 

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

type StepRunStartedTaskPayload 

type StepRunStartedTaskPayload struct {
	StepRunId string `json:"step_run_id" validate:"required,uuid"`
	StartedAt string `json:"started_at" validate:"required"`
}

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 {
	StepRunId string `json:"step_run_id" validate:"required,uuid"`
	JobRunId  string `json:"job_run_id" validate:"required,uuid"`
}

type StepRunTimedOutTaskMetadata 

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

type StepRunTimedOutTaskPayload 

type StepRunTimedOutTaskPayload struct {
	StepRunId string `json:"step_run_id" validate:"required,uuid"`
	JobRunId  string `json:"job_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.