Documentation ¶
Index ¶
- func FromStatus(st *status.Status) error
- func NewCurrentBranchChanged(currentBranchToken, requestBranchToken []byte) error
- func NewRetryReplication(message string, namespaceId string, workflowId string, runId string, ...) error
- func NewShardOwnershipLost(ownerHost, currentHost string) error
- func NewTaskAlreadyStarted(taskType string) error
- type CurrentBranchChanged
- type RetryReplication
- type ShardOwnershipLost
- 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 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 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 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
Click to show internal directories.
Click to hide internal directories.