tasks

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2022 License: MIT Imports: 8 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	CategoryIDUnspecified = int32(enumsspb.TASK_CATEGORY_UNSPECIFIED)
	CategoryIDTransfer    = int32(enumsspb.TASK_CATEGORY_TRANSFER)
	CategoryIDTimer       = int32(enumsspb.TASK_CATEGORY_TIMER)
	CategoryIDReplication = int32(enumsspb.TASK_CATEGORY_REPLICATION)
	CategoryIDVisibility  = int32(enumsspb.TASK_CATEGORY_VISIBILITY)
)
View Source 
const (
	CategoryNameTransfer    = "transfer"
	CategoryNameTimer       = "timer"
	CategoryNameReplication = "replication"
	CategoryNameVisibility  = "visibility"
)

Variables

View Source 
var (
	CategoryTransfer = Category{
						// contains filtered or unexported fields
	}

	CategoryTimer = Category{
					// contains filtered or unexported fields
	}

	CategoryReplication = Category{
						// contains filtered or unexported fields
	}

	CategoryVisibility = Category{
						// contains filtered or unexported fields
	}
)

Functions

func GetCategories added in v1.16.0 

func GetCategories() map[int32]Category

GetCategories returns a deep copy of all registered Categories

Types

type ActivityRetryTimerTask 

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

func (*ActivityRetryTimerTask) GetCategory added in v1.16.0 

func (r *ActivityRetryTimerTask) GetCategory() Category

func (*ActivityRetryTimerTask) GetKey 

func (r *ActivityRetryTimerTask) GetKey() Key

func (*ActivityRetryTimerTask) GetTaskID 

func (r *ActivityRetryTimerTask) GetTaskID() int64

func (*ActivityRetryTimerTask) GetType added in v1.16.0 

