zombie

README

zombie

AFAIRE

Licence

MIT.

---

Copyright (c) 2021-2022 losyme

Documentation

Index

• type GWContext
  • func GoWithContext(ctx context.Context, count int, fn func(ctx context.Context, n int), ...) *GWContext
  • func NewGWContext(ctx context.Context, opts ...Option) *GWContext
  • func (g *GWContext) Go(count int, fn func(ctx context.Context, n int), name string)
  • func (g *GWContext) Stop()
  • func (g *GWContext) Wait()
• type GWTicker
  • func GoWithTicker(ctx context.Context, count int, d time.Duration, cb func(), opts ...Option) *GWTicker
  • func (g *GWTicker) Go(count int)
  • func (g *GWTicker) Stop()
  • func (g *GWTicker) Wait()
• type GWTimer
  • func GoWithTimer(ctx context.Context, count int, d time.Duration, cb func() time.Duration, ...) *GWTimer
  • func (g *GWTimer) Go(count int)
  • func (g *GWTimer) Stop()
  • func (g *GWTimer) Wait()
• type Group
  • func Go(count int, fn func(n int), opts ...Option) *Group
  • func NewGroup(opts ...Option) *Group
  • func (g *Group) Go(count int, fn func(n int), name string)
  • func (g *Group) Wait()
• type Logger
• type Option
  • func WithLogger(logger Logger) Option
  • func WithName(name string) Option

Types

type GWContext

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

func GoWithContext

func GoWithContext(ctx context.Context, count int, fn func(ctx context.Context, n int), opts ...Option) *GWContext

func NewGWContext

func NewGWContext(ctx context.Context, opts ...Option) *GWContext

func (*GWContext) Go

func (g *GWContext) Go(count int, fn func(ctx context.Context, n int), name string)

func (*GWContext) Stop

func (g *GWContext) Stop()

func (*GWContext) Wait

func (g *GWContext) Wait()

type GWTicker

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

func GoWithTicker

func GoWithTicker(ctx context.Context, count int, d time.Duration, cb func(), opts ...Option) *GWTicker

func (*GWTicker) Go

func (g *GWTicker) Go(count int)

func (*GWTicker) Stop

func (g *GWTicker) Stop()

func (*GWTicker) Wait

func (g *GWTicker) Wait()

type GWTimer

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

func GoWithTimer

func GoWithTimer(ctx context.Context, count int, d time.Duration, cb func() time.Duration, opts ...Option) *GWTimer

func (*GWTimer) Go

func (g *GWTimer) Go(count int)

func (*GWTimer) Stop

func (g *GWTimer) Stop()

func (*GWTimer) Wait

func (g *GWTimer) Wait()

type Group

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

func Go

func Go(count int, fn func(n int), opts ...Option) *Group

func NewGroup

func NewGroup(opts ...Option) *Group

func (*Group) Go

func (g *Group) Go(count int, fn func(n int), name string)

func (*Group) Wait

func (g *Group) Wait()

type Logger

type Logger interface {
	Trace(msg string, kv ...interface{})
}

type Option

type Option func(*Group)

func WithLogger

func WithLogger(logger Logger) Option

func WithName

func WithName(name string) Option