Class: ServerlessPool

Defined in: glide-mq/src/serverless-pool.ts:29

Constructors

Constructor

new ServerlessPool(): ServerlessPool;

Returns

ServerlessPool

Accessors

size

Get Signature

get size(): number;

Defined in: glide-mq/src/serverless-pool.ts:72

Number of cached producers.

Returns

number

Methods

closeAll()

closeAll(): Promise<void>;

Defined in: glide-mq/src/serverless-pool.ts:63

Close all cached producers and clear the cache. Call this during Lambda SIGTERM or explicit cleanup.

Returns

Promise<void>

---

getProducer()

getProducer<D>(name, opts): Producer<D>;

Defined in: glide-mq/src/serverless-pool.ts:40

Get or create a Producer for the given queue name and options. Returns a cached instance if one exists with matching connection parameters.

Note: Injected clients and custom serializers bypass caching to prevent collisions where different instances could map to the same cache key.

Type Parameters

Type Parameter	Default type
D	any

Parameters

Parameter	Type
name	string
opts	ProducerOptions

Returns

Producer<D>