Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FromStatus ¶
func FromStatus(st *status.Status) error
FromStatus converts gogo gRPC status to service 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 NewCurrentBranchChanged ¶
func NewCurrentBranchChanged(currentBranchToken, requestBranchToken []byte) *CurrentBranchChanged
NewCurrentBranchChanged returns new CurrentBranchChanged error.
type RetryTask ¶
type RetryTask struct {
Message string
NamespaceId string
WorkflowId string
RunId string
NextEventId int64
// contains filtered or unexported fields
}
RetryTask represents retry task error.
func NewRetryTask ¶
func NewRetryTask(message, namespaceId, workflowId, runId string, nextEventId int64) *RetryTask
NewRetryTask returns new RetryTask error.
type RetryTaskV2 ¶
type RetryTaskV2 struct {
Message string
NamespaceId string
WorkflowId string
RunId string
StartEventId int64
StartEventVersion int64
EndEventId int64
EndEventVersion int64
// contains filtered or unexported fields
}
RetryTaskV2 represents retry task v2 error.
func NewRetryTaskV2 ¶
func NewRetryTaskV2(message, namespaceId, workflowId, runId string, startEventId, startEventVersion, endEventId, endEventVersion int64) *RetryTaskV2
NewRetryTaskV2 returns new RetryTaskV2 error.
type ShardOwnershipLost ¶
type ShardOwnershipLost struct {
Message string
OwnerHost string
CurrentHost string
// contains filtered or unexported fields
}
ShardOwnershipLost represents shard ownership lost error.
func NewShardOwnershipLost ¶
func NewShardOwnershipLost(ownerHost, currentHost string) *ShardOwnershipLost
NewShardOwnershipLost returns new ShardOwnershipLost error.
type TaskAlreadyStarted ¶
type TaskAlreadyStarted struct {
Message string
// contains filtered or unexported fields
}
TaskAlreadyStarted represents task already started error.
func NewTaskAlreadyStarted ¶
func NewTaskAlreadyStarted(taskType string) *TaskAlreadyStarted
NewTaskAlreadyStarted returns new TaskAlreadyStarted error.
Click to show internal directories.
Click to hide internal directories.