import { type Callback } from '../apis/definitions.ts';
import { type BeforeDeserializationHook, type BeforeHookPayloadType, type BeforeSerializationHook, type Deserializers, type Serializers } from '../clients/serde.ts';
import { type MessageToProduce } from '../protocol/records.ts';
export interface SchemaRegistry<Id = unknown, Schema = unknown, Key = Buffer, Value = Buffer, HeaderKey = Buffer, HeaderValue = Buffer> {
    get(id: Id): Schema | undefined;
    fetch(id: Id, callback?: (error?: Error) => void): void | Promise<void>;
    getSchemaId(payload: Buffer | MessageToProduce<Key, Value, HeaderKey, HeaderValue>, type?: BeforeHookPayloadType): Id;
    getSerializers(): Serializers<Key, Value, HeaderKey, HeaderValue>;
    getDeserializers(): Deserializers<Key, Value, HeaderKey, HeaderValue>;
    getBeforeSerializationHook(): BeforeSerializationHook<Key, Value, HeaderKey, HeaderValue>;
    getBeforeDeserializationHook(): BeforeDeserializationHook;
}
export declare function runAsyncSeries<V>(operation: (item: V, cb: Callback<void>) => void | Promise<void>, collection: V[], index: number, callback: Callback<void>): void;
export declare class AbstractSchemaRegistry<Id = unknown, Schema = unknown, Key = Buffer, Value = Buffer, HeaderKey = Buffer, HeaderValue = Buffer> implements SchemaRegistry<Id, Schema, Key, Value, HeaderKey, HeaderValue> {
    get(_: Id): Schema | undefined;
    fetch(_i: unknown, _c?: (error?: Error) => void): void | Promise<void>;
    getSchemaId(_p: Buffer | MessageToProduce<Key, Value, HeaderKey, HeaderValue>, _t?: BeforeHookPayloadType): Id;
    getSerializers(): Serializers<Key, Value, HeaderKey, HeaderValue>;
    getDeserializers(): Deserializers<Key, Value, HeaderKey, HeaderValue>;
    getBeforeSerializationHook(): BeforeSerializationHook<Key, Value, HeaderKey, HeaderValue>;
    getBeforeDeserializationHook(): BeforeDeserializationHook;
}