serviceerror

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
  • func (e *CurrentBranchChanged) Error() string
  • func (e *CurrentBranchChanged) Status() *status.Status
• type RetryReplication
  • func (e *RetryReplication) Error() string
  • func (e *RetryReplication) Status() *status.Status
• type ShardOwnershipLost
  • func (e *ShardOwnershipLost) Error() string
  • func (e *ShardOwnershipLost) Status() *status.Status
• type StickyWorkerUnavailable
  • func (e *StickyWorkerUnavailable) Error() string
  • func (e *StickyWorkerUnavailable) Status() *status.Status
• type TaskAlreadyStarted
  • func (e *TaskAlreadyStarted) Error() string
  • func (e *TaskAlreadyStarted) Status() *status.Status

Functions

func FromStatus

func FromStatus(st *status.Status) error

FromStatus converts gRPC status to service error.

func NewCurrentBranchChanged

func NewCurrentBranchChanged(currentBranchToken, requestBranchToken []byte) error

NewCurrentBranchChanged returns new CurrentBranchChanged error. TODO: Update CurrentBranchChanged with event id and event version. Do not use branch token bytes as branch identity.

func NewInternalErrorWithDPanic

func NewInternalErrorWithDPanic(logger log.Logger, msg string) error

NewInternalErrorWithDPanic is a wrapper for service error that will panic if it's in dev environment

func NewRetryReplication

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

func NewShardOwnershipLost(ownerHost string, currentHost string) error

NewShardOwnershipLost returns new ShardOwnershipLost error.

func NewStickyWorkerUnavailable

func NewStickyWorkerUnavailable() error

NewStickyWorkerUnavailable returns new StickyWorkerUnavailable error.

func NewTaskAlreadyStarted

func NewTaskAlreadyStarted(taskType string) error

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

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 (*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 (*ShardOwnershipLost) Error

func (e *ShardOwnershipLost) Error() string

Error returns string message.

func (*ShardOwnershipLost) Status

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

type StickyWorkerUnavailable

type StickyWorkerUnavailable struct {
	Message string
	// contains filtered or unexported fields
}

StickyWorkerUnavailable represents sticky worker unavailable error.

func (*StickyWorkerUnavailable) Error

func (e *StickyWorkerUnavailable) Error() string

Error returns string message.

func (*StickyWorkerUnavailable) Status

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

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