kafka_file

Documentation

Index

• type Config
  • func (c *Config) Configure(t *testing.T, conf *cfg.Config, pipelineName string)
  • func (c *Config) Send(t *testing.T)
  • func (c *Config) Validate(t *testing.T)

Types

type Config

type Config struct {
	Topics    []string
	Brokers   []string
	FilesDir  string
	Count     int
	RetTime   string
	Partition int
}

Config for kafka-file plugin e2e test

func (*Config) Configure

func (c *Config) Configure(t *testing.T, conf *cfg.Config, pipelineName string)

Configure sets additional fields for input and output plugins

func (*Config) Send

func (c *Config) Send(t *testing.T)

Send creates a Partition of messages (one for each partition) and sends them Count times to kafka

func (*Config) Validate

func (c *Config) Validate(t *testing.T)

Validate waits for the message processing to complete