tasks

package
v1.14.6 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2022 License: MIT Imports: 4 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivityRetryTimerTask 

type ActivityRetryTimerTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	EventID             int64
	Version             int64
	Attempt             int32
}

func (*ActivityRetryTimerTask) GetKey 

func (r *ActivityRetryTimerTask) GetKey() Key

func (*ActivityRetryTimerTask) GetTaskID 

func (r *ActivityRetryTimerTask) GetTaskID() int64

func (*ActivityRetryTimerTask) GetVersion 

func (r *ActivityRetryTimerTask) GetVersion() int64

func (*ActivityRetryTimerTask) GetVisibilityTime 

func (r *ActivityRetryTimerTask) GetVisibilityTime() time.Time

func (*ActivityRetryTimerTask) SetTaskID 

func (r *ActivityRetryTimerTask) SetTaskID(id int64)

func (*ActivityRetryTimerTask) SetVersion 

func (r *ActivityRetryTimerTask) SetVersion(version int64)

func (*ActivityRetryTimerTask) SetVisibilityTime 

func (r *ActivityRetryTimerTask) SetVisibilityTime(t time.Time)

type ActivityTask 

type ActivityTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	TargetNamespaceID   string
	TaskQueue           string
	ScheduleID          int64
	Version             int64
}

func (*ActivityTask) GetKey 

func (a *ActivityTask) GetKey() Key

func (*ActivityTask) GetTaskID 

func (a *ActivityTask) GetTaskID() int64

func (*ActivityTask) GetVersion 

func (a *ActivityTask) GetVersion() int64

func (*ActivityTask) GetVisibilityTime 

func (a *ActivityTask) GetVisibilityTime() time.Time

func (*ActivityTask) SetTaskID 

func (a *ActivityTask) SetTaskID(id int64)

func (*ActivityTask) SetVersion 

func (a *ActivityTask) SetVersion(version int64)

func (*ActivityTask) SetVisibilityTime 

func (a *ActivityTask) SetVisibilityTime(timestamp time.Time)

type ActivityTimeoutTask 

type ActivityTimeoutTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	TimeoutType         enumspb.TimeoutType
	EventID             int64
	Attempt             int32
	Version             int64
}

func (*ActivityTimeoutTask) GetKey 

func (a *ActivityTimeoutTask) GetKey() Key

func (*ActivityTimeoutTask) GetTaskID 

func (a *ActivityTimeoutTask) GetTaskID() int64

func (*ActivityTimeoutTask) GetVersion 

func (a *ActivityTimeoutTask) GetVersion() int64

func (*ActivityTimeoutTask) GetVisibilityTime 

func (a *ActivityTimeoutTask) GetVisibilityTime() time.Time

func (*ActivityTimeoutTask) SetTaskID 

func (a *ActivityTimeoutTask) SetTaskID(id int64)

func (*ActivityTimeoutTask) SetVersion 

func (a *ActivityTimeoutTask) SetVersion(version int64)

func (*ActivityTimeoutTask) SetVisibilityTime 

func (a *ActivityTimeoutTask) SetVisibilityTime(t time.Time)

type CancelExecutionTask 

type CancelExecutionTask struct {
	definition.WorkflowKey
	VisibilityTimestamp     time.Time
	TaskID                  int64
	TargetNamespaceID       string
	TargetWorkflowID        string
	TargetRunID             string
	TargetChildWorkflowOnly bool
	InitiatedID             int64
	Version                 int64
}

func (*CancelExecutionTask) GetKey 

func (u *CancelExecutionTask) GetKey() Key

func (*CancelExecutionTask) GetTaskID 

func (u *CancelExecutionTask) GetTaskID() int64

func (*CancelExecutionTask) GetVersion 

func (u *CancelExecutionTask) GetVersion() int64

func (*CancelExecutionTask) GetVisibilityTime 

func (u *CancelExecutionTask) GetVisibilityTime() time.Time

func (*CancelExecutionTask) SetTaskID 

func (u *CancelExecutionTask) SetTaskID(id int64)

func (*CancelExecutionTask) SetVersion 

func (u *CancelExecutionTask) SetVersion(version int64)

func (*CancelExecutionTask) SetVisibilityTime 

func (u *CancelExecutionTask) SetVisibilityTime(timestamp time.Time)

type CloseExecutionTask 

type CloseExecutionTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*CloseExecutionTask) GetKey 

func (a *CloseExecutionTask) GetKey() Key

func (*CloseExecutionTask) GetTaskID 

