Documentation
¶
Overview ¶
Package tasks is a generated GoMock package.
Index ¶
- Constants
- Variables
- func GetCategories() map[int32]Category
- func GetTimerTaskEventID(timerTask Task) int64
- func GetTransferTaskEventID(transferTask Task) int64
- func InitializeLogger(task Task, logger log.Logger) log.Logger
- func IsNamespacePredicate(p Predicate) bool
- func IsTypePredicate(p Predicate) bool
- func IsUniverisalPredicate(p Predicate) bool
- func RemoveCategory(id int32)
- func Tags(task Task) []tag.Tag
- func ValidateKey(key Key) error
- type ActivityRetryTimerTask
- func (r *ActivityRetryTimerTask) GetCategory() Category
- func (r *ActivityRetryTimerTask) GetKey() Key
- func (r *ActivityRetryTimerTask) GetTaskID() int64
- func (r *ActivityRetryTimerTask) GetType() enumsspb.TaskType
- func (r *ActivityRetryTimerTask) GetVersion() int64
- func (r *ActivityRetryTimerTask) GetVisibilityTime() time.Time
- func (r *ActivityRetryTimerTask) SetTaskID(id int64)
- func (r *ActivityRetryTimerTask) SetVersion(version int64)
- func (r *ActivityRetryTimerTask) SetVisibilityTime(t time.Time)
- type ActivityTask
- func (a *ActivityTask) GetCategory() Category
- func (a *ActivityTask) GetKey() Key
- func (a *ActivityTask) GetTaskID() int64
- func (a *ActivityTask) GetType() enumsspb.TaskType
- func (a *ActivityTask) GetVersion() int64
- func (a *ActivityTask) GetVisibilityTime() time.Time
- func (a *ActivityTask) SetTaskID(id int64)
- func (a *ActivityTask) SetVersion(version int64)
- func (a *ActivityTask) SetVisibilityTime(timestamp time.Time)
- type ActivityTimeoutTask
- func (a *ActivityTimeoutTask) GetCategory() Category
- func (a *ActivityTimeoutTask) GetKey() Key
- func (a *ActivityTimeoutTask) GetTaskID() int64
- func (a *ActivityTimeoutTask) GetType() enumsspb.TaskType
- func (a *ActivityTimeoutTask) GetVersion() int64
- func (a *ActivityTimeoutTask) GetVisibilityTime() time.Time
- func (a *ActivityTimeoutTask) SetTaskID(id int64)
- func (a *ActivityTimeoutTask) SetVersion(version int64)
- func (a *ActivityTimeoutTask) SetVisibilityTime(t time.Time)
- type ArchiveExecutionTask
- func (a *ArchiveExecutionTask) GetCategory() Category
- func (a *ArchiveExecutionTask) GetKey() Key
- func (a *ArchiveExecutionTask) GetTaskID() int64
- func (a *ArchiveExecutionTask) GetType() enumsspb.TaskType
- func (a *ArchiveExecutionTask) GetVersion() int64
- func (a *ArchiveExecutionTask) GetVisibilityTime() time.Time
- func (a *ArchiveExecutionTask) SetTaskID(id int64)
- func (a *ArchiveExecutionTask) SetVisibilityTime(timestamp time.Time)
- type CancelExecutionTask
- func (u *CancelExecutionTask) GetCategory() Category
- func (u *CancelExecutionTask) GetKey() Key
- func (u *CancelExecutionTask) GetTaskID() int64
- func (u *CancelExecutionTask) GetType() enumsspb.TaskType
- func (u *CancelExecutionTask) GetVersion() int64
- func (u *CancelExecutionTask) GetVisibilityTime() time.Time
- func (u *CancelExecutionTask) SetTaskID(id int64)
- func (u *CancelExecutionTask) SetVersion(version int64)
- func (u *CancelExecutionTask) SetVisibilityTime(timestamp time.Time)
- type Category
- type CategoryType
- type CloseExecutionTask
- func (a *CloseExecutionTask) GetCategory() Category
- func (a *CloseExecutionTask) GetKey() Key
- func (a *CloseExecutionTask) GetTaskID() int64
- func (a *CloseExecutionTask) GetType() enumsspb.TaskType
- func (a *CloseExecutionTask) GetVersion() int64
- func (a *CloseExecutionTask) GetVisibilityTime() time.Time
- func (a *CloseExecutionTask) SetTaskID(id int64)
- func (a *CloseExecutionTask) SetVersion(version int64)
- func (a *CloseExecutionTask) SetVisibilityTime(timestamp time.Time)
- type CloseExecutionVisibilityTask
- func (t *CloseExecutionVisibilityTask) GetCategory() Category
- func (t *CloseExecutionVisibilityTask) GetKey() Key
- func (t *CloseExecutionVisibilityTask) GetTaskID() int64
- func (t *CloseExecutionVisibilityTask) GetType() enumsspb.TaskType
- func (t *CloseExecutionVisibilityTask) GetVersion() int64
- func (t *CloseExecutionVisibilityTask) GetVisibilityTime() time.Time
- func (t *CloseExecutionVisibilityTask) SetTaskID(id int64)
- func (t *CloseExecutionVisibilityTask) SetVersion(version int64)
- func (t *CloseExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)
- type DeleteExecutionTask
- func (a *DeleteExecutionTask) GetCategory() Category
- func (a *DeleteExecutionTask) GetKey() Key
- func (a *DeleteExecutionTask) GetTaskID() int64
- func (a *DeleteExecutionTask) GetType() enumsspb.TaskType
- func (a *DeleteExecutionTask) GetVersion() int64
- func (a *DeleteExecutionTask) GetVisibilityTime() time.Time
- func (a *DeleteExecutionTask) SetTaskID(id int64)
- func (a *DeleteExecutionTask) SetVersion(version int64)
- func (a *DeleteExecutionTask) SetVisibilityTime(timestamp time.Time)
- type DeleteExecutionVisibilityTask
- func (t *DeleteExecutionVisibilityTask) GetCategory() Category
- func (t *DeleteExecutionVisibilityTask) GetKey() Key
- func (t *DeleteExecutionVisibilityTask) GetTaskID() int64
- func (t *DeleteExecutionVisibilityTask) GetType() enumsspb.TaskType
- func (t *DeleteExecutionVisibilityTask) GetVersion() int64
- func (t *DeleteExecutionVisibilityTask) GetVisibilityTime() time.Time
- func (t *DeleteExecutionVisibilityTask) SetTaskID(id int64)
- func (t *DeleteExecutionVisibilityTask) SetVersion(version int64)
- func (t *DeleteExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)
- type DeleteHistoryEventTask
- func (a *DeleteHistoryEventTask) GetCategory() Category
- func (a *DeleteHistoryEventTask) GetKey() Key
- func (a *DeleteHistoryEventTask) GetTaskID() int64
- func (a *DeleteHistoryEventTask) GetType() enumsspb.TaskType
- func (a *DeleteHistoryEventTask) GetVersion() int64
- func (a *DeleteHistoryEventTask) GetVisibilityTime() time.Time
- func (a *DeleteHistoryEventTask) SetTaskID(id int64)
- func (a *DeleteHistoryEventTask) SetVersion(version int64)
- func (a *DeleteHistoryEventTask) SetVisibilityTime(timestamp time.Time)
- type DeleteWorkflowExecutionStage
- type FakeTask
- func (f *FakeTask) GetCategory() Category
- func (f *FakeTask) GetKey() Key
- func (f *FakeTask) GetTaskID() int64
- func (f *FakeTask) GetType() enumsspb.TaskType
- func (f *FakeTask) GetVersion() int64
- func (f *FakeTask) GetVisibilityTime() time.Time
- func (f *FakeTask) SetTaskID(id int64)
- func (f *FakeTask) SetVersion(version int64)
- func (f *FakeTask) SetVisibilityTime(t time.Time)
- type HistoryReplicationTask
- func (a *HistoryReplicationTask) GetCategory() Category
- func (a *HistoryReplicationTask) GetKey() Key
- func (a *HistoryReplicationTask) GetTaskID() int64
- func (a *HistoryReplicationTask) GetType() enumsspb.TaskType
- func (a *HistoryReplicationTask) GetVersion() int64
- func (a *HistoryReplicationTask) GetVisibilityTime() time.Time
- func (a *HistoryReplicationTask) SetTaskID(id int64)
- func (a *HistoryReplicationTask) SetVersion(version int64)
- func (a *HistoryReplicationTask) SetVisibilityTime(timestamp time.Time)
- type Key
- type Keys
- type MockTask
- func (m *MockTask) EXPECT() *MockTaskMockRecorder
- func (m *MockTask) GetCategory() Category
- func (m *MockTask) GetKey() Key
- func (m *MockTask) GetNamespaceID() string
- func (m *MockTask) GetRunID() string
- func (m *MockTask) GetTaskID() int64
- func (m *MockTask) GetType() v1.TaskType
- func (m *MockTask) GetVersion() int64
- func (m *MockTask) GetVisibilityTime() time.Time
- func (m *MockTask) GetWorkflowID() string
- func (m *MockTask) SetTaskID(id int64)
- func (m *MockTask) SetVisibilityTime(timestamp time.Time)
- type MockTaskMockRecorder
- func (mr *MockTaskMockRecorder) GetCategory() *gomock.Call
- func (mr *MockTaskMockRecorder) GetKey() *gomock.Call
- func (mr *MockTaskMockRecorder) GetNamespaceID() *gomock.Call
- func (mr *MockTaskMockRecorder) GetRunID() *gomock.Call
- func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call
- func (mr *MockTaskMockRecorder) GetType() *gomock.Call
- func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call
- func (mr *MockTaskMockRecorder) GetVisibilityTime() *gomock.Call
- func (mr *MockTaskMockRecorder) GetWorkflowID() *gomock.Call
- func (mr *MockTaskMockRecorder) SetTaskID(id interface{}) *gomock.Call
- func (mr *MockTaskMockRecorder) SetVisibilityTime(timestamp interface{}) *gomock.Call
- type NamespacePredicate
- type Predicate
- type ResetWorkflowTask
- func (a *ResetWorkflowTask) GetCategory() Category
- func (a *ResetWorkflowTask) GetKey() Key
- func (a *ResetWorkflowTask) GetTaskID() int64
- func (a *ResetWorkflowTask) GetType() enumsspb.TaskType
- func (a *ResetWorkflowTask) GetVersion() int64
- func (a *ResetWorkflowTask) GetVisibilityTime() time.Time
- func (a *ResetWorkflowTask) SetTaskID(id int64)
- func (a *ResetWorkflowTask) SetVersion(version int64)
- func (a *ResetWorkflowTask) SetVisibilityTime(timestamp time.Time)
- type SignalExecutionTask
- func (u *SignalExecutionTask) GetCategory() Category
- func (u *SignalExecutionTask) GetKey() Key
- func (u *SignalExecutionTask) GetTaskID() int64
- func (u *SignalExecutionTask) GetType() enumsspb.TaskType
- func (u *SignalExecutionTask) GetVersion() int64
- func (u *SignalExecutionTask) GetVisibilityTime() time.Time
- func (u *SignalExecutionTask) SetTaskID(id int64)
- func (u *SignalExecutionTask) SetVersion(version int64)
- func (u *SignalExecutionTask) SetVisibilityTime(timestamp time.Time)
- type StartChildExecutionTask
- func (u *StartChildExecutionTask) GetCategory() Category
- func (u *StartChildExecutionTask) GetKey() Key
- func (u *StartChildExecutionTask) GetTaskID() int64
- func (u *StartChildExecutionTask) GetType() enumsspb.TaskType
- func (u *StartChildExecutionTask) GetVersion() int64
- func (u *StartChildExecutionTask) GetVisibilityTime() time.Time
- func (u *StartChildExecutionTask) SetTaskID(id int64)
- func (u *StartChildExecutionTask) SetVersion(version int64)
- func (u *StartChildExecutionTask) SetVisibilityTime(timestamp time.Time)
- type StartExecutionVisibilityTask
- func (t *StartExecutionVisibilityTask) GetCategory() Category
- func (t *StartExecutionVisibilityTask) GetKey() Key
- func (t *StartExecutionVisibilityTask) GetTaskID() int64
- func (t *StartExecutionVisibilityTask) GetType() enumsspb.TaskType
- func (t *StartExecutionVisibilityTask) GetVersion() int64
- func (t *StartExecutionVisibilityTask) GetVisibilityTime() time.Time
- func (t *StartExecutionVisibilityTask) SetTaskID(id int64)
- func (t *StartExecutionVisibilityTask) SetVersion(version int64)
- func (t *StartExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)
- type SyncActivityTask
- func (a *SyncActivityTask) GetCategory() Category
- func (a *SyncActivityTask) GetKey() Key
- func (a *SyncActivityTask) GetTaskID() int64
- func (a *SyncActivityTask) GetType() enumsspb.TaskType
- func (a *SyncActivityTask) GetVersion() int64
- func (a *SyncActivityTask) GetVisibilityTime() time.Time
- func (a *SyncActivityTask) SetTaskID(id int64)
- func (a *SyncActivityTask) SetVersion(version int64)
- func (a *SyncActivityTask) SetVisibilityTime(timestamp time.Time)
- type SyncWorkflowStateTask
- func (a *SyncWorkflowStateTask) GetCategory() Category
- func (a *SyncWorkflowStateTask) GetKey() Key
- func (a *SyncWorkflowStateTask) GetTaskID() int64
- func (a *SyncWorkflowStateTask) GetType() enumsspb.TaskType
- func (a *SyncWorkflowStateTask) GetVersion() int64
- func (a *SyncWorkflowStateTask) GetVisibilityTime() time.Time
- func (a *SyncWorkflowStateTask) SetTaskID(id int64)
- func (a *SyncWorkflowStateTask) SetVersion(version int64)
- func (a *SyncWorkflowStateTask) SetVisibilityTime(timestamp time.Time)
- type Task
- type TypePredicate
- type UpsertExecutionVisibilityTask
- func (t *UpsertExecutionVisibilityTask) GetCategory() Category
- func (t *UpsertExecutionVisibilityTask) GetKey() Key
- func (t *UpsertExecutionVisibilityTask) GetTaskID() int64
- func (t *UpsertExecutionVisibilityTask) GetType() enumsspb.TaskType
- func (t *UpsertExecutionVisibilityTask) GetVersion() int64
- func (t *UpsertExecutionVisibilityTask) GetVisibilityTime() time.Time
- func (t *UpsertExecutionVisibilityTask) SetTaskID(id int64)
- func (t *UpsertExecutionVisibilityTask) SetVersion(version int64)
- func (t *UpsertExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)
- type UserTimerTask
- func (u *UserTimerTask) GetCategory() Category
- func (u *UserTimerTask) GetKey() Key
- func (u *UserTimerTask) GetTaskID() int64
- func (u *UserTimerTask) GetType() enumsspb.TaskType
- func (u *UserTimerTask) GetVersion() int64
- func (u *UserTimerTask) GetVisibilityTime() time.Time
- func (u *UserTimerTask) SetTaskID(id int64)
- func (u *UserTimerTask) SetVersion(version int64)
- func (u *UserTimerTask) SetVisibilityTime(t time.Time)
- type WorkflowBackoffTimerTask
- func (r *WorkflowBackoffTimerTask) GetCategory() Category
- func (r *WorkflowBackoffTimerTask) GetKey() Key
- func (r *WorkflowBackoffTimerTask) GetTaskID() int64
- func (r *WorkflowBackoffTimerTask) GetType() enumsspb.TaskType
- func (r *WorkflowBackoffTimerTask) GetVersion() int64
- func (r *WorkflowBackoffTimerTask) GetVisibilityTime() time.Time
- func (r *WorkflowBackoffTimerTask) SetTaskID(id int64)
- func (r *WorkflowBackoffTimerTask) SetVersion(version int64)
- func (r *WorkflowBackoffTimerTask) SetVisibilityTime(t time.Time)
- type WorkflowTask
- func (d *WorkflowTask) GetCategory() Category
- func (d *WorkflowTask) GetKey() Key
- func (d *WorkflowTask) GetTaskID() int64
- func (d *WorkflowTask) GetType() enumsspb.TaskType
- func (d *WorkflowTask) GetVersion() int64
- func (d *WorkflowTask) GetVisibilityTime() time.Time
- func (d *WorkflowTask) SetTaskID(id int64)
- func (d *WorkflowTask) SetVersion(version int64)
- func (d *WorkflowTask) SetVisibilityTime(timestamp time.Time)
- type WorkflowTaskTimeoutTask
- func (d *WorkflowTaskTimeoutTask) Cancel()
- func (d *WorkflowTaskTimeoutTask) GetCategory() Category
- func (d *WorkflowTaskTimeoutTask) GetKey() Key
- func (d *WorkflowTaskTimeoutTask) GetTaskID() int64
- func (d *WorkflowTaskTimeoutTask) GetType() enumsspb.TaskType
- func (d *WorkflowTaskTimeoutTask) GetVersion() int64
- func (d *WorkflowTaskTimeoutTask) GetVisibilityTime() time.Time
- func (d *WorkflowTaskTimeoutTask) SetTaskID(id int64)
- func (d *WorkflowTaskTimeoutTask) SetVersion(version int64)
- func (d *WorkflowTaskTimeoutTask) SetVisibilityTime(t time.Time)
- func (d *WorkflowTaskTimeoutTask) State() ctasks.State
- type WorkflowTimeoutTask
- func (u *WorkflowTimeoutTask) GetCategory() Category
- func (u *WorkflowTimeoutTask) GetKey() Key
- func (u *WorkflowTimeoutTask) GetTaskID() int64
- func (u *WorkflowTimeoutTask) GetType() enumsspb.TaskType
- func (u *WorkflowTimeoutTask) GetVersion() int64
- func (u *WorkflowTimeoutTask) GetVisibilityTime() time.Time
- func (u *WorkflowTimeoutTask) SetTaskID(id int64)
- func (u *WorkflowTimeoutTask) SetVersion(version int64)
- func (u *WorkflowTimeoutTask) SetVisibilityTime(t time.Time)
Constants ¶
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)
CategoryIDArchival = int32(enumsspb.TASK_CATEGORY_ARCHIVAL)
CategoryIDMemoryTimer = int32(enumsspb.TASK_CATEGORY_MEMORY_TIMER)
)
const (
CategoryNameTransfer = "transfer"
CategoryNameTimer = "timer"
CategoryNameReplication = "replication"
CategoryNameVisibility = "visibility"
CategoryNameArchival = "archival"
CategoryNameMemoryTimer = "memory-timer"
)
Variables ¶
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
}
CategoryArchival = Category{
// contains filtered or unexported fields
}
CategoryMemoryTimer = Category{
// contains filtered or unexported fields
}
)
var (
MinimumKey = NewKey(DefaultFireTime, 0)
MaximumKey = NewKey(time.Unix(0, math.MaxInt64), math.MaxInt64)
)
var (
DefaultFireTime = time.Unix(0, 0).UTC()
)
Functions ¶
func GetCategories ¶ added in v1.16.0
func GetCategories() map[int32]Category
GetCategories returns a deep copy of all registered Categories
func GetTimerTaskEventID ¶ added in v1.17.0
func GetTimerTaskEventID(
timerTask Task,
) int64
func GetTransferTaskEventID ¶ added in v1.17.0
func GetTransferTaskEventID(
transferTask Task,
) int64
func InitializeLogger ¶ added in v1.17.0
func InitializeLogger(
task Task,
logger log.Logger,
) log.Logger
TODO: deprecate this method, use logger from executable.Logger() instead
func IsNamespacePredicate ¶ added in v1.18.0
func IsNamespacePredicate(p Predicate) bool
func IsTypePredicate ¶ added in v1.18.0
func IsTypePredicate(p Predicate) bool
func IsUniverisalPredicate ¶ added in v1.18.0
func IsUniverisalPredicate(p Predicate) bool
func RemoveCategory ¶ added in v1.20.0
func RemoveCategory(id int32)
RemoveCategory removes a registered Category. This should only be used for testing.
func ValidateKey ¶ added in v1.17.0
func ValidateKey(key Key) error
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) 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) 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
TaskQueue string
ScheduledEventID int64
Version int64
}
func (*ActivityTask) GetCategory ¶ added in v1.16.0
func (a *ActivityTask) GetCategory() Category
func (*ActivityTask) GetVersion ¶
func (a *ActivityTask) GetVersion() int64
func (*ActivityTask) GetVisibilityTime ¶
func (a *ActivityTask) GetVisibilityTime() time.Time
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) 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) SetVersion ¶
func (a *ActivityTimeoutTask) SetVersion(version int64)
func (*ActivityTimeoutTask) SetVisibilityTime ¶
func (a *ActivityTimeoutTask) SetVisibilityTime(t time.Time)
type ArchiveExecutionTask ¶ added in v1.19.0
type ArchiveExecutionTask struct {
definition.WorkflowKey
VisibilityTimestamp time.Time
TaskID int64
Version int64
}
ArchiveExecutionTask is the task which archives both the history and visibility of a workflow execution and then produces a retention timer task to delete the data.
func (*ArchiveExecutionTask) GetCategory ¶ added in v1.19.0
func (a *ArchiveExecutionTask) GetCategory() Category
func (*ArchiveExecutionTask) GetTaskID ¶ added in v1.19.0
func (a *ArchiveExecutionTask) GetTaskID() int64
func (*ArchiveExecutionTask) GetType ¶ added in v1.19.0
func (a *ArchiveExecutionTask) GetType() enumsspb.TaskType
func (*ArchiveExecutionTask) GetVersion ¶ added in v1.19.0
func (a *ArchiveExecutionTask) GetVersion() int64
func (*ArchiveExecutionTask) GetVisibilityTime ¶ added in v1.19.0
func (a *ArchiveExecutionTask) GetVisibilityTime() time.Time
func (*ArchiveExecutionTask) SetTaskID ¶ added in v1.19.0
func (a *ArchiveExecutionTask) SetTaskID(id int64)
func (*ArchiveExecutionTask) SetVisibilityTime ¶ added in v1.19.0
func (a *ArchiveExecutionTask) SetVisibilityTime(timestamp time.Time)
type CancelExecutionTask ¶
type CancelExecutionTask struct {
definition.WorkflowKey
VisibilityTimestamp time.Time
TaskID int64
TargetNamespaceID string
TargetWorkflowID string
TargetRunID string
TargetChildWorkflowOnly bool
InitiatedEventID int64
Version int64
}
func (*CancelExecutionTask) GetCategory ¶ added in v1.16.0
func (u *CancelExecutionTask) GetCategory() Category
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) 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
type CategoryType ¶ added in v1.16.0
type CategoryType int
const (
CategoryTypeUnspecified CategoryType = iota
CategoryTypeImmediate
CategoryTypeScheduled
)
type CloseExecutionTask ¶
type CloseExecutionTask struct {
definition.WorkflowKey
VisibilityTimestamp time.Time
TaskID int64
Version int64
DeleteAfterClose bool
// CanSkipVisibilityArchival means the archival of visibility records will be handled by the archival queue, so
// we can skip archiving visibility records here while processing this task on the transfer queue.
CanSkipVisibilityArchival bool
DeleteProcessStage DeleteWorkflowExecutionStage
}
func (*CloseExecutionTask) GetCategory ¶ added in v1.16.0
func (a *CloseExecutionTask) GetCategory() Category
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) 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) 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
ProcessStage DeleteWorkflowExecutionStage
}
func (*DeleteExecutionTask) GetCategory ¶ added in v1.16.0
func (a *DeleteExecutionTask) GetCategory() Category
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
CloseExecutionVisibilityTaskID int64
// These two fields are needed for cassandra standard visibility.
// TODO (alex): Remove them when cassandra standard visibility is removed.
StartTime *time.Time
CloseTime *time.Time
}
func (*DeleteExecutionVisibilityTask) GetCategory ¶ added in v1.16.0
func (t *DeleteExecutionVisibilityTask) GetCategory() Category
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
WorkflowDataAlreadyArchived bool
ProcessStage DeleteWorkflowExecutionStage
}
func (*DeleteHistoryEventTask) GetCategory ¶ added in v1.16.0
func (a *DeleteHistoryEventTask) GetCategory() Category
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) SetVersion ¶
func (a *DeleteHistoryEventTask) SetVersion(version int64)
func (*DeleteHistoryEventTask) SetVisibilityTime ¶
func (a *DeleteHistoryEventTask) SetVisibilityTime(timestamp time.Time)
type DeleteWorkflowExecutionStage ¶ added in v1.19.0
type DeleteWorkflowExecutionStage byte
DeleteWorkflowExecutionStage used by ContextImpl.DeleteWorkflowExecution to indicate progress stage.
const (
DeleteWorkflowExecutionStageVisibility DeleteWorkflowExecutionStage = 1 << iota
DeleteWorkflowExecutionStageCurrent
DeleteWorkflowExecutionStageMutableState
DeleteWorkflowExecutionStageHistory
)
const (
DeleteWorkflowExecutionStageNone DeleteWorkflowExecutionStage = 0
)
func (*DeleteWorkflowExecutionStage) IsProcessed ¶ added in v1.19.0
func (s *DeleteWorkflowExecutionStage) IsProcessed(stage DeleteWorkflowExecutionStage) bool
func (*DeleteWorkflowExecutionStage) MarkProcessed ¶ added in v1.19.0
func (s *DeleteWorkflowExecutionStage) MarkProcessed(stage DeleteWorkflowExecutionStage)
type FakeTask ¶ added in v1.19.0
type FakeTask struct {
definition.WorkflowKey
VisibilityTimestamp time.Time
TaskID int64
Version int64
Category Category
}
func (*FakeTask) GetCategory ¶ added in v1.19.0
func (f *FakeTask) GetCategory() Category
func (*FakeTask) GetVersion ¶ added in v1.19.0
func (f *FakeTask) GetVersion() int64
func (*FakeTask) GetVisibilityTime ¶ added in v1.19.0
func (f *FakeTask) GetVisibilityTime() time.Time
func (*FakeTask) SetVersion ¶ added in v1.19.0
func (f *FakeTask) SetVersion(version int64)
func (*FakeTask) SetVisibilityTime ¶ added in v1.19.0
func (f *FakeTask) SetVisibilityTime(t time.Time)
type HistoryReplicationTask ¶
type HistoryReplicationTask struct {
definition.WorkflowKey
VisibilityTimestamp time.Time
TaskID int64
FirstEventID int64
NextEventID int64
Version int64
// deprecated
BranchToken []byte
// deprecated
NewRunBranchToken []byte
NewRunID string
}
func (*HistoryReplicationTask) GetCategory ¶ added in v1.16.0
func (a *HistoryReplicationTask) GetCategory() Category
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) 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 NewImmediateKey ¶ added in v1.17.0
func NewImmediateKey(taskID int64) Key
type MockTask ¶ added in v1.17.0
type MockTask struct {
// contains filtered or unexported fields
}
MockTask is a mock of Task interface.
func NewMockTask ¶ added in v1.17.0
func NewMockTask(ctrl *gomock.Controller) *MockTask
NewMockTask creates a new mock instance.
func (*MockTask) EXPECT ¶ added in v1.17.0
func (m *MockTask) EXPECT() *MockTaskMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTask) GetCategory ¶ added in v1.17.0
func (m *MockTask) GetCategory() Category
GetCategory mocks base method.
func (*MockTask) GetKey ¶ added in v1.17.0
func (m *MockTask) GetKey() Key
GetKey mocks base method.
func (*MockTask) GetNamespaceID ¶ added in v1.17.0
func (m *MockTask) GetNamespaceID() string
GetNamespaceID mocks base method.
func (*MockTask) GetRunID ¶ added in v1.17.0
func (m *MockTask) GetRunID() string
GetRunID mocks base method.
func (*MockTask) GetTaskID ¶ added in v1.17.0
func (m *MockTask) GetTaskID() int64
GetTaskID mocks base method.
func (*MockTask) GetType ¶ added in v1.17.0
func (m *MockTask) GetType() v1.TaskType
GetType mocks base method.
func (*MockTask) GetVersion ¶ added in v1.17.0
func (m *MockTask) GetVersion() int64
GetVersion mocks base method.
func (*MockTask) GetVisibilityTime ¶ added in v1.17.0
func (m *MockTask) GetVisibilityTime() time.Time
GetVisibilityTime mocks base method.
func (*MockTask) GetWorkflowID ¶ added in v1.17.0
func (m *MockTask) GetWorkflowID() string
GetWorkflowID mocks base method.
func (*MockTask) SetTaskID ¶ added in v1.17.0
func (m *MockTask) SetTaskID(id int64)
SetTaskID mocks base method.
func (*MockTask) SetVisibilityTime ¶ added in v1.17.0
func (m *MockTask) SetVisibilityTime(timestamp time.Time)
SetVisibilityTime mocks base method.
type MockTaskMockRecorder ¶ added in v1.17.0
type MockTaskMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskMockRecorder is the mock recorder for MockTask.
func (*MockTaskMockRecorder) GetCategory ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetCategory() *gomock.Call
GetCategory indicates an expected call of GetCategory.
func (*MockTaskMockRecorder) GetKey ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetKey() *gomock.Call
GetKey indicates an expected call of GetKey.
func (*MockTaskMockRecorder) GetNamespaceID ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetNamespaceID() *gomock.Call
GetNamespaceID indicates an expected call of GetNamespaceID.
func (*MockTaskMockRecorder) GetRunID ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetRunID() *gomock.Call
GetRunID indicates an expected call of GetRunID.
func (*MockTaskMockRecorder) GetTaskID ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call
GetTaskID indicates an expected call of GetTaskID.
func (*MockTaskMockRecorder) GetType ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetType() *gomock.Call
GetType indicates an expected call of GetType.
func (*MockTaskMockRecorder) GetVersion ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call
GetVersion indicates an expected call of GetVersion.
func (*MockTaskMockRecorder) GetVisibilityTime ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetVisibilityTime() *gomock.Call
GetVisibilityTime indicates an expected call of GetVisibilityTime.
func (*MockTaskMockRecorder) GetWorkflowID ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) GetWorkflowID() *gomock.Call
GetWorkflowID indicates an expected call of GetWorkflowID.
func (*MockTaskMockRecorder) SetTaskID ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) SetTaskID(id interface{}) *gomock.Call
SetTaskID indicates an expected call of SetTaskID.
func (*MockTaskMockRecorder) SetVisibilityTime ¶ added in v1.17.0
func (mr *MockTaskMockRecorder) SetVisibilityTime(timestamp interface{}) *gomock.Call
SetVisibilityTime indicates an expected call of SetVisibilityTime.
type NamespacePredicate ¶ added in v1.17.0
type NamespacePredicate struct {
NamespaceIDs map[string]struct{}
}
func NewNamespacePredicate ¶ added in v1.17.0
func NewNamespacePredicate(
namespaceIDs []string,
) *NamespacePredicate
type Predicate ¶ added in v1.17.0
type Predicate = predicates.Predicate[Task]
func AndPredicates ¶ added in v1.17.3
func AndPredicates(a Predicate, b Predicate) Predicate
func OrPredicates ¶ added in v1.17.3
func OrPredicates(a Predicate, b Predicate) Predicate
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) 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) 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
InitiatedEventID int64
Version int64
}
func (*SignalExecutionTask) GetCategory ¶ added in v1.16.0
func (u *SignalExecutionTask) GetCategory() Category
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) 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
InitiatedEventID int64
Version int64
}
func (*StartChildExecutionTask) GetCategory ¶ added in v1.16.0
func (u *StartChildExecutionTask) GetCategory() Category
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) 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) 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
ScheduledEventID int64
}
func (*SyncActivityTask) GetCategory ¶ added in v1.16.0
func (a *SyncActivityTask) GetCategory() Category
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) SetVersion ¶
func (a *SyncActivityTask) SetVersion(version int64)
func (*SyncActivityTask) SetVisibilityTime ¶
func (a *SyncActivityTask) SetVisibilityTime(timestamp time.Time)
type SyncWorkflowStateTask ¶ added in v1.17.0
type SyncWorkflowStateTask struct {
definition.WorkflowKey
VisibilityTimestamp time.Time
TaskID int64
Version int64
}
func (*SyncWorkflowStateTask) GetCategory ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) GetCategory() Category
func (*SyncWorkflowStateTask) GetKey ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) GetKey() Key
func (*SyncWorkflowStateTask) GetTaskID ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) GetTaskID() int64
func (*SyncWorkflowStateTask) GetType ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) GetType() enumsspb.TaskType
func (*SyncWorkflowStateTask) GetVersion ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) GetVersion() int64
func (*SyncWorkflowStateTask) GetVisibilityTime ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) GetVisibilityTime() time.Time
func (*SyncWorkflowStateTask) SetTaskID ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) SetTaskID(id int64)
func (*SyncWorkflowStateTask) SetVersion ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) SetVersion(version int64)
func (*SyncWorkflowStateTask) SetVisibilityTime ¶ added in v1.17.0
func (a *SyncWorkflowStateTask) 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
SetTaskID(id int64)
SetVisibilityTime(timestamp time.Time)
}
Task is the generic task interface
func NewFakeTask ¶ added in v1.16.0
func NewFakeTask(
workflowKey definition.WorkflowKey,
category Category,
visibilityTimestamp time.Time,
) Task
type TypePredicate ¶ added in v1.17.0
type TypePredicate struct {
Types map[enumsspb.TaskType]struct{}
}
func NewTypePredicate ¶ added in v1.17.0
func NewTypePredicate(
types []enumsspb.TaskType,
) *TypePredicate
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) 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) 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) 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) 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) 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
ScheduledEventID int64
Version int64
}
func (*WorkflowTask) GetCategory ¶ added in v1.16.0
func (d *WorkflowTask) GetCategory() Category
func (*WorkflowTask) GetVersion ¶
func (d *WorkflowTask) GetVersion() int64
func (*WorkflowTask) GetVisibilityTime ¶
func (d *WorkflowTask) GetVisibilityTime() time.Time
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
// contains filtered or unexported fields
}
func (*WorkflowTaskTimeoutTask) Cancel ¶ added in v1.21.0
func (d *WorkflowTaskTimeoutTask) Cancel()
Cancel and State are used by in-memory WorkflowTaskTimeoutTask (for speculative WT) only. TODO (alex): They need to be moved to speculativeWorkflowTaskTimeoutExecutable and workflowTaskStateMachine should somehow signal that executable directly. Major refactoring needs to be done to achieve that.
func (*WorkflowTaskTimeoutTask) GetCategory ¶ added in v1.16.0
func (d *WorkflowTaskTimeoutTask) GetCategory() Category
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) 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) 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) SetVersion ¶
func (u *WorkflowTimeoutTask) SetVersion(version int64)
func (*WorkflowTimeoutTask) SetVisibilityTime ¶
func (u *WorkflowTimeoutTask) SetVisibilityTime(t time.Time)
Source Files
¶
- activity_replication_task.go
- activity_retry_timer.go
- activity_task.go
- activity_task_timer.go
- archive_execution_task.go
- category.go
- child_workflow_task.go
- close_task.go
- close_visibility_task.go
- delete_execution_task.go
- delete_visibility_task.go
- delete_workflow_execution_stage.go
- fake_task.go
- history_replication_task.go
- key.go
- predicates.go
- requst_cancel_task.go
- reset_task.go
- signal_task.go
- start_visibility_task.go
- sync_workflow_state_task.go
- task.go
- task_mock.go
- upsert_visibility_task.go
- user_timer.go
- utils.go
- workflow_cleanup_timer.go
- workflow_delay_timer.go
- workflow_task.go
- workflow_task_timer.go
- workflow_timer.go