common

Documentation

Index

• Constants
• func IsNotFound(err error) bool
• func WaitForCompleted(condition wait.ConditionFunc) error
• type ExecutePool
  • func NewExecutePool(size int) *ExecutePool
  • func (w *ExecutePool) Start()
  • func (w *ExecutePool) Stop()
  • func (w *ExecutePool) Submit(work JobHandle)
• type JobHandle

Constants

const (
	DefaultInitDelay = 2 * time.Second
	DefaultFactor    = 1.02
	DefaultSteps     = 30
)

Functions

func IsNotFound

func IsNotFound(err error) bool

func WaitForCompleted

func WaitForCompleted(condition wait.ConditionFunc) error

WaitForCompleted wait for completion, interval 2s+, up to 30 pols

Types

type ExecutePool

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

func NewExecutePool

func NewExecutePool(size int) *ExecutePool

func (*ExecutePool) Start

func (w *ExecutePool) Start()

func (*ExecutePool) Stop

func (w *ExecutePool) Stop()

func (*ExecutePool) Submit

func (w *ExecutePool) Submit(work JobHandle)

type JobHandle

type JobHandle func()