@terascope/job-components/dist/operations/job-observer.d.ts

import { ExecutionConfig, APIConfig, SliceAnalyticsData, WorkerContext } from '../interfaces';
import Observer from './observer';
/**
 * An Observer for monitoring the Slice Analyitcs
 */
export default class JobObserver extends Observer {
    collectAnalytics: boolean;
    analyticsData: SliceAnalyticsData | undefined;
    protected _currentSliceId: string;
    protected _currentIndex: number;
    private _opLength;
    private _initialized;
    constructor(context: WorkerContext, apiConfig: APIConfig, executionConfig: ExecutionConfig);
    onSliceInitialized(sliceId: string): Promise<void>;
    onOperationStart(sliceId: string, index: number): void;
    onOperationComplete(sliceId: string, index: number, processed: number): void;
    private defaultAnalytics;
}