kafka

Documentation

Index

• type JsonFLow
• type Kafka
  • func (b *Kafka) Add(values map[uint16]fields.Value)
  • func (b *Kafka) BenchmarkBackend(t testing.B)
  • func (b *Kafka) Configure(config map[string]string)
  • func (b *Kafka) Init()
  • func (b *Kafka) Prune(string)
  • func (b *Kafka) Status() string

Types

type JsonFLow

type JsonFLow struct {
	Src_ip     string
	Dst_ip     string
	Src_port   int
	Dst_port   int
	Protocol   int
	In_bytes   int
	In_packets int
	Src_ip6    string
	Dst_ip6    string
}

type Kafka

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

func (*Kafka) Add

func (b *Kafka) Add(values map[uint16]fields.Value)

func (*Kafka) BenchmarkBackend

func (b *Kafka) BenchmarkBackend(t testing.B)

func (*Kafka) Configure

func (b *Kafka) Configure(config map[string]string)

func (*Kafka) Init

func (b *Kafka) Init()

func (*Kafka) Prune

func (b *Kafka) Prune(string)

func (*Kafka) Status

func (b *Kafka) Status() string