distribution

Documentation

Index

• Constants
• type Algorithm
  • func (h *Algorithm) FromString(s string) error
  • func (h *Algorithm) MarshalJSON() ([]byte, error)
  • func (h *Algorithm) UnmarshalJSON(data []byte) error
  • func (h *Algorithm) UnmarshalYAML(unmarshal func(interface{}) error) error
• type AllDistribution
  • func NewAllDistribution(name string) *AllDistribution
  • func (d *AllDistribution) MetricToShard(metric *carbon.Metric) int
• type Distribute
• type FNV1aDistribution
  • func NewFNV1aDistribution(name string, shards int) *FNV1aDistribution
  • func (d *FNV1aDistribution) MetricToShard(metric *carbon.Metric) int
• type JumpFNV1aDistribution
  • func NewJumpFNV1aDistribution(name string, shards int) *JumpFNV1aDistribution
  • func (d *JumpFNV1aDistribution) MetricToShard(metric *carbon.Metric) int

Constants

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

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