partitioner

Documentation

Index

• type Kafka
  • func NewKafka(partitionBy string) (*Kafka, error)
  • func (k *Kafka) Partition(m schema.PartitionedMetric, numPartitions int32) (int32, error)
• type Partitioner

Types

type Kafka

type Kafka struct {
	Method schema.PartitionByMethod
}

func NewKafka

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

func (*Kafka) Partition

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

type Partitioner

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