elasticsearch

Documentation

Index

• Variables
• func NewElasticsearch(conf output.Config, mgr bundle.NewManagement) (output.Streamed, error)
• type Elasticsearch
  • 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

Variables

var AWSOptFn = notImportedAWSOptFn

AWSOptFn is populated with the child `aws` package when imported.

Functions

func NewElasticsearch

func NewElasticsearch(conf output.Config, mgr bundle.NewManagement) (output.Streamed, error)

NewElasticsearch creates a new Elasticsearch output type.

Types

type Elasticsearch

type Elasticsearch struct {
	// contains filtered or unexported fields
}

Elasticsearch is a writer type that writes messages into elasticsearch.

func NewElasticsearchV2

func NewElasticsearchV2(conf output.ElasticsearchConfig, mgr bundle.NewManagement) (*Elasticsearch, error)

NewElasticsearchV2 creates a new Elasticsearch writer type.

func (*Elasticsearch) Close

func (e *Elasticsearch) Close(context.Context) error

Close shuts down the Elasticsearch writer and stops processing messages.

func (*Elasticsearch) Connect

func (e *Elasticsearch) Connect(ctx context.Context) error

Connect attempts to establish a connection to a Elasticsearch broker.

func (*Elasticsearch) Write

func (e *Elasticsearch) Write(msg message.Batch) error

Write will attempt to write a message to Elasticsearch, wait for acknowledgement, and returns an error if applicable.

func (*Elasticsearch) WriteBatch

func (e *Elasticsearch) WriteBatch(ctx context.Context, msg message.Batch) error

WriteBatch will attempt to write a message to Elasticsearch, wait for acknowledgement, and returns an error if applicable.