Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + var AWSOptFn = notImportedAWSOptFn + func NewElasticsearch(conf output.Config, mgr bundle.NewManagement) (output.Streamed, error) + type Elasticsearch struct + func NewElasticsearchV2(conf output.ElasticsearchConfig, mgr bundle.NewManagement) (*Elasticsearch, error) + func (e *Elasticsearch) Close(context.Context) error + func (e *Elasticsearch) Connect(ctx context.Context) error + func (e *Elasticsearch) Write(msg message.Batch) error + func (e *Elasticsearch) WriteBatch(ctx context.Context, msg message.Batch) error
Go to main page