elasticsearch

Documentation

Index

• type BulkIndexer
• type HttpBulkIndexer
  • func NewHttpBulkIndexer(protocol string, domain string, maxCount int, username string, password string, ...) *HttpBulkIndexer
  • func (h *HttpBulkIndexer) CheckFlush(count int, length int) bool
  • func (h *HttpBulkIndexer) Index(body []byte) error
• type MongodbOutput
  • func (self *MongodbOutput) Init(conf toml.Primitive) error
  • func (self *MongodbOutput) Run(runner plugins.OutputRunner) error
• type MongodbOutputConfig

Types

type BulkIndexer

type BulkIndexer interface {
	// Index documents
	Index(body []byte) error
	// Check if a flush is needed
	CheckFlush(count int, length int) bool
}

A BulkIndexer is used to index documents in ElasticSearch

type HttpBulkIndexer

type HttpBulkIndexer struct {
	// Protocol (http or https).
	Protocol string
	// Host name and port number (default to "localhost:9200").
	Domain string
	// Maximum number of documents.
	MaxCount int
	// contains filtered or unexported fields
}

A HttpBulkIndexer uses the HTTP REST Bulk Api of ElasticSearch in order to index documents

func NewHttpBulkIndexer

func NewHttpBulkIndexer(protocol string, domain string, maxCount int,
	username string, password string, httpTimeout uint32, httpDisableKeepalives bool,
	connectTimeout uint32, tlsConf *tls.Config) *HttpBulkIndexer

func (*HttpBulkIndexer) CheckFlush

func (h *HttpBulkIndexer) CheckFlush(count int, length int) bool

func (*HttpBulkIndexer) Index

func (h *HttpBulkIndexer) Index(body []byte) error

type MongodbOutput

type MongodbOutput struct {
	FailedCount int64
	// contains filtered or unexported fields
}

func (*MongodbOutput) Init

func (self *MongodbOutput) Init(conf toml.Primitive) error

func (*MongodbOutput) Run

func (self *MongodbOutput) Run(runner plugins.OutputRunner) error

type MongodbOutputConfig

type MongodbOutputConfig struct {
	Host, Port, Database, Collection string
	User, Password                   string
	Capped                           bool
	CappedSize                       int `toml:"capped_size"`
}