func (a *CloseExecutionTask) GetTaskID() int64

func (*CloseExecutionTask) GetVersion 

func (a *CloseExecutionTask) GetVersion() int64

func (*CloseExecutionTask) GetVisibilityTime 

func (a *CloseExecutionTask) GetVisibilityTime() time.Time

func (*CloseExecutionTask) SetTaskID 

func (a *CloseExecutionTask) SetTaskID(id int64)

func (*CloseExecutionTask) SetVersion 

func (a *CloseExecutionTask) SetVersion(version int64)

func (*CloseExecutionTask) SetVisibilityTime 

func (a *CloseExecutionTask) SetVisibilityTime(timestamp time.Time)

type CloseExecutionVisibilityTask 

type CloseExecutionVisibilityTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*CloseExecutionVisibilityTask) GetKey 

func (t *CloseExecutionVisibilityTask) GetKey() Key

func (*CloseExecutionVisibilityTask) GetTaskID 

func (t *CloseExecutionVisibilityTask) GetTaskID() int64

func (*CloseExecutionVisibilityTask) GetVersion 

func (t *CloseExecutionVisibilityTask) GetVersion() int64

func (*CloseExecutionVisibilityTask) GetVisibilityTime 

func (t *CloseExecutionVisibilityTask) GetVisibilityTime() time.Time

func (*CloseExecutionVisibilityTask) SetTaskID 

func (t *CloseExecutionVisibilityTask) SetTaskID(id int64)

func (*CloseExecutionVisibilityTask) SetVersion 

func (t *CloseExecutionVisibilityTask) SetVersion(version int64)

func (*CloseExecutionVisibilityTask) SetVisibilityTime 

func (t *CloseExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type DeleteExecutionVisibilityTask 

type DeleteExecutionVisibilityTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*DeleteExecutionVisibilityTask) GetKey 

func (t *DeleteExecutionVisibilityTask) GetKey() Key

func (*DeleteExecutionVisibilityTask) GetTaskID 

func (t *DeleteExecutionVisibilityTask) GetTaskID() int64

func (*DeleteExecutionVisibilityTask) GetVersion 

func (t *DeleteExecutionVisibilityTask) GetVersion() int64

func (*DeleteExecutionVisibilityTask) GetVisibilityTime 

func (t *DeleteExecutionVisibilityTask) GetVisibilityTime() time.Time

func (*DeleteExecutionVisibilityTask) SetTaskID 

func (t *DeleteExecutionVisibilityTask) SetTaskID(id int64)

func (*DeleteExecutionVisibilityTask) SetVersion 

func (t *DeleteExecutionVisibilityTask) SetVersion(version int64)

func (*DeleteExecutionVisibilityTask) SetVisibilityTime 

func (t *DeleteExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type DeleteHistoryEventTask 

type DeleteHistoryEventTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*DeleteHistoryEventTask) GetKey 

func (a *DeleteHistoryEventTask) GetKey() Key

func (*DeleteHistoryEventTask) GetTaskID 

func (a *DeleteHistoryEventTask) GetTaskID() int64

func (*DeleteHistoryEventTask) GetVersion 

func (a *DeleteHistoryEventTask) GetVersion() int64

func (*DeleteHistoryEventTask) GetVisibilityTime 

func (a *DeleteHistoryEventTask) GetVisibilityTime() time.Time

func (*DeleteHistoryEventTask) SetTaskID 

func (a *DeleteHistoryEventTask) SetTaskID(id int64)

func (*DeleteHistoryEventTask) SetVersion 

func (a *DeleteHistoryEventTask) SetVersion(version int64)

func (*DeleteHistoryEventTask) SetVisibilityTime 

func (a *DeleteHistoryEventTask) SetVisibilityTime(timestamp time.Time)

type HistoryReplicationTask 

type HistoryReplicationTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	FirstEventID        int64
	NextEventID         int64
	Version             int64
	BranchToken         []byte
	NewRunBranchToken   []byte
}

func (*HistoryReplicationTask) GetKey 

func (a *HistoryReplicationTask) GetKey() Key

func (*HistoryReplicationTask) GetTaskID 

func (a *HistoryReplicationTask) GetTaskID() int64

func (*HistoryReplicationTask) GetVersion 

func (a *HistoryReplicationTask) GetVersion() int64

func (*HistoryReplicationTask) GetVisibilityTime 

func (a *HistoryReplicationTask) GetVisibilityTime() time.Time

func (*HistoryReplicationTask) SetTaskID 

func (a *HistoryReplicationTask) SetTaskID(id int64)

