wait

Documentation

Index

• type LogFunc
• type Observer
  • func NewObserver(ctx context.Context, p Parameters) *Observer
  • func (w *Observer) Cancel()
  • func (w *Observer) Retry(err error) error
• type Parameters

Types

type LogFunc

type LogFunc func(err error, waitTime string)

type Observer

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

func NewObserver

func NewObserver(ctx context.Context, p Parameters) *Observer

func (*Observer) Cancel

func (w *Observer) Cancel()

func (*Observer) Retry

func (w *Observer) Retry(err error) error

type Parameters

type Parameters struct {
	RetryInterval   time.Duration
	WarningInterval time.Duration
	Timeout         time.Duration
	Log             LogFunc
}