async

Documentation

Index

• type AtomicGroup
  • func NewAtomicGroup(parent context.Context) *AtomicGroup
  • func (d *AtomicGroup) Add(cmd Command)
  • func (d *AtomicGroup) Error() error
  • func (d *AtomicGroup) Stop()
  • func (d *AtomicGroup) Wait()
  • func (d *AtomicGroup) WaitAsync() <-chan struct{}
• type Command
• type Commander
• type FiniteCommand
  • func (c FiniteCommand) Run(ctx context.Context) error
• type Group
  • func NewGroup(parent context.Context) *Group
  • func (g *Group) Add(cmd Command)
  • func (g *Group) Stop()
  • func (g *Group) Wait()
  • func (g *Group) WaitAsync() <-chan struct{}
• type InfiniteCommand
  • func (c InfiniteCommand) Run(ctx context.Context) error
• type QueuedAtomicGroup
  • func NewQueuedAtomicGroup(parent context.Context, limit uint32) *QueuedAtomicGroup
  • func (d *QueuedAtomicGroup) Add(cmd Command)

Types

type AtomicGroup

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

AtomicGroup terminates as soon as first goroutine terminates..

func NewAtomicGroup

func NewAtomicGroup(parent context.Context) *AtomicGroup

func (*AtomicGroup) Add

func (d *AtomicGroup) Add(cmd Command)

Go spawns function in a goroutine and stores results or errors.

func (*AtomicGroup) Error

func (d *AtomicGroup) Error() error

Error stores an error that was reported by any of the downloader. Should be called after Wait.

func (*AtomicGroup) Stop

func (d *AtomicGroup) Stop()

func (*AtomicGroup) Wait

func (d *AtomicGroup) Wait()

Wait for all downloaders to finish.

func (*AtomicGroup) WaitAsync

func (d *AtomicGroup) WaitAsync() <-chan struct{}

type Command

type Command func(context.Context) error

type Commander

type Commander interface {
	Command() Command
}

type FiniteCommand

type FiniteCommand struct {
	Interval time.Duration
	Runable  func(context.Context) error
}

FiniteCommand terminates when error is nil.

func (FiniteCommand) Run

func (c FiniteCommand) Run(ctx context.Context) error

type Group

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

func NewGroup

func NewGroup(parent context.Context) *Group

func (*Group) Add

func (g *Group) Add(cmd Command)

func (*Group) Stop

func (g *Group) Stop()

func (*Group) Wait

func (g *Group) Wait()

func (*Group) WaitAsync

func (g *Group) WaitAsync() <-chan struct{}

type InfiniteCommand

type InfiniteCommand struct {
	Interval time.Duration
	Runable  func(context.Context) error
}

InfiniteCommand runs until context is closed.

func (InfiniteCommand) Run

func (c InfiniteCommand) Run(ctx context.Context) error

type QueuedAtomicGroup

type QueuedAtomicGroup struct {
	*AtomicGroup
	// contains filtered or unexported fields
}

func NewQueuedAtomicGroup

func NewQueuedAtomicGroup(parent context.Context, limit uint32) *QueuedAtomicGroup

func (*QueuedAtomicGroup) Add

func (d *QueuedAtomicGroup) Add(cmd Command)