Class PubSub

Hierarchy

PubSub

Index

Constructors

constructor

Methods

Constructors

constructor

new PubSub(projectId: string, decodingTable: SubscriptionMap, customStateManager?: StateManager): PubSub

- Defined in index.ts:227
Parameters
- projectId: string
- decodingTable: SubscriptionMap
- Optional customStateManager: StateManager
Returns PubSub

Methods

handlePubSubMessage

handlePubSubMessage(rawMsg: UnprocessedPubSubMessage): Promise<SubscriptionError | undefined>

- Defined in index.ts:267
This is the entrypoint for all pubsub subscription events

Parameters
- rawMsg: UnprocessedPubSubMessage
  
  An unprocessed pubsub message that must first be validated
Returns Promise<SubscriptionError | undefined>

publish

publish<J>(topic: string, data: J): Promise<void>

- Defined in index.ts:251
Publish an event to a topic

This method assumes that your data is serializeable to JSON

Type parameters
- J: {}
Parameters
- topic: string
  
  the event stream in GCP PubSub
- data: J
  
  the data associated with this event stream
Returns Promise<void>

Generated using TypeDoc