utils

Documentation

Index

• Variables
• func AwaitConnection(dialer func() (interface{}, error), timeout time.Duration) (interface{}, error)
• type TimeoutRetryer
  • func NewRetryer(f func() (interface{}, error), deadlineTimeout time.Duration) *TimeoutRetryer
  • func (r *TimeoutRetryer) Do() (interface{}, error)

Variables

var (
	ErrDeadlineExceeded = errors.New("deadline exceeded")
)

Functions

func AwaitConnection

func AwaitConnection(dialer func() (interface{}, error), timeout time.Duration) (interface{}, error)

Types

type TimeoutRetryer

type TimeoutRetryer struct {
	DeadlineTimeout     time.Duration
	AttemptTimeout      time.Duration
	AttemptErrorHanlder func(err error)
	// contains filtered or unexported fields
}

func NewRetryer

func NewRetryer(f func() (interface{}, error), deadlineTimeout time.Duration) *TimeoutRetryer

func (*TimeoutRetryer) Do

func (r *TimeoutRetryer) Do() (interface{}, error)