pubsub-http-handler
- CreatePubSubHandlerResponse
- HandlePubSubMessageArgs
- PubSubCloudFunctionsConfig
- PubSubConfig
- PubSubServerConfig
Ƭ CloudFunctionFun: (req: express.Request, res: express.Response) => Promise<void>
▸ (req, res): Promise<void>
| Name | Type |
|---|---|
req |
express.Request |
res |
express.Response |
Promise<void>
Ƭ OnErrorHandler: (error: unknown) => void | Promise<void>
▸ (error): void | Promise<void>
| Name | Type |
|---|---|
error |
unknown |
void | Promise<void>
Ƭ PubSubHandler<T>: (args: { context?: unknown ; data?: T ; log: FastifyLoggerInstance ; message: PubSubMessageType }) => Promise<PubSubHandlerResponse | void> | PubSubHandlerResponse | void
| Name | Type |
|---|---|
T |
any |
▸ (args): Promise<PubSubHandlerResponse | void> | PubSubHandlerResponse | void
| Name | Type |
|---|---|
args |
Object |
args.context? |
unknown |
args.data? |
T |
args.log |
FastifyLoggerInstance |
args.message |
PubSubMessageType |
Promise<PubSubHandlerResponse | void> | PubSubHandlerResponse | void
Ƭ PubSubMessageType: Static<typeof PubSubMessage>
Ƭ PubSubRequestType: Static<typeof PubSubRequest>
• Const PubSubMessage: TObject<{ attributes: TOptional<TRecord<TString, TString>> ; data: TString ; messageId: TOptional<TString> }>
• Const PubSubRequest: TObject<{ message: TObject<{ attributes: TOptional<TRecord<TString, TString>> ; data: TString ; messageId: TOptional<TString> }> = PubSubMessage; subscription: TString }>
▸ createPubSubCloudFunctions<T>(handler, options?): CloudFunctionFun
| Name | Type |
|---|---|
T |
unknown |
| Name | Type |
|---|---|
handler |
PubSubHandler<T> |
options |
PubSubCloudFunctionsConfig |
▸ createPubSubServer<T>(handler, config?): CreatePubSubHandlerResponse
| Name | Type |
|---|---|
T |
unknown |
| Name | Type |
|---|---|
handler |
PubSubHandler<T> |
config |
PubSubServerConfig |
▸ handlePubSubMessage<Context>(args): Promise<PubSubHandlerResponse | void>
| Name | Type |
|---|---|
Context |
unknown |
| Name | Type |
|---|---|
args |
HandlePubSubMessageArgs<Context> |
Promise<PubSubHandlerResponse | void>
▸ pubSubFastifyPlugin(instance, opts): Promise<void>
| Name | Type |
|---|---|
instance |
FastifyInstance<Server, IncomingMessage, ServerResponse, FastifyLoggerInstance, FastifyTypeProviderDefault> |
opts |
PubSubConfig |
Promise<void>