file_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 {
	FilesDir string
	Count    int
	Lines    int
	RetTime  string
}

Config for file-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 Count files and writes Lines of lines to each

func (*Config) Validate

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

Validate waits for the message processing to complete