serviceerror

Documentation

Index

• func FromStatus(st *status.Status) error
• func NewCurrentBranchChanged(currentBranchToken, requestBranchToken []byte) error
• func NewInternalErrorWithDPanic(logger log.Logger, msg string) error
• func NewObsoleteDispatchBuildId(msg string) error
• func NewRetryReplication(message string, namespaceId string, workflowId string, runId string, ...) error
• func NewShardOwnershipLost(ownerHost string, currentHost string) error
• func NewStickyWorkerUnavailable() error
• func NewSyncState(message string, namespaceId string, workflowId string, runId string, ...) error
• func NewTaskAlreadyStarted(taskType string) error
• type CurrentBranchChanged
  • func (e *CurrentBranchChanged) Error() string
  • func (e *CurrentBranchChanged) Status() *status.Status
• type ObsoleteDispatchBuildId
  • func (e *ObsoleteDispatchBuildId) Error() string
  • func (e *ObsoleteDispatchBuildId) Status() *status.Status
• type RetryReplication
  • func (e *RetryReplication) Equal(err *RetryReplication) bool
  • func (e *RetryReplication) Error() string
  • func (e *RetryReplication) Status() *status.Status
• type ShardOwnershipLost
  • func (e *ShardOwnershipLost) Error() string
  • func (e *ShardOwnershipLost) Status() *status.Status
• type StickyWorkerUnavailable
  • func (e *StickyWorkerUnavailable) Error() string
  • func (e *StickyWorkerUnavailable) Status() *status.Status
• type SyncState
  • func (e *SyncState) Equal(err *SyncState) bool
  • func (e *SyncState) Error() string
  • func (e *SyncState) Status() *status.Status
• type TaskAlreadyStarted
  • func (e *TaskAlreadyStarted) Error() string
  • func (e *TaskAlreadyStarted) Status() *status.Status

Functions

func FromStatus

func FromStatus(st *status.Status) error

FromStatus converts gRPC status to service error.

func NewCurrentBranchChanged

func NewCurrentBranchChanged(currentBranchToken, requestBranchToken []byte) error

NewCurrentBranchChanged returns new CurrentBranchChanged error. TODO: Update CurrentBranchChanged with event id and event version. Do not use branch token bytes as branch identity.

func NewInternalErrorWithDPanic

func NewInternalErrorWithDPanic(logger log.Logger, msg string) error

NewInternalErrorWithDPanic is a wrapper for service error that will panic if it's in dev environment

func NewObsoleteDispatchBuildId

func NewObsoleteDispatchBuildId(msg string) error

func NewRetryReplication

func NewRetryReplication(
	message string,
	namespaceId string,
	workflowId string,
	runId string,
	startEventId int64,
	startEventVersion int64,
	endEventId int64,
	endEventVersion int64,
) error

NewRetryReplication returns new RetryReplication error.

func NewShardOwnershipLost

func NewShardOwnershipLost(ownerHost string, currentHost string) error

NewShardOwnershipLost returns new ShardOwnershipLost error.

func NewStickyWorkerUnavailable

func NewStickyWorkerUnavailable() error

NewStickyWorkerUnavailable returns new StickyWorkerUnavailable error.

func NewSyncState

func NewSyncState(
	message string,
	namespaceId string,
	workflowId string,
	runId string,
	versionedTransition *persistencespb.VersionedTransition,
) error

NewSyncState returns new SyncState error.

func NewTaskAlreadyStarted

func NewTaskAlreadyStarted(taskType string) error

NewTaskAlreadyStarted returns new TaskAlreadyStarted error.

Types

type CurrentBranchChanged

type CurrentBranchChanged struct {
	Message            string
	CurrentBranchToken []byte
	RequestBranchToken []byte
	// contains filtered or unexported fields
}

CurrentBranchChanged represents current branch changed error.

func (*CurrentBranchChanged) Error

func (e *CurrentBranchChanged) Error() string

Error returns string message.

func (*CurrentBranchChanged) Status

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.

func (*ObsoleteDispatchBuildId) Error

func (e *ObsoleteDispatchBuildId) Error() string

Error returns string message.

func (*ObsoleteDispatchBuildId) Status

func (e *ObsoleteDispatchBuildId) 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 (*RetryReplication) Equal

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

func (*RetryReplication) Error

func (e *RetryReplication) Error() string

Error returns string message.

func (*RetryReplication) Status

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 (*ShardOwnershipLost) Error

func (e *ShardOwnershipLost) Error() string

Error returns string message.

func (*ShardOwnershipLost) Status

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 (*StickyWorkerUnavailable) Error

func (e *StickyWorkerUnavailable) Error() string

Error returns string message.

func (*StickyWorkerUnavailable) Status

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

type SyncState

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

SyncState represents sync state error.

func (*SyncState) Equal

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

func (*SyncState) Error

func (e *SyncState) Error() string

Error returns string message.

func (*SyncState) Status

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 (*TaskAlreadyStarted) Error

func (e *TaskAlreadyStarted) Error() string

Error returns string message.

func (*TaskAlreadyStarted) Status

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