Class: PubSubService

Properties

client

▪ Static Protected client: PubSubClientV2

Defined in

src/service/pubsub.ts:13

---

driver

▪ Static Protected driver: "synchronous" | "google"

Defined in

src/service/pubsub.ts:15

---

instance

▪ Static Protected instance: PubSubService

Defined in

src/service/pubsub.ts:14

Methods

closeAll

▸ closeAll(): Promise<void>

Returns

Promise<void>

Defined in

src/service/pubsub.ts:123

---

getAllSubscriptions

▸ getAllSubscriptions(): Promise<AllSubscriptions[]>

Retrieves a list of subscribers

Returns

Promise<AllSubscriptions[]>

Defined in

src/service/pubsub.ts:213

---

getSubscribers

▸ getSubscribers(): Subscribers

Returns

Subscribers

Defined in

src/service/pubsub.ts:119

---

initClient

▸ initClient(): void

Returns

void

Defined in

src/service/pubsub.ts:84

---

publish

▸ publish<T>(topic, message, options?): Promise<string>

Publishes new orders to PubSub.

Type parameters

Name	Type
T	extends TopicProperties

Parameters

Name	Type
topic	T
message	Record<string, unknown>
options?	PublishOptions

Returns

Promise<string>

Defined in

src/service/pubsub.ts:102

---

startSubscriptions

▸ startSubscriptions(): Promise<void>

Returns

Promise<void>

Defined in

src/service/pubsub.ts:144

---

subscribe

▸ subscribe(subscription): Promise<void>

Subscribes to any given topic

Parameters

Name	Type
subscription	SubscriberTuple

Returns

Promise<void>

Defined in

src/service/pubsub.ts:206

---

getInstance

▸ Static getInstance(): PubSubService

Returns

PubSubService

Defined in

src/service/pubsub.ts:92

---

isHealthy

▸ Static isHealthy(): boolean

Returns

boolean

Defined in

src/service/pubsub.ts:48