Class BrokerState

Hierarchy

BrokerState

Index

Constructors

Properties

entityFields locker setStore subscriptions

Methods

delete get getEntityFields increment isLocked lock publish publishEntityFields set subscribe tryLock unsubscribe unsubscribeEntityFields

Constructors

constructor

new BrokerState(): BrokerState
Returns BrokerState

Properties

entityFields

entityFields: Map<string, Map<string, number>> = ...

locker

locker: ProcessLocker = ...

setStore

setStore: Map<string, Uint8Array> = ...

subscriptions

subscriptions: Map<string, BrokerConnection[]> = ...

Methods

delete

delete(id: string): void
Parameters
- id: string
Returns void
- Defined in packages/broker/src/kernel.ts:289

get

get(id: string): undefined | Uint8Array
Parameters
- id: string
Returns undefined | Uint8Array
- Defined in packages/broker/src/kernel.ts:285

getEntityFields

getEntityFields(name: string): string[]
Parameters
- name: string
Returns string[]
- Defined in packages/broker/src/kernel.ts:192

increment

increment(id: string, v?: number): number
Parameters
- id: string
- Optional v: number
Returns number
- Defined in packages/broker/src/kernel.ts:277

isLocked

isLocked(id: string): boolean
Parameters
- id: string
Returns boolean
- Defined in packages/broker/src/kernel.ts:241

lock

lock(id: string, ttl: number, timeout?: number): Promise<ProcessLock>
Parameters
- id: string
- ttl: number
- timeout: number = 0
Returns Promise<ProcessLock>
- Defined in packages/broker/src/kernel.ts:233

publish

publish(channel: string, v: Uint8Array): void
Parameters
- channel: string
- v: Uint8Array
Returns void
- Defined in packages/broker/src/kernel.ts:260

publishEntityFields

publishEntityFields(name: string, fields: string[]): boolean
Parameters
- name: string
- fields: string[]
Returns boolean
- Defined in packages/broker/src/kernel.ts:196

set

set(id: string, data: Uint8Array): void
Parameters
- id: string
- data: Uint8Array
Returns void
- Defined in packages/broker/src/kernel.ts:273

subscribe

subscribe(channel: string, connection: BrokerConnection): void
Parameters
- channel: string
- connection: BrokerConnection
Returns void
- Defined in packages/broker/src/kernel.ts:251

tryLock

tryLock(id: string, ttl?: number): Promise<undefined | ProcessLock>
Parameters
- id: string
- ttl: number = 0
Returns Promise<undefined | ProcessLock>
- Defined in packages/broker/src/kernel.ts:237

unsubscribe

unsubscribe(channel: string, connection: BrokerConnection): void
Parameters
- channel: string
- connection: BrokerConnection
Returns void
- Defined in packages/broker/src/kernel.ts:245

unsubscribeEntityFields

unsubscribeEntityFields(name: string, fields: string[]): undefined | boolean
Parameters
- name: string
- fields: string[]
Returns undefined | boolean
- Defined in packages/broker/src/kernel.ts:215

Generated using TypeDoc