Version: v1.11.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Mar 7, 2019 License: Apache-2.0 Imports: 16 Imported by: 0




This section is empty.


This section is empty.


This section is empty.


type ClientBuilder added in v0.6.0

type ClientBuilder interface {
	NewClient(logger *zap.Logger, metricsFactory metrics.Factory) (es.Client, error)
	GetNumShards() int64
	GetNumReplicas() int64
	GetMaxSpanAge() time.Duration
	GetMaxNumSpans() int
	GetIndexPrefix() string
	GetTagsFilePath() string
	GetAllTagsAsFields() bool
	GetTagDotReplacement() string
	GetUseReadWriteAliases() bool
	GetTokenFilePath() string
	IsEnabled() bool

ClientBuilder creates new es.Client

type Configuration

type Configuration struct {
	Servers             []string
	Username            string
	Password            string
	TokenFilePath       string
	Sniffer             bool          //
	MaxNumSpans         int           // defines maximum number of spans to fetch from storage per query
	MaxSpanAge          time.Duration `yaml:"max_span_age"` // configures the maximum lookback on span reads
	NumShards           int64         `yaml:"shards"`
	NumReplicas         int64         `yaml:"replicas"`
	Timeout             time.Duration `validate:"min=500"`
	BulkSize            int
	BulkWorkers         int
	BulkActions         int
	BulkFlushInterval   time.Duration
	IndexPrefix         string
	TagsFilePath        string
	AllTagsAsFields     bool
	TagDotReplacement   string
	Enabled             bool
	TLS                 TLSConfig
	UseReadWriteAliases bool

Configuration describes the configuration properties needed to connect to an ElasticSearch cluster

func (*Configuration) ApplyDefaults added in v0.6.0

func (c *Configuration) ApplyDefaults(source *Configuration)

ApplyDefaults copies settings from source unless its own value is non-zero.

func (*Configuration) GetAllTagsAsFields added in v1.7.0

func (c *Configuration) GetAllTagsAsFields() bool

GetAllTagsAsFields returns true if all tags should be stored as object fields

func (*Configuration) GetIndexPrefix added in v1.7.0

func (c *Configuration) GetIndexPrefix() string

GetIndexPrefix returns index prefix

func (*Configuration) GetMaxNumSpans added in v1.9.0

func (c *Configuration) GetMaxNumSpans() int

GetMaxNumSpans returns max spans allowed per query from Configuration

func (*Configuration) GetMaxSpanAge added in v0.6.0

func (c *Configuration) GetMaxSpanAge() time.Duration

GetMaxSpanAge returns max span age from Configuration

func (*Configuration) GetNumReplicas added in v0.6.0

func (c *Configuration) GetNumReplicas() int64

GetNumReplicas returns number of replicas from Configuration

func (*Configuration) GetNumShards added in v0.6.0

func (c *Configuration) GetNumShards() int64

GetNumShards returns number of shards from Configuration

func (*Configuration) GetTagDotReplacement added in v1.7.0

func (c *Configuration) GetTagDotReplacement() string

GetTagDotReplacement returns character is used to replace dots in tag keys, when the tag is stored as object field.

func (*Configuration) GetTagsFilePath added in v1.7.0

func (c *Configuration) GetTagsFilePath() string

GetTagsFilePath returns a path to file containing tag keys

func (*Configuration) GetTokenFilePath added in v1.10.0

func (c *Configuration) GetTokenFilePath() string

GetTokenFilePath returns file path containing the bearer token

func (*Configuration) GetUseReadWriteAliases added in v1.10.0

func (c *Configuration) GetUseReadWriteAliases() bool

GetUseReadWriteAliases indicates whether read alias should be used

func (*Configuration) IsEnabled added in v1.10.0

func (c *Configuration) IsEnabled() bool

IsEnabled determines whether storage is enabled

func (*Configuration) NewClient

func (c *Configuration) NewClient(logger *zap.Logger, metricsFactory metrics.Factory) (es.Client, error)

NewClient creates a new ElasticSearch client

type TLSConfig added in v1.8.0

type TLSConfig struct {
	Enabled  bool
	CertPath string
	KeyPath  string
	CaPath   string

TLSConfig describes the configuration properties to connect tls enabled ElasticSearch cluster

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL