run

Documentation

Index

• func CheckUntil(f func() bool, dur time.Duration, stopCh <-chan struct{}) bool
• func CheckUntilImmediately(f func() bool, dur time.Duration, stopCh <-chan struct{}) bool
• func EachUntil(f func(), dur time.Duration, stopCh <-chan struct{})
• func EachUntilImmediately(f func(), dur time.Duration, stopCh <-chan struct{})
• type LazyRunner
  • func (lr *LazyRunner) AddSupervisor(stopCh <-chan struct{})
  • func (lr *LazyRunner) Wait()

Functions

func CheckUntil

func CheckUntil(f func() bool, dur time.Duration, stopCh <-chan struct{}) bool

CheckUntil run f each dur, until f return true or stopCh return when stop because f return true, CheckUntil return true when stop because stopCh return, CheckUntil return false

func CheckUntilImmediately

func CheckUntilImmediately(f func() bool, dur time.Duration, stopCh <-chan struct{}) bool

CheckUntilImmediately is an immediately version of CheckUntil CheckUntilImmediatelylike EachUntilImmediately to EachUntil

func EachUntil

func EachUntil(f func(), dur time.Duration, stopCh <-chan struct{})

EachUntil run f each dur, until stopCh return

func EachUntilImmediately

func EachUntilImmediately(f func(), dur time.Duration, stopCh <-chan struct{})

EachUntilImmediately like EachUntil but run f once immediately, unless stopCh already return

Types

type LazyRunner

type LazyRunner struct {
	Run func(stopCh <-chan struct{})

	Locker interface {
		sync.Locker

		RLock()
		RUnlock()
	} // protect supervisorStopChs, running, stoppedCh
	// contains filtered or unexported fields
}

LazyRunner run Run only when there is at least one supervisor

func (*LazyRunner) AddSupervisor

func (lr *LazyRunner) AddSupervisor(stopCh <-chan struct{})

func (*LazyRunner) Wait

func (lr *LazyRunner) Wait()