import { Observable } from 'rxjs';
import { MetricsSource } from '../../../../metrics';
import { OrchestratorGateway } from '../../../../orchestrator';
import { Sample } from '../../../../raw-metrics-query';
import { ComposedMetricSource } from '../composed-metric-source';
/**
 * `ComposedMetricSourceBase` may be used as a superclass for {@link ComposedMetricSource} implementations.
 *
 * It implements common operations in a reusable manner.
 */
export declare abstract class ComposedMetricSourceBase<V> implements ComposedMetricSource<V> {
    protected metricsSource: MetricsSource;
    protected orchestrator: OrchestratorGateway;
    constructor(metricsSource: MetricsSource, orchestrator: OrchestratorGateway);
    abstract getValueStream(): Observable<Sample<V>>;
    getCurrentValue(): Observable<Sample<V>>;
    /**
     * Helper method to create an observable that emits immediately and then at the default polling interval.
     *
     * The emitted value counts the number of emissions, starting with `0`, like `interval()`.
     *
     * This should be used for realizing `getValueStream()` on raw metrics sources that require polling.
     */
    protected getDefaultPollingInterval(): Observable<number>;
}