serviceerror

type ActivityStartDuringTransition ¶

type ActivityStartDuringTransition struct {
	Message string
	// contains filtered or unexported fields
}

ActivityStartDuringTransition when an activity start is rejected by History because the workflow is in a transitioning between worker deployments. When Matching sees this error it can safely drop the activity task because History will reschedule the activity task after the transition is complete.

func (e *ActivityStartDuringTransition) Error() string

func (e *ActivityStartDuringTransition) Status() *status.Status

type CurrentBranchChanged ¶

type CurrentBranchChanged struct {
	Message                    string
	CurrentBranchToken         []byte
	RequestBranchToken         []byte
	CurrentVersionedTransition *persistencespb.VersionedTransition
	RequestVersionedTransition *persistencespb.VersionedTransition
	// contains filtered or unexported fields
}

CurrentBranchChanged represents current branch changed error.

func (e *CurrentBranchChanged) Error() string

func (e *CurrentBranchChanged) Status() *status.Status

type ObsoleteDispatchBuildId ¶

type ObsoleteDispatchBuildId struct {
	Message string
	// contains filtered or unexported fields
}

ObsoleteDispatchBuildId happens when matching wants to dispatch task to an obsolete build ID. This is expected to happen when a workflow has concurrent tasks (and in some other edge cases) and redirect rules apply to the WF. In that case, tasks already scheduled but not started will become invalid and History reschedules them in the new build ID. Matching will still try dispatching the old tasks but it will face this error. Matching can safely drop tasks which face this error. Deprecated. [cleanup-old-wv]

func (e *ObsoleteDispatchBuildId) Error() string

func (e *ObsoleteDispatchBuildId) Status() *status.Status

type ObsoleteMatchingTask ¶

type ObsoleteMatchingTask struct {
	Message string
	// contains filtered or unexported fields
}

ObsoleteMatchingTask happens when History determines a task that Matching wants to dispatch is no longer valid. Some examples:

• WFT belongs to a sticky queue but the workflow is not on that sticky queue anymore.
• WFT belongs to the normal queue but no the workflow is on a sticky queue.
• WFT options were updated and the task was rescheduled
• WF or activity task wants to start but their schedule time directive deployment no longer matched the workflows effective deployment.

When Matching receives this error it can safely drop the task because History has already scheduled new Matching tasks on the right task queue and deployment.

func (e *ObsoleteMatchingTask) Error() string

func (e *ObsoleteMatchingTask) Status() *status.Status

type RetryReplication ¶

type RetryReplication struct {
	Message           string
	NamespaceId       string
	WorkflowId        string
	RunId             string
	StartEventId      int64
	StartEventVersion int64
	EndEventId        int64
	EndEventVersion   int64
	// contains filtered or unexported fields
}

RetryReplication represents retry task v2 error.

func (e *RetryReplication) Equal(err *RetryReplication) bool

func (e *RetryReplication) Error() string

func (e *RetryReplication) Status() *status.Status

type ShardOwnershipLost ¶

type ShardOwnershipLost struct {
	Message     string
	OwnerHost   string
	CurrentHost string
	// contains filtered or unexported fields
}

ShardOwnershipLost represents shard ownership lost error.

func (e *ShardOwnershipLost) Error() string

func (e *ShardOwnershipLost) Status() *status.Status

type StickyWorkerUnavailable ¶

type StickyWorkerUnavailable struct {
	Message string
	// contains filtered or unexported fields
}

StickyWorkerUnavailable represents sticky worker unavailable error.

func (e *StickyWorkerUnavailable) Error() string

func (e *StickyWorkerUnavailable) Status() *status.Status

type SyncState ¶

type SyncState struct {
	Message             string
	NamespaceId         string
	WorkflowId          string
	RunId               string
	ArchetypeId         uint32
	VersionedTransition *persistencespb.VersionedTransition
	VersionHistories    *historyspb.VersionHistories
	// contains filtered or unexported fields
}

SyncState represents sync state error. nolint:staticcheck

func (e *SyncState) Equal(err *SyncState) bool

func (e *SyncState) Error() string

func (e *SyncState) Status() *status.Status

type TaskAlreadyStarted ¶

type TaskAlreadyStarted struct {
	Message string
	// contains filtered or unexported fields
}

TaskAlreadyStarted represents task already started error.

func (e *TaskAlreadyStarted) Error() string

func (e *TaskAlreadyStarted) Status() *status.Status