elasticsearch

Documentation

Index

• func NewElasticsearch(conf output.Config, mgr bundle.NewManagement, log log.Modular, ...) (output.Streamed, error)
• type Elasticsearch
  • func NewElasticsearchV2(conf output.ElasticsearchConfig, mgr bundle.NewManagement, log log.Modular, ...) (*Elasticsearch, error)
  • func (e *Elasticsearch) CloseAsync()
  • func (e *Elasticsearch) Connect() error
  • func (e *Elasticsearch) ConnectWithContext(ctx context.Context) error
  • func (e *Elasticsearch) WaitForClose(timeout time.Duration) error
  • func (e *Elasticsearch) Write(msg *message.Batch) error
  • func (e *Elasticsearch) WriteWithContext(ctx context.Context, msg *message.Batch) error

Functions

func NewElasticsearch

func NewElasticsearch(conf output.Config, mgr bundle.NewManagement, log log.Modular, stats metrics.Type) (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, log log.Modular, stats metrics.Type) (*Elasticsearch, error)

NewElasticsearchV2 creates a new Elasticsearch writer type.

func (*Elasticsearch) CloseAsync

func (e *Elasticsearch) CloseAsync()

CloseAsync shuts down the Elasticsearch writer and stops processing messages.

func (*Elasticsearch) Connect

func (e *Elasticsearch) Connect() error

Connect attempts to establish a connection to a Elasticsearch broker.

func (*Elasticsearch) ConnectWithContext

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

ConnectWithContext attempts to establish a connection to a Elasticsearch broker.

func (*Elasticsearch) WaitForClose

func (e *Elasticsearch) WaitForClose(timeout time.Duration) error

WaitForClose blocks until the Elasticsearch writer has closed down.

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) WriteWithContext

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

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