traceability

type Backoff struct {
	Init time.Duration
	Max  time.Duration
}

type Client struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Config struct {
	Index             string            `config:"index"`
	LoadBalance       bool              `config:"loadbalance"`
	BulkMaxSize       int               `config:"bulk_max_size"`
	SlowStart         bool              `config:"slow_start"`
	Timeout           time.Duration     `config:"client_timeout"    validate:"min=0"`
	TTL               time.Duration     `config:"ttl"               validate:"min=0"`
	Pipelining        int               `config:"pipelining"        validate:"min=0"`
	CompressionLevel  int               `config:"compression_level" validate:"min=0, max=9"`
	MaxRetries        int               `config:"max_retries"       validate:"min=-1"`
	TLS               *tlscommon.Config `config:"ssl"`
	Proxy             ProxyConfig       `config:",inline"`
	Backoff           Backoff           `config:"backoff"`
	EscapeHTML        bool              `config:"escape_html"`
	Protocol          string            `config:"protocol"`
	Hosts             []string          `config:"hosts"`
	Redaction         redaction.Config  `config:"redaction" yaml:"redaction"`
	Sampling          sampling.Sampling `config:"sampling" yaml:"sampling"`
	APIExceptionsList []string          `config:"apiExceptionsList"`
}

type Connection struct {
	sync.Mutex
	URL string
	// contains filtered or unexported fields
}

type HTTPClient struct {
	Connection
	// contains filtered or unexported fields
}

type HTTPClientSettings struct {
	BeatInfo         beat.Info
	URL              string
	Proxy            *url.URL
	TLS              *transport.TLSConfig
	Index            outil.Selector
	Pipeline         *outil.Selector
	Timeout          time.Duration
	CompressionLevel int
	Observer         outputs.Observer
	Headers          map[string]string
	UserAgent        string
	IsSingleEntry    bool
}

type HostConfig struct {
	Protocol string   `config:"protocol"`
	Hosts    []string `config:"hosts"`
}

type OutputEventProcessor interface {
	Process(events []publisher.Event) []publisher.Event
}

type ProxyConfig struct {
	// URL of the SOCKS proxy. Scheme must be socks5. Username and password can be
	// embedded in the URL.
	URL string `config:"proxy_url"`

	// Resolve names locally instead of on the SOCKS server.
	LocalResolve bool `config:"proxy_use_local_resolver"`
}