Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configuration ¶
type Configuration struct {
WorkerPoolSize int `yaml:"workerPoolSize"`
OpPool pool.ObjectPoolConfiguration `yaml:"opPool"`
Retry retry.Configuration `yaml:"retry"`
}
Configuration configs the ingester.
func (Configuration) NewIngester ¶
func (cfg Configuration) NewIngester( appender storage.Appender, instrumentOptions instrument.Options, ) (*Ingester, error)
NewIngester creates an ingester with an appender.
type Ingester ¶
type Ingester struct {
// contains filtered or unexported fields
}
Ingester ingests metrics with a worker pool.
type Options ¶
type Options struct {
Appender storage.Appender
Workers xsync.PooledWorkerPool
PoolOptions pool.ObjectPoolOptions
TagDecoderPool serialize.TagDecoderPool
RetryOptions retry.Options
InstrumentOptions instrument.Options
}
Options configures the ingester.
Click to show internal directories.
Click to hide internal directories.