/opt/canhelp/node_modules/svix/dist/api
Edit: /opt/canhelp/node_modules/svix/dist/api/messagePoller.d.ts (1255B)
import { type PollingEndpointConsumerSeekIn } from "../models/pollingEndpointConsumerSeekIn";
import { type PollingEndpointConsumerSeekOut } from "../models/pollingEndpointConsumerSeekOut";
import { type PollingEndpointOut } from "../models/pollingEndpointOut";
import { type SvixRequestContext } from "../request";
export interface MessagePollerPollOptions {
limit?: number;
iterator?: string | null;
eventType?: string;
channel?: string;
after?: Date | null;
}
export interface MessagePollerConsumerPollOptions {
limit?: number;
iterator?: string | null;
}
export interface MessagePollerConsumerSeekOptions {
idempotencyKey?: string;
}
export declare class MessagePoller {
private readonly requestCtx;
constructor(requestCtx: SvixRequestContext);
poll(appId: string, sinkId: string, options?: MessagePollerPollOptions): Promise
;
consumerPoll(appId: string, sinkId: string, consumerId: string, options?: MessagePollerConsumerPollOptions): Promise;
consumerSeek(appId: string, sinkId: string, consumerId: string, pollingEndpointConsumerSeekIn: PollingEndpointConsumerSeekIn, options?: MessagePollerConsumerSeekOptions): Promise;
}