traceability

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

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

type Config struct {
	LoadBalance       bool
	BulkMaxSize       int
	SlowStart         bool
	Timeout           time.Duration
	TTL               time.Duration
	Pipelining        int
	CompressionLevel  int
	MaxRetries        int
	TLS               TLSConfig
	Proxy             ProxyConfig
	Backoff           Backoff
	EscapeHTML        bool
	Protocol          string
	Hosts             []string
	Redaction         redaction.Config
	Sampling          sampling.Sampling
	APIExceptionsList []string
}

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

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

type HTTPClientSettings struct {
	URL              string
	Proxy            *url.URL
	TLS              config.TLSConfig
	Timeout          time.Duration
	CompressionLevel int
	Headers          map[string]string
	UserAgent        string
	IsSingleEntry    bool
}

type NetworkClient interface {
	Connect() error
	Close() error
	Publish(ctx context.Context, batch event.Batch) error
	String() string
}

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

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

	// Resolve names locally instead of on the SOCKS server.
	LocalResolve bool
}

type TLSConfig struct {
	// Enabled is accepted but not acted on: protocol already determines whether TLS
	// applies.
	Enabled          *bool    `config:"enabled"`
	VerificationMode string   `config:"verification_mode"`
	CipherSuites     []string `config:"cipher_suites"`

	SupportedProtocols     []string `config:"supported_protocols"`
	CertificateAuthorities []string `config:"certificate_authorities"`
	CurveTypes             []string `config:"curve_types"`
	Renegotiation          string   `config:"renegotiation"`
	CASha256               []string `config:"ca_sha256"`
	KeyPassphrase          string   `config:"key_passphrase"`
}