func (r *ActivityRetryTimerTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (a *ActivityTask) GetCategory() Category

func (*ActivityTask) GetKey 

func (a *ActivityTask) GetKey() Key

func (*ActivityTask) GetTaskID 

func (a *ActivityTask) GetTaskID() int64

func (*ActivityTask) GetType added in v1.16.0 

func (a *ActivityTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (a *ActivityTimeoutTask) GetCategory() Category

func (*ActivityTimeoutTask) GetKey 

func (a *ActivityTimeoutTask) GetKey() Key

func (*ActivityTimeoutTask) GetTaskID 

func (a *ActivityTimeoutTask) GetTaskID() int64

func (*ActivityTimeoutTask) GetType added in v1.16.0 

func (a *ActivityTimeoutTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (u *CancelExecutionTask) GetCategory() Category

func (*CancelExecutionTask) GetKey 

func (u *CancelExecutionTask) GetKey() Key

func (*CancelExecutionTask) GetTaskID 

func (u *CancelExecutionTask) GetTaskID() int64

func (*CancelExecutionTask) GetType added in v1.16.0 

func (u *CancelExecutionTask) GetType() enumsspb.TaskType

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 Category added in v1.16.0 

type Category struct {
	// contains filtered or unexported fields
}

func GetCategoryByID added in v1.16.0 

func GetCategoryByID(id int32) (Category, bool)

GetCategoryByID returns a registered Category with the same ID

func NewCategory added in v1.16.0 

func NewCategory(
	id int32,
	categoryType CategoryType,
	name string,
) Category

NewCategory creates a new Category and register the created Category Registered Categories can be retrieved via GetCategories() or GetCategoryByID() NewCategory panics when a Category with the same ID has already been registered

func (*Category) ID added in v1.16.0 

func (c *Category) ID() int32

func (*Category) Name added in v1.16.0 

func (c *Category) Name() string

func (*Category) Type added in v1.16.0 

func (c *Category) Type() CategoryType

type CategoryType added in v1.16.0 

type CategoryType int
const (
	CategoryTypeUnspecified CategoryType = iota
	CategoryTypeImmediate
	CategoryTypeScheduled
)

func (CategoryType) String added in v1.16.0 

func (t CategoryType) String() string

type CloseExecutionTask 

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

func (*CloseExecutionTask) GetCategory added in v1.16.0 

func (a *CloseExecutionTask) GetCategory() Category

func (*CloseExecutionTask) GetKey 

func (a *CloseExecutionTask) GetKey() Key

func (*CloseExecutionTask) GetTaskID 

func (a *CloseExecutionTask) GetTaskID() int64

func (*CloseExecutionTask) GetType added in v1.16.0 

func (a *CloseExecutionTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (t *CloseExecutionVisibilityTask) GetCategory() Category

func (*CloseExecutionVisibilityTask) GetKey 

func (t *CloseExecutionVisibilityTask) GetKey() Key

func (*CloseExecutionVisibilityTask) GetTaskID 

func (t *CloseExecutionVisibilityTask) GetTaskID() int64

func (*CloseExecutionVisibilityTask) GetType added in v1.16.0 

func (t *CloseExecutionVisibilityTask) GetType() enumsspb.TaskType

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 DeleteExecutionTask added in v1.15.0 

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

func (*DeleteExecutionTask) GetCategory added in v1.16.0 

func (a *DeleteExecutionTask) GetCategory() Category

func (*DeleteExecutionTask) GetKey added in v1.15.0 

func (a *DeleteExecutionTask) GetKey() Key

func (*DeleteExecutionTask) GetTaskID added in v1.15.0 

func (a *DeleteExecutionTask) GetTaskID() int64

func (*DeleteExecutionTask) GetType added in v1.16.0 

func (a *DeleteExecutionTask) GetType() enumsspb.TaskType

func (*DeleteExecutionTask) GetVersion added in v1.15.0 

func (a *DeleteExecutionTask) GetVersion() int64

func (*DeleteExecutionTask) GetVisibilityTime added in v1.15.0 

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

func (*DeleteExecutionTask) SetTaskID added in v1.15.0 

func (a *DeleteExecutionTask) SetTaskID(id int64)

func (*DeleteExecutionTask) SetVersion added in v1.15.0 

func (a *DeleteExecutionTask) SetVersion(version int64)

func (*DeleteExecutionTask) SetVisibilityTime added in v1.15.0 

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

type DeleteExecutionVisibilityTask 

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

func (*DeleteExecutionVisibilityTask) GetCategory added in v1.16.0 

func (t *DeleteExecutionVisibilityTask) GetCategory() Category

func (*DeleteExecutionVisibilityTask) GetKey 

func (t *DeleteExecutionVisibilityTask) GetKey() Key

func (*DeleteExecutionVisibilityTask) GetTaskID 

func (t *DeleteExecutionVisibilityTask) GetTaskID() int64

func (*DeleteExecutionVisibilityTask) GetType added in v1.16.0 

func (t *DeleteExecutionVisibilityTask) GetType() enumsspb.TaskType

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
	BranchToken         []byte
}

func (*DeleteHistoryEventTask) GetCategory added in v1.16.0 

func (a *DeleteHistoryEventTask) GetCategory() Category

func (*DeleteHistoryEventTask) GetKey 

func (a *DeleteHistoryEventTask) GetKey() Key

func (*DeleteHistoryEventTask) GetTaskID 

func (a *DeleteHistoryEventTask) GetTaskID() int64

func (*DeleteHistoryEventTask) GetType added in v1.16.0 

func (a *DeleteHistoryEventTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (a *HistoryReplicationTask) GetCategory() Category

func (*HistoryReplicationTask) GetKey 

func (a *HistoryReplicationTask) GetKey() Key

func (*HistoryReplicationTask) GetTaskID 

func (a *HistoryReplicationTask) GetTaskID() int64

func (*HistoryReplicationTask) GetType added in v1.16.0 

func (a *HistoryReplicationTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (a *ResetWorkflowTask) GetCategory() Category

func (*ResetWorkflowTask) GetKey 

func (a *ResetWorkflowTask) GetKey() Key

func (*ResetWorkflowTask) GetTaskID 

func (a *ResetWorkflowTask) GetTaskID() int64

func (*ResetWorkflowTask) GetType added in v1.16.0 

func (a *ResetWorkflowTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (u *SignalExecutionTask) GetCategory() Category

func (*SignalExecutionTask) GetKey 

func (u *SignalExecutionTask) GetKey() Key

func (*SignalExecutionTask) GetTaskID 

func (u *SignalExecutionTask) GetTaskID() int64

func (*SignalExecutionTask) GetType added in v1.16.0 

func (u *SignalExecutionTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (u *StartChildExecutionTask) GetCategory() Category

func (*StartChildExecutionTask) GetKey 

func (u *StartChildExecutionTask) GetKey() Key

func (*StartChildExecutionTask) GetTaskID 

func (u *StartChildExecutionTask) GetTaskID() int64

func (*StartChildExecutionTask) GetType added in v1.16.0 

func (u *StartChildExecutionTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (t *StartExecutionVisibilityTask) GetCategory() Category

func (*StartExecutionVisibilityTask) GetKey 

func (t *StartExecutionVisibilityTask) GetKey() Key

func (*StartExecutionVisibilityTask) GetTaskID 

func (t *StartExecutionVisibilityTask) GetTaskID() int64

func (*StartExecutionVisibilityTask) GetType added in v1.16.0 

func (t *StartExecutionVisibilityTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (a *SyncActivityTask) GetCategory() Category

func (*SyncActivityTask) GetKey 

func (a *SyncActivityTask) GetKey() Key

func (*SyncActivityTask) GetTaskID 

func (a *SyncActivityTask) GetTaskID() int64

func (*SyncActivityTask) GetType added in v1.16.0 

func (a *SyncActivityTask) GetType() enumsspb.TaskType

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
	GetCategory() Category
	GetType() enumsspb.TaskType

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

Task is the generic task interface

func NewFakeTask added in v1.16.0 

func NewFakeTask(
	category Category,
	visibilityTimestamp time.Time,
) Task

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) GetCategory added in v1.16.0 

func (t *UpsertExecutionVisibilityTask) GetCategory() Category

func (*UpsertExecutionVisibilityTask) GetKey 

func (t *UpsertExecutionVisibilityTask) GetKey() Key

func (*UpsertExecutionVisibilityTask) GetTaskID 

func (t *UpsertExecutionVisibilityTask) GetTaskID() int64

func (*UpsertExecutionVisibilityTask) GetType added in v1.16.0 

func (t *UpsertExecutionVisibilityTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (u *UserTimerTask) GetCategory() Category

func (*UserTimerTask) GetKey 

func (u *UserTimerTask) GetKey() Key

func (*UserTimerTask) GetTaskID 

func (u *UserTimerTask) GetTaskID() int64

func (*UserTimerTask) GetType added in v1.16.0 

func (u *UserTimerTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (r *WorkflowBackoffTimerTask) GetCategory() Category

func (*WorkflowBackoffTimerTask) GetKey 

func (r *WorkflowBackoffTimerTask) GetKey() Key

func (*WorkflowBackoffTimerTask) GetTaskID 

func (r *WorkflowBackoffTimerTask) GetTaskID() int64

func (*WorkflowBackoffTimerTask) GetType added in v1.16.0 

func (r *WorkflowBackoffTimerTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (d *WorkflowTask) GetCategory() Category

func (*WorkflowTask) GetKey 

func (d *WorkflowTask) GetKey() Key

func (*WorkflowTask) GetTaskID 

func (d *WorkflowTask) GetTaskID() int64

func (*WorkflowTask) GetType added in v1.16.0 

func (d *WorkflowTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (d *WorkflowTaskTimeoutTask) GetCategory() Category

func (*WorkflowTaskTimeoutTask) GetKey 

func (d *WorkflowTaskTimeoutTask) GetKey() Key

func (*WorkflowTaskTimeoutTask) GetTaskID 

func (d *WorkflowTaskTimeoutTask) GetTaskID() int64

func (*WorkflowTaskTimeoutTask) GetType added in v1.16.0 

func (d *WorkflowTaskTimeoutTask) GetType() enumsspb.TaskType

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) GetCategory added in v1.16.0 

func (u *WorkflowTimeoutTask) GetCategory() Category

func (*WorkflowTimeoutTask) GetKey 

func (u *WorkflowTimeoutTask) GetKey() Key

func (*WorkflowTimeoutTask) GetTaskID 

func (u *WorkflowTimeoutTask) GetTaskID() int64

func (*WorkflowTimeoutTask) GetType added in v1.16.0 

func (u *WorkflowTimeoutTask) GetType() enumsspb.TaskType

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.