runtime

type MockOptionsWatcher struct {
	// contains filtered or unexported fields
}

type MockOptionsWatcherMockRecorder struct {
	// contains filtered or unexported fields
}

type Options interface {
	// SetWriteValuesPerMetricLimitPerSecond sets the rate limit used
	// to cap the maximum number of values allowed to be written per second.
	SetWriteValuesPerMetricLimitPerSecond(value int64) Options

	// WriteValuesPerMetricLimitPerSecond returns the rate limit used
	// to cap the maximum number of values allowed to be written per second.
	WriteValuesPerMetricLimitPerSecond() int64

	// SetWriteNewMetricLimitPerShardPerSecond sets the rate limit used
	// to cap the maximum number of new metrics allowed to be written per shard per second.
	SetWriteNewMetricLimitPerShardPerSecond(value int64) Options

	// WriteNewMetricLimitPerShardPerSecond returns the rate limit used
	// to cap the maximum number of new metrics allowed to be written per shard per second.
	WriteNewMetricLimitPerShardPerSecond() int64

	// SetWriteNewMetricNoLimitWarmupDuration sets the warmup duration during which
	// rate limiting is not applied for writing new metric series for the purpose
	// of not aggresively limiting new series insertion rate when an instance just
	// comes online and is ingesting a large number of new series during startup.
	// The warmup duration is in effect starting from the time when the first entry
	// is insert into the shard.
	SetWriteNewMetricNoLimitWarmupDuration(value time.Duration) Options

	// WriteNewMetricNoLimitWarmupDuration returns the warmup duration during which
	// rate limiting is not applied for writing new metric series for the purpose
	// of not aggresively limiting new series insertion rate when an instance just
	// comes online and is ingesting a large number of new series during startup.
	// The warmup duration is in effect starting from the time when the first entry
	// is insert into the shard.
	WriteNewMetricNoLimitWarmupDuration() time.Duration
}

type OptionsManager interface {
	// SetRuntimeOptions sets the runtime options.
	SetRuntimeOptions(value Options)

	// RuntimeOptions returns the current runtime options.
	RuntimeOptions() Options

	// RegisterWatcher registers a watcher that watches updates to runtime options.
	// When an update arrives, the manager will deliver the update to all registered
	// watchers.
	RegisterWatcher(l OptionsWatcher) close.SimpleCloser

	// Close closes the watcher and all descendent watches
	Close()
}

type OptionsWatcher interface {
	// SetRuntimeOptions is called for registerer watchers when the runtime options
	// are updated, passing in the updated options as the argument.
	SetRuntimeOptions(value Options)
}