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 RetryTask
  • func NewRetryTask(message, namespaceId, workflowId, runId string, nextEventId int64) *RetryTask
  • func (e *RetryTask) Error() string
  • func (e *RetryTask) Status() *status.Status
• type RetryTaskV2
  • func NewRetryTaskV2(message, namespaceId, workflowId, runId string, ...) *RetryTaskV2
  • func (e *RetryTaskV2) Error() string
  • func (e *RetryTaskV2) 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 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.

func (*RetryTask) Error

func (e *RetryTask) Error() string

Error returns string message.

func (*RetryTask) Status

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

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.

func (*RetryTaskV2) Error

func (e *RetryTaskV2) Error() string

Error returns string message.

func (*RetryTaskV2) Status

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