shuffle

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 23, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DeviceSetSize = "device_set_size"
)

Variables

This section is empty.

Functions

func Metrics added in v0.3.0

func Metrics() []xmetrics.Metric

Types

type Interface added in v0.3.0

type Interface interface {
	Add(interface{})
	Get() interface{}
}

func NewStreamShuffler

func NewStreamShuffler(poolSize int, provider provider.Provider) Interface

type Measures added in v0.3.0

type Measures struct {
	DeviceSize metrics.Gauge
}

func NewMeasures added in v0.3.0

func NewMeasures(p provider.Provider) *Measures

NewMeasures constructs a Measures given a go-kit metrics Provider

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL