syncx

Documentation

Index

• Variables
• type CompletionTimer
  • func NewCompletionTimer(maxIdleTime, maxTotalTime time.Duration, check func() bool) *CompletionTimer
  • func (t *CompletionTimer) Cancel()
  • func (t *CompletionTimer) Notify()
  • func (t *CompletionTimer) Reset() int32
  • func (t *CompletionTimer) WaitForCompletion() (err error)
• type WaitGroup
  • func NewWaitGroup(ctx context.Context) *WaitGroup
  • func (wg *WaitGroup) Add(delta int)
  • func (wg *WaitGroup) Cancel()
  • func (wg *WaitGroup) Done()
  • func (wg *WaitGroup) Wait() (err error)

Variables

var Cancelled = errors.New("cancelled")

var ExceededMaxTime = errors.New("exceeded max time")

var IdleTimeout = errors.New("idle timeout")

Types

type CompletionTimer

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

func NewCompletionTimer

func NewCompletionTimer(maxIdleTime, maxTotalTime time.Duration, check func() bool) *CompletionTimer

func (*CompletionTimer) Cancel

func (t *CompletionTimer) Cancel()

func (*CompletionTimer) Notify

func (t *CompletionTimer) Notify()

func (*CompletionTimer) Reset

func (t *CompletionTimer) Reset() int32

Reset lets the completion timer do a new WaitForCompletion if the previous returned an IdleTimeout Reset returns the number of notifications received since last reset

func (*CompletionTimer) WaitForCompletion

func (t *CompletionTimer) WaitForCompletion() (err error)

type WaitGroup

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

func NewWaitGroup

func NewWaitGroup(ctx context.Context) *WaitGroup

func (*WaitGroup) Add

func (wg *WaitGroup) Add(delta int)

func (*WaitGroup) Cancel

func (wg *WaitGroup) Cancel()

func (*WaitGroup) Done

func (wg *WaitGroup) Done()

func (*WaitGroup) Wait

func (wg *WaitGroup) Wait() (err error)