metrictank: github.com/grafana/metrictank/cluster/partitioner Index | Files

package partitioner

import "github.com/grafana/metrictank/cluster/partitioner"

Index

Package Files

partitioner.go

type Kafka Uses

type Kafka struct {
    Method schema.PartitionByMethod
}

func NewKafka Uses

func NewKafka(partitionBy string) (*Kafka, error)

func (*Kafka) Partition Uses

func (k *Kafka) Partition(m schema.PartitionedMetric, numPartitions int32) (int32, error)

type Partitioner Uses

type Partitioner interface {
    Partition(schema.PartitionedMetric, int32) (int32, error)
}

Package partitioner imports 1 packages (graph) and is imported by 10 packages. Updated 2019-10-08. Refresh now. Tools for package owners.