Affected by 
Documentation
¶
Index ¶
- func FromStatus(st *status.Status) error
- func NewCurrentBranchChanged(currentBranchToken, requestBranchToken []byte) error
- func NewInternalErrorWithDPanic(logger log.Logger, 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 NewTaskAlreadyStarted(taskType string) error
- type CurrentBranchChanged
- type RetryReplication
- type ShardOwnershipLost
- type StickyWorkerUnavailable
- type TaskAlreadyStarted
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FromStatus ¶
FromStatus converts gogo gRPC status to service error.
func NewCurrentBranchChanged ¶
NewCurrentBranchChanged returns new CurrentBranchChanged error.
func NewInternalErrorWithDPanic ¶ added in v1.20.0
NewInternalErrorWithDPanic is a wrapper for service error that will panic if it's in dev environment
func NewRetryReplication ¶ added in v1.4.0
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 ¶
NewShardOwnershipLost returns new ShardOwnershipLost error.
func NewStickyWorkerUnavailable ¶ added in v1.17.0
func NewStickyWorkerUnavailable() error
NewStickyWorkerUnavailable returns new StickyWorkerUnavailable error.
func NewTaskAlreadyStarted ¶
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 ¶ added in v0.31.0
func (e *CurrentBranchChanged) Status() *status.Status
type RetryReplication ¶ added in v1.4.0
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) Error ¶ added in v1.4.0
func (e *RetryReplication) Error() string
Error returns string message.
func (*RetryReplication) Status ¶ added in v1.4.0
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 ¶ added in v0.31.0
func (e *ShardOwnershipLost) Status() *status.Status
type StickyWorkerUnavailable ¶ added in v1.17.0
type StickyWorkerUnavailable struct {
// contains filtered or unexported fields
}
StickyWorkerUnavailable represents sticky worker unavailable error.
func (*StickyWorkerUnavailable) Error ¶ added in v1.17.0
func (e *StickyWorkerUnavailable) Error() string
Error returns string message.
func (*StickyWorkerUnavailable) Status ¶ added in v1.17.0
func (e *StickyWorkerUnavailable) 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 ¶ added in v0.31.0
func (e *TaskAlreadyStarted) Status() *status.Status
Source Files