elasticsearch

Documentation

Index

• Constants
• type Config
• type DevNull
  • func (DevNull) Write(p []byte) (int, error)
• type ESServer
  • func (e *ESServer) Init(config yaml.MapSlice, b buffer.Sender) error
  • func (es *ESServer) Start() error
  • func (es *ESServer) Stop() error
  • func (e *ESServer) ValidateConfig(config *Config) error
• type Indexer

Constants

const IndexTemplate string = `` /* 2958-byte string literal not displayed */

Types

type Config

type Config struct {
	Hosts           []string `yaml:"hosts"`
	IndexPrefix     string   `yaml:"index"`
	IndexType       string   `yaml:"index_type"`
	Timeout         int      `yaml:"timeout"`
	GzipEnabled     bool     `yaml:"gzip_enabled"`
	InfoLogEnabled  bool     `yaml:"info_log_enabled"`
	ErrorLogEnabled bool     `yaml:"error_log_enabled"`
}

type DevNull

type DevNull struct{}

Dummy discard, satisfies io.Writer without importing io or os.

func (DevNull) Write

func (DevNull) Write(p []byte) (int, error)

type ESServer

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

func (*ESServer) Init

func (e *ESServer) Init(config yaml.MapSlice, b buffer.Sender) error

func (*ESServer) Start

func (es *ESServer) Start() error

func (*ESServer) Stop

func (es *ESServer) Stop() error

func (*ESServer) ValidateConfig

func (e *ESServer) ValidateConfig(config *Config) error

type Indexer

type Indexer struct {
	RateCounter *ratecounter.RateCounter
	// contains filtered or unexported fields
}