func (*HistoryReplicationTask) SetVersion 

func (a *HistoryReplicationTask) SetVersion(version int64)

func (*HistoryReplicationTask) SetVisibilityTime 

func (a *HistoryReplicationTask) SetVisibilityTime(timestamp time.Time)

type Key 

type Key struct {
	// FireTime is the scheduled time of the task
	FireTime time.Time
	// TaskID is the ID of the task
	TaskID int64
}

func (Key) CompareTo 

func (left Key) CompareTo(right Key) int

type Keys 

type Keys []Key

func (Keys) Len 

func (s Keys) Len() int

Len implements sort.Interface

func (Keys) Less 

func (s Keys) Less(
	this int,
	that int,
) bool

Less implements sort.Interface

func (Keys) Swap 

func (s Keys) Swap(
	this int,
	that int,
)

Swap implements sort.Interface.

type ResetWorkflowTask 

type ResetWorkflowTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*ResetWorkflowTask) GetKey 

func (a *ResetWorkflowTask) GetKey() Key

func (*ResetWorkflowTask) GetTaskID 

func (a *ResetWorkflowTask) GetTaskID() int64

func (*ResetWorkflowTask) GetVersion 

func (a *ResetWorkflowTask) GetVersion() int64

func (*ResetWorkflowTask) GetVisibilityTime 

func (a *ResetWorkflowTask) GetVisibilityTime() time.Time

func (*ResetWorkflowTask) SetTaskID 

func (a *ResetWorkflowTask) SetTaskID(id int64)

func (*ResetWorkflowTask) SetVersion 

func (a *ResetWorkflowTask) SetVersion(version int64)

func (*ResetWorkflowTask) SetVisibilityTime 

func (a *ResetWorkflowTask) SetVisibilityTime(timestamp time.Time)

type SignalExecutionTask 

type SignalExecutionTask struct {
	definition.WorkflowKey
	VisibilityTimestamp     time.Time
	TaskID                  int64
	TargetNamespaceID       string
	TargetWorkflowID        string
	TargetRunID             string
	TargetChildWorkflowOnly bool
	InitiatedID             int64
	Version                 int64
}

func (*SignalExecutionTask) GetKey 

func (u *SignalExecutionTask) GetKey() Key

func (*SignalExecutionTask) GetTaskID 

func (u *SignalExecutionTask) GetTaskID() int64

func (*SignalExecutionTask) GetVersion 

func (u *SignalExecutionTask) GetVersion() int64

func (*SignalExecutionTask) GetVisibilityTime 

func (u *SignalExecutionTask) GetVisibilityTime() time.Time

func (*SignalExecutionTask) SetTaskID 

func (u *SignalExecutionTask) SetTaskID(id int64)

func (*SignalExecutionTask) SetVersion 

func (u *SignalExecutionTask) SetVersion(version int64)

func (*SignalExecutionTask) SetVisibilityTime 

func (u *SignalExecutionTask) SetVisibilityTime(timestamp time.Time)

type StartChildExecutionTask 

type StartChildExecutionTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	TargetNamespaceID   string
	TargetWorkflowID    string
	InitiatedID         int64
	Version             int64
}

func (*StartChildExecutionTask) GetKey 

func (u *StartChildExecutionTask) GetKey() Key

func (*StartChildExecutionTask) GetTaskID 

func (u *StartChildExecutionTask) GetTaskID() int64

func (*StartChildExecutionTask) GetVersion 

func (u *StartChildExecutionTask) GetVersion() int64

func (*StartChildExecutionTask) GetVisibilityTime 

func (u *StartChildExecutionTask) GetVisibilityTime() time.Time

func (*StartChildExecutionTask) SetTaskID 

func (u *StartChildExecutionTask) SetTaskID(id int64)

func (*StartChildExecutionTask) SetVersion 

func (u *StartChildExecutionTask) SetVersion(version int64)

func (*StartChildExecutionTask) SetVisibilityTime 

func (u *StartChildExecutionTask) SetVisibilityTime(timestamp time.Time)

type StartExecutionVisibilityTask 

type StartExecutionVisibilityTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*StartExecutionVisibilityTask) GetKey 

func (t *StartExecutionVisibilityTask) GetKey() Key

func (*StartExecutionVisibilityTask) GetTaskID 

func (t *StartExecutionVisibilityTask) GetTaskID() int64

func (*StartExecutionVisibilityTask) GetVersion 

func (t *StartExecutionVisibilityTask) GetVersion() int64

func (*StartExecutionVisibilityTask) GetVisibilityTime 

func (t *StartExecutionVisibilityTask) GetVisibilityTime() time.Time

func (*StartExecutionVisibilityTask) SetTaskID 

func (t *StartExecutionVisibilityTask) SetTaskID(id int64)

func (*StartExecutionVisibilityTask) SetVersion 

func (t *StartExecutionVisibilityTask) SetVersion(version int64)

func (*StartExecutionVisibilityTask) SetVisibilityTime 

func (t *StartExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type SyncActivityTask 

type SyncActivityTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
	ScheduledID         int64
}

func (*SyncActivityTask) GetKey 

func (a *SyncActivityTask) GetKey() Key

func (*SyncActivityTask) GetTaskID 

func (a *SyncActivityTask) GetTaskID() int64

func (*SyncActivityTask) GetVersion 

func (a *SyncActivityTask) GetVersion() int64

func (*SyncActivityTask) GetVisibilityTime 

func (a *SyncActivityTask) GetVisibilityTime() time.Time

func (*SyncActivityTask) SetTaskID 

func (a *SyncActivityTask) SetTaskID(id int64)

func (*SyncActivityTask) SetVersion 

func (a *SyncActivityTask) SetVersion(version int64)

func (*SyncActivityTask) SetVisibilityTime 

func (a *SyncActivityTask) SetVisibilityTime(timestamp time.Time)

type Task 

type Task interface {
	GetKey() Key
	GetNamespaceID() string
	GetWorkflowID() string
	GetRunID() string
	GetTaskID() int64
	GetVisibilityTime() time.Time
	GetVersion() int64

	SetVersion(version int64)
	SetTaskID(id int64)
	SetVisibilityTime(timestamp time.Time)
}

Task is the generic task interface

type TieredStorageTask 

type TieredStorageTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*TieredStorageTask) GetKey 

func (t *TieredStorageTask) GetKey() Key

func (*TieredStorageTask) GetTaskID 

func (t *TieredStorageTask) GetTaskID() int64

func (*TieredStorageTask) GetVersion 

func (t *TieredStorageTask) GetVersion() int64

func (*TieredStorageTask) GetVisibilityTime 

func (t *TieredStorageTask) GetVisibilityTime() time.Time

func (*TieredStorageTask) SetTaskID 

func (t *TieredStorageTask) SetTaskID(id int64)

func (*TieredStorageTask) SetVersion 

func (t *TieredStorageTask) SetVersion(version int64)

func (*TieredStorageTask) SetVisibilityTime 

func (t *TieredStorageTask) SetVisibilityTime(timestamp time.Time)

type UpsertExecutionVisibilityTask 

type UpsertExecutionVisibilityTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	// this version is not used by task processing for validation,
	// instead, the version is used by Elasticsearch
	Version int64
}

func (*UpsertExecutionVisibilityTask) GetKey 

func (t *UpsertExecutionVisibilityTask) GetKey() Key

func (*UpsertExecutionVisibilityTask) GetTaskID 

func (t *UpsertExecutionVisibilityTask) GetTaskID() int64

func (*UpsertExecutionVisibilityTask) GetVersion 

func (t *UpsertExecutionVisibilityTask) GetVersion() int64

func (*UpsertExecutionVisibilityTask) GetVisibilityTime 

func (t *UpsertExecutionVisibilityTask) GetVisibilityTime() time.Time

func (*UpsertExecutionVisibilityTask) SetTaskID 

func (t *UpsertExecutionVisibilityTask) SetTaskID(id int64)

func (*UpsertExecutionVisibilityTask) SetVersion 

func (t *UpsertExecutionVisibilityTask) SetVersion(version int64)

func (*UpsertExecutionVisibilityTask) SetVisibilityTime 

func (t *UpsertExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type UserTimerTask 

type UserTimerTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	EventID             int64
	Version             int64
}

func (*UserTimerTask) GetKey 

func (u *UserTimerTask) GetKey() Key

func (*UserTimerTask) GetTaskID 

func (u *UserTimerTask) GetTaskID() int64

func (*UserTimerTask) GetVersion 

func (u *UserTimerTask) GetVersion() int64

func (*UserTimerTask) GetVisibilityTime 

func (u *UserTimerTask) GetVisibilityTime() time.Time

func (*UserTimerTask) SetTaskID 

func (u *UserTimerTask) SetTaskID(id int64)

func (*UserTimerTask) SetVersion 

func (u *UserTimerTask) SetVersion(version int64)

func (*UserTimerTask) SetVisibilityTime 

