singleflight

Documentation

Index

• type SingleFlight
  • func (g *SingleFlight) Do(key interface{}, fn func() (interface{}, error)) (interface{}, error)

Types

type SingleFlight

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

func (*SingleFlight) Do

func (g *SingleFlight) Do(key interface{}, fn func() (interface{}, error)) (interface{}, error)

do executes and returns the results of the given function, making sure that only one execution is in-flight for a given key at a time. If a duplicate comes in, the duplicate caller waits for the original to complete and receives the same results.