vpcerrors

package
v0.0.0-...-c3677c5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 10, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsConcurrencyError

func IsConcurrencyError(err error) bool

func IsPersistentError

func IsPersistentError(err error) bool

func IsRetryable

func IsRetryable(err error) bool

func IsSerializationFailure

func IsSerializationFailure(err error) bool

func IsSleep

func IsSleep(err error) bool

func NewConcurrencyError

func NewConcurrencyError(err error) error

func NewIrrecoverableError

func NewIrrecoverableError(err error) error

func NewMethodNotPossibleError

func NewMethodNotPossibleError(method string) error

func NewNotFoundError

func NewNotFoundError(err error) error

func NewPersistentError

func NewPersistentError(err error) error

func NewRetryable

func NewRetryable(err error) error

func NewWithSleep

func NewWithSleep(err error) error

func PqError

func PqError(err error) *pq.Error

Types

type ConcurrencyError

type ConcurrencyError struct {
	// contains filtered or unexported fields
}

func (*ConcurrencyError) Error

func (c *ConcurrencyError) Error() string

func (*ConcurrencyError) GRPCStatus

func (c *ConcurrencyError) GRPCStatus() *status.Status

func (*ConcurrencyError) Is

func (c *ConcurrencyError) Is(target error) bool

func (*ConcurrencyError) Unwrap

func (c *ConcurrencyError) Unwrap() error

type ErrGroupish

type ErrGroupish struct {
	// contains filtered or unexported fields
}

func NewErrGroupIsh

func NewErrGroupIsh() *ErrGroupish

func (*ErrGroupish) Run

func (e *ErrGroupish) Run(f func() error)

func (*ErrGroupish) Wait

func (e *ErrGroupish) Wait(ctx context.Context) error

type IrrecoverableError

type IrrecoverableError struct {
	// contains filtered or unexported fields
}

vpcerrors.IrrecoverableError indicates that this work item cannot be started

func (*IrrecoverableError) Error

func (p *IrrecoverableError) Error() string

func (*IrrecoverableError) Is

func (p *IrrecoverableError) Is(target error) bool

func (*IrrecoverableError) Unwrap

func (p *IrrecoverableError) Unwrap() error

type MethodNotPossible

type MethodNotPossible struct {
	// contains filtered or unexported fields
}

func (*MethodNotPossible) Error

func (m *MethodNotPossible) Error() string

func (*MethodNotPossible) GRPCStatus

func (m *MethodNotPossible) GRPCStatus() *status.Status

func (*MethodNotPossible) Is

func (m *MethodNotPossible) Is(target error) bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL