Documentation ¶
Index ¶
- type ClientBuilder
- type Configuration
- func (c *Configuration) ApplyDefaults(source *Configuration)
- func (c *Configuration) GetAllTagsAsFields() bool
- func (c *Configuration) GetIndexPrefix() string
- func (c *Configuration) GetMaxNumSpans() int
- func (c *Configuration) GetMaxSpanAge() time.Duration
- func (c *Configuration) GetNumReplicas() int64
- func (c *Configuration) GetNumShards() int64
- func (c *Configuration) GetTagDotReplacement() string
- func (c *Configuration) GetTagsFilePath() string
- func (c *Configuration) GetTokenFilePath() string
- func (c *Configuration) GetUseReadWriteAliases() bool
- func (c *Configuration) IsEnabled() bool
- func (c *Configuration) NewClient(logger *zap.Logger, metricsFactory metrics.Factory) (es.Client, error)
- type TLSConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientBuilder ¶
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 AllowTokenFromContext bool Sniffer bool // https://github.com/olivere/elastic/wiki/Sniffing 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 ¶
func (c *Configuration) ApplyDefaults(source *Configuration)
ApplyDefaults copies settings from source unless its own value is non-zero.
func (*Configuration) GetAllTagsAsFields ¶
func (c *Configuration) GetAllTagsAsFields() bool
GetAllTagsAsFields returns true if all tags should be stored as object fields
func (*Configuration) GetIndexPrefix ¶
func (c *Configuration) GetIndexPrefix() string
GetIndexPrefix returns index prefix
func (*Configuration) GetMaxNumSpans ¶
func (c *Configuration) GetMaxNumSpans() int
GetMaxNumSpans returns max spans allowed per query from Configuration
func (*Configuration) GetMaxSpanAge ¶
func (c *Configuration) GetMaxSpanAge() time.Duration
GetMaxSpanAge returns max span age from Configuration
func (*Configuration) GetNumReplicas ¶
func (c *Configuration) GetNumReplicas() int64
GetNumReplicas returns number of replicas from Configuration
func (*Configuration) GetNumShards ¶
func (c *Configuration) GetNumShards() int64
GetNumShards returns number of shards from Configuration
func (*Configuration) GetTagDotReplacement ¶
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 ¶
func (c *Configuration) GetTagsFilePath() string
GetTagsFilePath returns a path to file containing tag keys
func (*Configuration) GetTokenFilePath ¶
func (c *Configuration) GetTokenFilePath() string
GetTokenFilePath returns file path containing the bearer token
func (*Configuration) GetUseReadWriteAliases ¶
func (c *Configuration) GetUseReadWriteAliases() bool
GetUseReadWriteAliases indicates whether read alias should be used
func (*Configuration) IsEnabled ¶
func (c *Configuration) IsEnabled() bool
IsEnabled determines whether storage is enabled