Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
WALDir string `yaml:"wal_dir"`
ConcurrentFlushes int `yaml:"concurrent_flushes"`
FlushOpTimeout time.Duration `yaml:"flush_op_timeout"`
ExitAfterFlush bool `yaml:"exit_after_flush"`
}
Config for an Ingester.
func (*Config) RegisterFlags ¶
RegisterFlags adds the flags required to config this to the given FlagSet
type Flusher ¶
Flusher is designed to be used as a job to flush the data from the WAL on disk. Flusher works with both chunks-based and blocks-based ingesters.
func New ¶
func New( cfg Config, ingesterConfig ingester.Config, chunkStore ingester.ChunkStore, limits *validation.Overrides, registerer prometheus.Registerer, logger log.Logger, ) (*Flusher, error)
New constructs a new Flusher and flushes the data from the WAL. The returned Flusher has no other operations.
Source Files
Click to show internal directories.
Click to hide internal directories.