file_elasticsearch

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 {
	Count    int
	Endpoint string
	Pipeline string
	Username string
	Password string
	// contains filtered or unexported fields
}

Config for file-elasticsearch 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 file and writes messages

func (*Config) Validate

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

Validate waits for the message processing to complete