picker

Documentation

Index

• type Picker
  • func WithContext(ctx context.Context) (*Picker, context.Context)
  • func WithTimeout(ctx context.Context, timeout time.Duration) (*Picker, context.Context)
  • func (p *Picker) Error() error
  • func (p *Picker) Go(f func() (any, error))
  • func (p *Picker) Wait() any

Types

type Picker

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

Picker provides synchronization, and Context cancelation for groups of goroutines working on subtasks of a common task. Inspired by errGroup

func WithContext

func WithContext(ctx context.Context) (*Picker, context.Context)

WithContext returns a new Picker and an associated Context derived from ctx. and cancel when first element return.

func WithTimeout

func WithTimeout(ctx context.Context, timeout time.Duration) (*Picker, context.Context)

WithTimeout returns a new Picker and an associated Context derived from ctx with timeout.

func (*Picker) Error

func (p *Picker) Error() error

Error return the first error (if all success return nil)

func (*Picker) Go

func (p *Picker) Go(f func() (any, error))

Go calls the given function in a new goroutine. The first call to return a nil error cancels the group; its result will be returned by Wait.

func (*Picker) Wait

func (p *Picker) Wait() any

Wait blocks until all function calls from the Go method have returned, then returns the first nil error result (if any) from them.