ctxutil

Documentation

Index

• func Cancel(ctx context.Context)
• func CancelAfterInactivity(ctx context.Context, key string, d time.Duration)
• func CancelContext(ctx context.Context) context.Context
• func SimpleKey(name string) interface{}
• func Tick(ctx context.Context, key string)
• func TickContext(ctx context.Context, key string) context.Context
• func WaitForInactivity(ctx context.Context, key string, d time.Duration)
• func WaitGroupAdd(ctx context.Context)
• func WaitGroupContext(ctx context.Context, desc ...string) context.Context
• func WaitGroupDone(ctx context.Context)
• func WaitGroupRun(ctx context.Context, f func())
• func WaitGroupRunAndCancelOnExit(ctx context.Context, f func())
• func WaitGroupRunUntilCancelled(ctx context.Context, f func())
• func WaitGroupWait(ctx context.Context, duration time.Duration, desc ...string)
• type Ticker
  • func (this *Ticker) CancelAfterInactivity(ctx context.Context, d time.Duration)
  • func (this *Ticker) WaitForInactivity(ctx context.Context, d time.Duration)
• type ValueKey
  • func NewValueKey(name string, proto interface{}) ValueKey
• type WaitGroup
  • func NewWaitGroup(name string) *WaitGroup
  • func (this *WaitGroup) WaitWithTimeout(duration time.Duration, desc ...string)

Functions

func Cancel

func Cancel(ctx context.Context)

func CancelAfterInactivity

func CancelAfterInactivity(ctx context.Context, key string, d time.Duration)

func CancelContext

func CancelContext(ctx context.Context) context.Context

func SimpleKey

func SimpleKey(name string) interface{}

func Tick

func Tick(ctx context.Context, key string)

func TickContext

func TickContext(ctx context.Context, key string) context.Context

func WaitForInactivity

func WaitForInactivity(ctx context.Context, key string, d time.Duration)

func WaitGroupAdd

func WaitGroupAdd(ctx context.Context)

func WaitGroupContext

func WaitGroupContext(ctx context.Context, desc ...string) context.Context

func WaitGroupDone

func WaitGroupDone(ctx context.Context)

func WaitGroupRun

func WaitGroupRun(ctx context.Context, f func())

func WaitGroupRunAndCancelOnExit

func WaitGroupRunAndCancelOnExit(ctx context.Context, f func())

func WaitGroupRunUntilCancelled

func WaitGroupRunUntilCancelled(ctx context.Context, f func())

func WaitGroupWait

func WaitGroupWait(ctx context.Context, duration time.Duration, desc ...string)

Types

type Ticker

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

func (*Ticker) CancelAfterInactivity

func (this *Ticker) CancelAfterInactivity(ctx context.Context, d time.Duration)

func (*Ticker) WaitForInactivity

func (this *Ticker) WaitForInactivity(ctx context.Context, d time.Duration)

type ValueKey

type ValueKey interface {
	Name() string
	WithValue(ctx context.Context, value interface{}) context.Context
	Get(ctx context.Context) interface{}
}

func NewValueKey

func NewValueKey(name string, proto interface{}) ValueKey

type WaitGroup

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

func NewWaitGroup

func NewWaitGroup(name string) *WaitGroup

func (*WaitGroup) WaitWithTimeout

func (this *WaitGroup) WaitWithTimeout(duration time.Duration, desc ...string)