distribution

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Dec 29, 2017 License: Apache-2.0 Imports: 6 Imported by: 4

Documentation

Index

Constants

View Source
const (
	Unknown   Algorithm = -1
	All                 = 0
	JumpFNV1a           = 1
	FNV1a               = 2
	CarbonCH            = 3 //NotImplementedYet
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Algorithm

type Algorithm int

func (*Algorithm) FromString

func (h *Algorithm) FromString(s string) error

func (*Algorithm) MarshalJSON

func (h *Algorithm) MarshalJSON() ([]byte, error)

func (*Algorithm) UnmarshalJSON

func (h *Algorithm) UnmarshalJSON(data []byte) error

func (*Algorithm) UnmarshalYAML

func (h *Algorithm) UnmarshalYAML(unmarshal func(interface{}) error) error

type AllDistribution

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

func NewAllDistribution

func NewAllDistribution(name string) *AllDistribution

func (*AllDistribution) MetricToShard

func (d *AllDistribution) MetricToShard(metric *carbon.Metric) int

type Distribute

type Distribute interface {
	MetricToShard(metric *carbon.Metric) int
}

type FNV1aDistribution

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

func NewFNV1aDistribution

func NewFNV1aDistribution(name string, shards int) *FNV1aDistribution

func (*FNV1aDistribution) MetricToShard

func (d *FNV1aDistribution) MetricToShard(metric *carbon.Metric) int

type JumpFNV1aDistribution

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

func NewJumpFNV1aDistribution

func NewJumpFNV1aDistribution(name string, shards int) *JumpFNV1aDistribution

func (*JumpFNV1aDistribution) MetricToShard

func (d *JumpFNV1aDistribution) MetricToShard(metric *carbon.Metric) int

Jump to

Keyboard shortcuts

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