http

Jun 22, 2026

Changes in this version

type Config

+ BanPeriod cfg.Duration

+ BanPeriod_ time.Duration

+ ReconnectInterval cfg.Duration

+ ReconnectInterval_ time.Duration

May 18, 2026

Changes in this version

+ const EncoderTypeJSON

+ const EncoderTypeRaw

type Config

+ Encoding EncodingConfig

+ type Encoder interface

+ Encode func(event *pipeline.Event, buf []byte) []byte

+ func NewEncoder(cfg EncodingConfig) (Encoder, error)

+ type EncodingConfig struct

+ Params json.RawMessage

+ Type string

+ type JSONEncoder struct

+ func (e *JSONEncoder) Encode(event *pipeline.Event, buf []byte) []byte

+ type JSONEncoderParams struct

+ type RawEncoder struct

+ func (e *RawEncoder) Encode(event *pipeline.Event, buf []byte) []byte

+ type RawEncoderParams struct

+ Field string

Jan 26, 2026

Changes in this version

+ func Factory() (pipeline.AnyPlugin, pipeline.AnyConfig)

+ type Config struct

+ APIKey string

+ BatchFlushTimeout cfg.Duration

+ BatchFlushTimeout_ time.Duration

+ BatchSize cfg.Expression

+ BatchSizeBytes cfg.Expression

+ BatchSizeBytes_ int

+ BatchSize_ int

+ CACert string

+ ConnectionTimeout cfg.Duration

+ ConnectionTimeout_ time.Duration

+ ContentType string

+ Endpoints []string

+ FatalOnFailedInsert bool

+ GzipCompressionLevel string

+ KeepAlive KeepAliveConfig

+ Password string

+ Retention cfg.Duration

+ RetentionExponentMultiplier int

+ Retention_ time.Duration

+ Retry int

+ SplitBatch bool

+ Strict bool

+ UseGzip bool

+ Username string

+ WorkersCount cfg.Expression

+ WorkersCount_ int

+ type KeepAliveConfig struct

+ MaxConnDuration cfg.Duration

+ MaxConnDuration_ time.Duration

+ MaxIdleConnDuration cfg.Duration

+ MaxIdleConnDuration_ time.Duration

+ type Plugin struct

+ func (p *Plugin) Out(event *pipeline.Event)

+ func (p *Plugin) Start(config pipeline.AnyConfig, params *pipeline.OutputPluginParams)

+ func (p *Plugin) Stop()