sync

Documentation

Index

• Variables
• type ExtendedWaitGroup
  • func (wg *ExtendedWaitGroup) Add(delta int)
  • func (wg *ExtendedWaitGroup) Done()
  • func (wg *ExtendedWaitGroup) UpdateUntil(waitUntil time.Time)
  • func (wg *ExtendedWaitGroup) Wait()
  • func (wg *ExtendedWaitGroup) WaitUntil(waitUntil time.Time) error
  • func (wg *ExtendedWaitGroup) WaitWithTimeout(duration time.Duration) error

Variables

var (
	TimeoutError = fmt.Errorf("group timed out")
)

Types

type ExtendedWaitGroup

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

func (*ExtendedWaitGroup) Add

func (wg *ExtendedWaitGroup) Add(delta int)

func (*ExtendedWaitGroup) Done

func (wg *ExtendedWaitGroup) Done()

func (*ExtendedWaitGroup) UpdateUntil

func (wg *ExtendedWaitGroup) UpdateUntil(waitUntil time.Time)

func (*ExtendedWaitGroup) Wait

func (wg *ExtendedWaitGroup) Wait()

func (*ExtendedWaitGroup) WaitUntil

func (wg *ExtendedWaitGroup) WaitUntil(waitUntil time.Time) error

func (*ExtendedWaitGroup) WaitWithTimeout

func (wg *ExtendedWaitGroup) WaitWithTimeout(duration time.Duration) error