UNPKG

632 BTypeScriptView Raw
1import { pubsub_v1 } from "googleapis";
2import { Message, PollResult } from "../provider";
3import { Attributes } from "../types";
4import { GoogleMetrics } from "./google-faast";
5import PubSubApi = pubsub_v1;
6export declare function receiveMessages(pubsub: PubSubApi.Pubsub, subscription: string, metrics: GoogleMetrics, cancel: Promise<void>): Promise<PollResult>;
7export declare function publishPubSub(pubsub: PubSubApi.Pubsub, topic: string, message: string, attributes?: Attributes): Promise<void>;
8export declare function publishResponseMessage(pubsub: PubSubApi.Pubsub, ResponseQueue: string, message: Message): Promise<void>;