import * as m3o from '@m3o/m3o-node';
export declare class EventService {
    private client;
    constructor(token: string);
    consume(request: ConsumeRequest): Promise<m3o.Stream<ConsumeRequest, ConsumeResponse>>;
    publish(request: PublishRequest): Promise<PublishResponse>;
    read(request: ReadRequest): Promise<ReadResponse>;
}
export interface ConsumeRequest {
    group?: string;
    offset?: string;
    topic?: string;
}
export interface ConsumeResponse {
    id?: string;
    message?: {
        [key: string]: any;
    };
    timestamp?: string;
    topic?: string;
}
export interface Ev {
    id?: string;
    message?: {
        [key: string]: any;
    };
    timestamp?: string;
}
export interface PublishRequest {
    message?: {
        [key: string]: any;
    };
    topic?: string;
}
export interface PublishResponse {
}
export interface ReadRequest {
    limit?: number;
    offset?: number;
    topic?: string;
}
export interface ReadResponse {
    events?: Ev[];
}