serviceerror

Documentation

Index

• func FromStatus(st *status.Status) error
• type CurrentBranchChanged
  • func NewCurrentBranchChanged(currentBranchToken, requestBranchToken []byte) *CurrentBranchChanged
  • func (e *CurrentBranchChanged) Error() string
  • func (e *CurrentBranchChanged) Status() *status.Status
• type RetryReplication
  • func NewRetryReplication(message string, namespaceId string, workflowId string, runId string, ...) *RetryReplication
  • func (e *RetryReplication) Error() string
  • func (e *RetryReplication) Status() *status.Status
• type ShardOwnershipLost
  • func NewShardOwnershipLost(ownerHost, currentHost string) *ShardOwnershipLost
  • func (e *ShardOwnershipLost) Error() string
  • func (e *ShardOwnershipLost) Status() *status.Status
• type TaskAlreadyStarted
  • func NewTaskAlreadyStarted(taskType string) *TaskAlreadyStarted
  • func (e *TaskAlreadyStarted) Error() string
  • func (e *TaskAlreadyStarted) Status() *status.Status

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.

func (*CurrentBranchChanged) Error

func (e *CurrentBranchChanged) Error() string

Error returns string message.

func (*CurrentBranchChanged) Status

func (e *CurrentBranchChanged) 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 NewRetryReplication

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

NewRetryReplication returns new RetryReplication error.

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 NewShardOwnershipLost

func NewShardOwnershipLost(ownerHost, currentHost string) *ShardOwnershipLost

NewShardOwnershipLost returns new ShardOwnershipLost error.

func (*ShardOwnershipLost) Error

func (e *ShardOwnershipLost) Error() string

Error returns string message.

func (*ShardOwnershipLost) Status

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 NewTaskAlreadyStarted

func NewTaskAlreadyStarted(taskType string) *TaskAlreadyStarted

NewTaskAlreadyStarted returns new TaskAlreadyStarted error.

func (*TaskAlreadyStarted) Error

func (e *TaskAlreadyStarted) Error() string

Error returns string message.

func (*TaskAlreadyStarted) Status

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