func (u *UserTimerTask) SetVisibilityTime(t time.Time)

type WorkflowBackoffTimerTask 

type WorkflowBackoffTimerTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
	WorkflowBackoffType enumsspb.WorkflowBackoffType
}

func (*WorkflowBackoffTimerTask) GetKey 

func (r *WorkflowBackoffTimerTask) GetKey() Key

func (*WorkflowBackoffTimerTask) GetTaskID 

func (r *WorkflowBackoffTimerTask) GetTaskID() int64

func (*WorkflowBackoffTimerTask) GetVersion 

func (r *WorkflowBackoffTimerTask) GetVersion() int64

func (*WorkflowBackoffTimerTask) GetVisibilityTime 

func (r *WorkflowBackoffTimerTask) GetVisibilityTime() time.Time

func (*WorkflowBackoffTimerTask) SetTaskID 

func (r *WorkflowBackoffTimerTask) SetTaskID(id int64)

func (*WorkflowBackoffTimerTask) SetVersion 

func (r *WorkflowBackoffTimerTask) SetVersion(version int64)

func (*WorkflowBackoffTimerTask) SetVisibilityTime 

func (r *WorkflowBackoffTimerTask) SetVisibilityTime(t time.Time)

type WorkflowTask 

type WorkflowTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	TaskQueue           string
	ScheduleID          int64
	Version             int64
}

func (*WorkflowTask) GetKey 

func (d *WorkflowTask) GetKey() Key

func (*WorkflowTask) GetTaskID 

func (d *WorkflowTask) GetTaskID() int64

func (*WorkflowTask) GetVersion 

func (d *WorkflowTask) GetVersion() int64

func (*WorkflowTask) GetVisibilityTime 

func (d *WorkflowTask) GetVisibilityTime() time.Time

func (*WorkflowTask) SetTaskID 

func (d *WorkflowTask) SetTaskID(id int64)

func (*WorkflowTask) SetVersion 

func (d *WorkflowTask) SetVersion(version int64)

func (*WorkflowTask) SetVisibilityTime 

func (d *WorkflowTask) SetVisibilityTime(timestamp time.Time)

type WorkflowTaskTimeoutTask 

type WorkflowTaskTimeoutTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	EventID             int64
	ScheduleAttempt     int32
	TimeoutType         enumspb.TimeoutType
	Version             int64
}

func (*WorkflowTaskTimeoutTask) GetKey 

func (d *WorkflowTaskTimeoutTask) GetKey() Key

func (*WorkflowTaskTimeoutTask) GetTaskID 

func (d *WorkflowTaskTimeoutTask) GetTaskID() int64

func (*WorkflowTaskTimeoutTask) GetVersion 

func (d *WorkflowTaskTimeoutTask) GetVersion() int64

func (*WorkflowTaskTimeoutTask) GetVisibilityTime 

func (d *WorkflowTaskTimeoutTask) GetVisibilityTime() time.Time

func (*WorkflowTaskTimeoutTask) SetTaskID 

func (d *WorkflowTaskTimeoutTask) SetTaskID(id int64)

func (*WorkflowTaskTimeoutTask) SetVersion 

func (d *WorkflowTaskTimeoutTask) SetVersion(version int64)

func (*WorkflowTaskTimeoutTask) SetVisibilityTime 

func (d *WorkflowTaskTimeoutTask) SetVisibilityTime(t time.Time)

type WorkflowTimeoutTask 

type WorkflowTimeoutTask struct {
	definition.WorkflowKey
	VisibilityTimestamp time.Time
	TaskID              int64
	Version             int64
}

func (*WorkflowTimeoutTask) GetKey 

func (u *WorkflowTimeoutTask) GetKey() Key

func (*WorkflowTimeoutTask) GetTaskID 

func (u *WorkflowTimeoutTask) GetTaskID() int64

func (*WorkflowTimeoutTask) GetVersion 

func (u *WorkflowTimeoutTask) GetVersion() int64

func (*WorkflowTimeoutTask) GetVisibilityTime 

func (u *WorkflowTimeoutTask) GetVisibilityTime() time.Time

func (*WorkflowTimeoutTask) SetTaskID 

func (u *WorkflowTimeoutTask) SetTaskID(id int64)

func (*WorkflowTimeoutTask) SetVersion 

func (u *WorkflowTimeoutTask) SetVersion(version int64)

func (*WorkflowTimeoutTask) SetVisibilityTime 

func (u *WorkflowTimeoutTask) SetVisibilityTime(t time.Time)

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.