gate

Documentation

Index

• type Gate
  • func NewGate(maxConcurrent int, reg prometheus.Registerer) *Gate
  • func (g *Gate) Done()
  • func (g *Gate) IsMyTurn(ctx context.Context) error
• type Gater

Types

type Gate

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

Gate wraps the Prometheus gate with extra metrics.

func NewGate

func NewGate(maxConcurrent int, reg prometheus.Registerer) *Gate

NewGate returns a new query gate.

func (*Gate) Done

func (g *Gate) Done()

Done finishes a query.

func (*Gate) IsMyTurn

func (g *Gate) IsMyTurn(ctx context.Context) error

IsMyTurn iniates a new query and waits until it's our turn to fulfill a query request.

type Gater

type Gater interface {
	IsMyTurn(ctx context.Context) error
	Done()
}