kafka

Documentation

Index

• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
  • func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
• type Tee
  • func NewTee(cfg Config, metricsNamespace string, registerer prometheus.Registerer, ...) (*Tee, error)
  • func (t *Tee) Duplicate(tenant string, streams []distributor.KeyedStream)

Types

type Config

type Config struct {
	Address string `yaml:"address" docs:"the kafka endpoint to connect to"`
	Topic   string `yaml:"topic" docs:"the kafka topic to write to"`
}

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

func (*Config) RegisterFlagsWithPrefix

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

type Tee

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

func NewTee

func NewTee(
	cfg Config,
	metricsNamespace string,
	registerer prometheus.Registerer,
	logger log.Logger,
	partitionRing *ring.PartitionInstanceRing,
) (*Tee, error)

func (*Tee) Duplicate

func (t *Tee) Duplicate(tenant string, streams []distributor.KeyedStream)

Duplicate Implements distributor.Tee which is used to tee distributor requests to pattern ingesters.