import type IDriver from '../driver/i-driver';
import type * as IRPC from '../base/iapi';
import type { CallOptions } from '../base/options';
export * from '../base/iapi';
export interface IResponseStream<T> {
    on: ((event: 'data', fn: (item: T) => void) => this) & ((event: 'end', fn: () => void) => this) & ((event: 'status', fn: (status: any) => void) => this) & ((event: 'error', fn: (err: Error) => void) => this);
}
export declare class KVClient implements IRPC.IKVClient {
    private readonly client;
    constructor(client: IDriver);
    range(req: IRPC.IRangeRequest, options?: CallOptions): Promise<IRPC.IRangeResponse>;
    put(req: IRPC.IPutRequest, options?: CallOptions): Promise<IRPC.IPutResponse>;
    deleteRange(req: IRPC.IDeleteRangeRequest, options?: CallOptions): Promise<IRPC.IDeleteRangeResponse>;
    txn(req: IRPC.ITxnRequest, options?: CallOptions): Promise<IRPC.ITxnResponse>;
}
export declare class WatchClient implements IRPC.IWatchClient {
    private readonly client;
    constructor(client: IDriver);
    watch(options?: CallOptions): Promise<IRPC.IDuplexStream<IRPC.IWatchRequest, IRPC.IWatchResponse>>;
}
export declare class LeaseClient implements IRPC.ILeaseClient {
    private readonly client;
    constructor(client: IDriver);
    leaseGrant(req: IRPC.ILeaseGrantRequest, options?: CallOptions): Promise<IRPC.ILeaseGrantResponse>;
    leaseRevoke(req: IRPC.ILeaseRevokeRequest, options?: CallOptions): Promise<IRPC.ILeaseRevokeResponse>;
    leaseKeepAlive(options?: CallOptions): Promise<IRPC.IDuplexStream<IRPC.ILeaseKeepAliveRequest, IRPC.ILeaseKeepAliveResponse>>;
    leaseTimeToLive(req: IRPC.ILeaseTimeToLiveRequest, options?: CallOptions): Promise<IRPC.ILeaseTimeToLiveResponse>;
    leaseLeases(options?: CallOptions): Promise<IRPC.ILeaseLeasesResponse>;
}
export declare const Services: {
    KV: typeof KVClient;
    Watch: typeof WatchClient;
    Lease: typeof LeaseClient;
};