task

package
v0.0.6 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivityTask

type ActivityTask struct {
	TaskID            string
	WorkflowID        string
	NumAttempted      int
	TaskScheduleEvent *history.ActivityScheduled
}

func (*ActivityTask) Summary

func (t *ActivityTask) Summary() any

type ActivityTaskResult

type ActivityTaskResult struct {
	Task            *ActivityTask
	ExecutionResult *dto.ExecutionResult
}

func (*ActivityTaskResult) Summary

func (r *ActivityTaskResult) Summary() any

type ActivityTaskResultSummary

type ActivityTaskResultSummary struct {
	TaskID          string
	WorkflowID      string
	TaskScheduledID int64
	ExecutionResult *dto.ExecutionResult
}

type ActivityTaskSummary

type ActivityTaskSummary struct {
	TaskID          string
	WorkflowID      string
	TaskScheduledID int64
	NumAttempted    int
}

type TaskType

type TaskType string
const (
	TaskTypeWorkflow TaskType = "workflow"
	TaskTypeActivity TaskType = "activity"
)

type WorkflowTask

type WorkflowTask struct {
	TaskID         string
	WorkflowID     string
	FetchTimestamp int64
	OldEvents      []*history.HistoryEvent
	NewEvents      []*history.HistoryEvent
}

func (*WorkflowTask) Summary

func (t *WorkflowTask) Summary() any

type WorkflowTaskResult

type WorkflowTaskResult struct {
	Task                       *WorkflowTask
	PendingActivities          []*history.ActivityScheduled
	PendingTimers              []*history.TimerCreated
	WorkflowExecutionCompleted *history.WorkflowExecutionCompleted `json:",omitempty"`
}

func (*WorkflowTaskResult) Summary

func (r *WorkflowTaskResult) Summary() any

type WorkflowTaskResultSummary

type WorkflowTaskResultSummary struct {
	TaskID                     string
	WorkflowID                 string
	TaskFetchTimestamp         time.Time
	PendingActivities          []*history.ActivityScheduled
	PendingTimers              []*history.TimerCreated
	WorkflowExecutionCompleted *history.WorkflowExecutionCompleted `json:",omitempty"`
}

type WorkflowTaskSummary

type WorkflowTaskSummary struct {
	TaskID         string
	WorkflowID     string
	FetchTimestamp time.Time
	OldEvents      []string
	NewEvents      []string
}

Jump to

Keyboard shortcuts

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