import { NatsConnection, RequestOptions } from "@nats-io/nats-core";
import { AggregateId, Entity, ServiceDescription, Environment, State, Command, Service, ServiceInfo } from "@weegigs/events-core";
export type RequestOptionsModifier = (options: RequestOptions) => RequestOptions;
export declare class NatsClient<S extends State = State> implements Service<S> {
    private readonly connection;
    private readonly description;
    private readonly modifiers;
    static create<S extends State = State>(description: ServiceDescription<Environment, S>): {
        connect(natsUrl: string): Promise<NatsClient<S>>;
    };
    readonly info: ServiceInfo<S>;
    private readonly commands;
    constructor(connection: NatsConnection, description: ServiceDescription<Environment, S>, modifiers?: RequestOptionsModifier[]);
    execute(name: string, target: AggregateId, command: Command): Promise<Entity<S>>;
    withModifier(modifier: RequestOptionsModifier): NatsClient<S>;
    load(aggregate: AggregateId): Promise<Entity<S>>;
    withTimeout(ms: number): NatsClient<S>;
    withHeader(key: string, value: string): NatsClient<S>;
    close(): Promise<void>;
}
//# sourceMappingURL=client.d.ts.map