shuffle

Documentation

Index

• Constants
• func Metrics() []xmetrics.Metric
• type Interface
  • func NewStreamShuffler(poolSize int, provider provider.Provider) Interface
• type Measures
  • func NewMeasures(p provider.Provider) *Measures

Constants

const (
	DeviceSetSize = "device_set_size"
)

Functions

func Metrics

func Metrics() []xmetrics.Metric

Types

type Interface

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

func NewStreamShuffler

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

type Measures

type Measures struct {
	DeviceSize metrics.Gauge
}

func NewMeasures

func NewMeasures(p provider.Provider) *Measures

NewMeasures constructs a Measures given a go-kit metrics Provider