futures

Documentation

Index

• func AsCompleted(fs ...*F) <-chan *F
• func AsCompletedDelayed(ctx context.Context, initial []*F, delayed []Delayed) <-chan *F
• type Delayed
• type F
  • func Start(fn func() (interface{}, error)) *F
  • func StartNoError(fn func() interface{}) *F
  • func (f *F) Done() <-chan struct{}
  • func (f *F) Err() error
  • func (f *F) MustResult() interface{}
  • func (f *F) Result() (interface{}, error)
  • func (f *F) ScanResult(res interface{}) error
  • func (f *F) SetName(s string)
  • func (f *F) String() string

Functions

func AsCompleted

func AsCompleted(fs ...*F) <-chan *F

Sends each future as it completes on the returned chan, closing it when everything has been sent.

func AsCompletedDelayed

func AsCompletedDelayed(ctx context.Context, initial []*F, delayed []Delayed) <-chan *F

Returns futures as they complete. Delayed futures are not released until their timeout has passed, or all prior delayed futures, and the initial set have completed. One use case is to prefer the value in some futures over others, such as hitting several origin servers where some are better informed than others.

Types

type Delayed

type Delayed struct {
	Delay time.Duration
	Fs    []*F
}

type F

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

func Start

func Start(fn func() (interface{}, error)) *F

func StartNoError

func StartNoError(fn func() interface{}) *F

func (*F) Done

func (f *F) Done() <-chan struct{}

func (*F) Err

func (f *F) Err() error

func (*F) MustResult

func (f *F) MustResult() interface{}

func (*F) Result

func (f *F) Result() (interface{}, error)

TODO: Just return value.

func (*F) ScanResult

func (f *F) ScanResult(res interface{}) error

func (*F) SetName

func (f *F) SetName(s string)

func (*F) String

func (f *F) String() string