elasticsink

Documentation

Index

• func MustNew(client *elastic.Client, options ...Option) pipeline.Sink
• type DeleteMessage
• type IndexMessage
• type Option
  • func WithIgnoreIndexNotFoundOnDelete() Option
• type SinkMessage

Functions

func MustNew

func MustNew(
	client *elastic.Client,
	options ...Option,
) pipeline.Sink

MustNew creates a new sink that saves documents to elastic

Types

type DeleteMessage

type DeleteMessage struct {
	ID    string
	Index string
}

DeleteMessage deletes the document from the elasticsearch

type IndexMessage

type IndexMessage struct {
	ID       string
	Index    string
	Document interface{}
}

IndexMessage saves the document into elasticsearch

type Option

type Option func(*elasticSink)

func WithIgnoreIndexNotFoundOnDelete

func WithIgnoreIndexNotFoundOnDelete() Option

type SinkMessage

type SinkMessage = IndexMessage

SinkMessage is the input for the Elastic Sink Deprecated: this is an alias to IndexMessage, use that instead.