Searched defs:WALConfig (Results 1 – 6 of 6) sorted by relevance
26 type WALConfig struct { struct27 Enabled bool `yaml:"enabled"`28 Dir string `yaml:"dir"`29 CheckpointDuration time.Duration `yaml:"checkpoint_duration"`30 FlushOnShutdown bool `yaml:"flush_on_shutdown"`31 ReplayMemoryCeiling flagext.ByteSize `yaml:"replay_memory_ceiling"`34 func (cfg *WALConfig) Validate() error {42 func (cfg *WALConfig) RegisterFlags(f *flag.FlagSet) {79 func newWAL(cfg WALConfig, registerer prometheus.Registerer, metrics *ingesterMetrics, seriesIter S…
58 func newReplayController(metrics *ingesterMetrics, cfg WALConfig, flusher Flusher) *replayControlle…
34 type WALConfig struct { struct35 WALEnabled bool `yaml:"wal_enabled"`36 CheckpointEnabled bool `yaml:"checkpoint_enabled"`37 Recover bool `yaml:"recover_from_wal"`38 Dir string `yaml:"wal_dir"`39 CheckpointDuration time.Duration `yaml:"checkpoint_duration"`40 FlushOnShutdown bool `yaml:"flush_on_shutdown_with_wal_enabled"`42 checkpointDuringShutdown bool46 func (cfg *WALConfig) RegisterFlags(f *flag.FlagSet) {106 func newWAL(cfg WALConfig, userStatesFunc func() map[string]*userState, registerer prometheus.Regis…
61 …WALConfig WALConfig `yaml:"walconfig" doc:"description=Configures the Write-Ahe… member