config

Documentation

Index

• type Config
  • func (c *Config) ApplyDefaults()
• type Elasticsearch

Types

type Config

type Config struct {
	Elasticsearch Elasticsearch `yaml:"elasticsearch"`
	Dcp           config.Dcp    `yaml:",inline"`
}

func (*Config) ApplyDefaults

func (c *Config) ApplyDefaults()

type Elasticsearch

type Elasticsearch struct {
	CollectionIndexMapping map[string]string `yaml:"collectionIndexMapping"`
	MaxConnsPerHost        *int              `yaml:"maxConnsPerHost"`
	MaxIdleConnDuration    *time.Duration    `yaml:"maxIdleConnDuration"`
	TypeName               string            `yaml:"typeName"`
	Urls                   []string          `yaml:"urls"`
	BatchSizeLimit         int               `yaml:"batchSizeLimit"`
	BatchByteSizeLimit     int               `yaml:"batchByteSizeLimit"`
	BatchTickerDuration    time.Duration     `yaml:"batchTickerDuration"`
	ConcurrentRequest      int               `yaml:"concurrentRequest"`
	CompressionEnabled     bool              `yaml:"compressionEnabled"`
}