gate

package

v0.15.0 Latest Latest Go to latest Published: Sep 7, 2020 License: Apache-2.0 Imports: 5 Imported by: 7

Details

This section is empty.

This section is empty.

This section is empty.

type Gate interface {
	Start(ctx context.Context) error
	Done()
}

Gate is an interface that mimics prometheus/pkg/gate behavior.

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

Keeper is used to create multiple gates sharing the same metrics.

func NewKeeper(reg prometheus.Registerer) *Keeper

NewKeeper creates a new Keeper.

func (k *Keeper) NewGate(maxConcurrent int) Gate

NewGate returns a new Gate that collects metrics.