singleflight

Documentation

Index

• type Group
  • func NewGroup(mapSize int) *Group
  • func (g *Group) Call(ctx context.Context, key string, ...) (interface{}, error)
  • func (g *Group) Delete(key string)
  • func (g *Group) DeleteAll()

Types

type Group

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

Group stores all calls in flight.

func NewGroup

func NewGroup(mapSize int) *Group

NewGroup returns a new Group holder with given mapSize.

func (*Group) Call

func (g *Group) Call(ctx context.Context, key string, fn func(ctx context.Context) (interface{}, error)) (interface{}, error)

Call will call fn in single-flight mode.

func (*Group) Delete

func (g *Group) Delete(key string)

Delete removes the flight of key so a new flight will start.

func (*Group) DeleteAll

func (g *Group) DeleteAll()

DeleteAll removes all flights.