Class ClusterWorkerRequestProcessor

A RequestProcessor that is being run as Node.JS Cluster worker handling all the actual work.

Hierarchy

AbstractRequestProcessor
- ClusterWorkerRequestProcessor

Implements

RequestProcessor

Constructors

constructor

new ClusterWorkerRequestProcessor(_automations: AutomationServer, _configuration: Configuration, _listeners?: AutomationEventListener[]): ClusterWorkerRequestProcessor

Overrides AbstractRequestProcessor.constructor
- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:59
Parameters
- _automations: AutomationServer
- _configuration: Configuration
- Default value _listeners: AutomationEventListener[] = []
Returns ClusterWorkerRequestProcessor

Properties

Private Readonly _automations

_automations: AutomationServer

Private Readonly _configuration

_configuration: Configuration

Private Readonly _listeners

_listeners: AutomationEventListener[]

Protected automations

automations: AutomationServer

Protected configuration

configuration: Configuration

Private graphClients

graphClients: GraphClientFactory

Protected listeners

listeners: AutomationEventListener[]

Private Optional registration

registration: RegistrationConfirmation

Private shutdownInitiated

shutdownInitiated: boolean = false

Methods

Protected clearNamespace

clearNamespace(): void

Inherited from AbstractRequestProcessor.clearNamespace
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:327
Returns void

Protected createAndWrapMessageClient

createAndWrapMessageClient(event: EventIncoming | CommandIncoming, context: HandlerContext & AutomationContextAware): MessageClient & SlackMessageClient

Inherited from AbstractRequestProcessor.createAndWrapMessageClient
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:305
Parameters
- event: EventIncoming | CommandIncoming
- context: HandlerContext & AutomationContextAware
Returns MessageClient & SlackMessageClient

Protected createGraphClient

createGraphClient(event: CommandIncoming | EventIncoming, context: AutomationContextAware): GraphClient

Overrides AbstractRequestProcessor.createGraphClient
- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:138
Parameters
- event: CommandIncoming | EventIncoming
- context: AutomationContextAware
Returns GraphClient

Protected createMessageClient

createMessageClient(event: EventIncoming | CommandIncoming, context: AutomationContextAware): MessageClient

Overrides AbstractRequestProcessor.createMessageClient
- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:145
Parameters
- event: EventIncoming | CommandIncoming
- context: AutomationContextAware
Returns MessageClient

Protected invokeCommand

invokeCommand(ci: CommandInvocation, ctx: HandlerContext & AutomationContextAware, command: CommandIncoming, callback: (result: Promise<HandlerResult>) => void): void

Inherited from AbstractRequestProcessor.invokeCommand
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:189
Parameters
- ci: CommandInvocation
- ctx: HandlerContext & AutomationContextAware
- command: CommandIncoming
- callback: (result: Promise<HandlerResult>) => void
  - - (result: Promise<HandlerResult>): void
    - Parameters
      - result: Promise<HandlerResult>
      Returns void
Returns void

Protected invokeEvent

invokeEvent(ef: EventFired<any>, ctx: HandlerContext & AutomationContextAware, event: EventIncoming, callback: (results: Promise<HandlerResult[]>) => void): void

Inherited from AbstractRequestProcessor.invokeEvent
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:247
Parameters
- ef: EventFired<any>
- ctx: HandlerContext & AutomationContextAware
- event: EventIncoming
- callback: (results: Promise<HandlerResult[]>) => void
  - - (results: Promise<HandlerResult[]>): void
    - Parameters
      - results: Promise<HandlerResult[]>
      Returns void
Returns void

processCommand

processCommand(command: CommandIncoming, callback?: (result: Promise<HandlerResult>) => void): void

Inherited from AbstractRequestProcessor.processCommand
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:51
Parameters
- command: CommandIncoming
- Default value callback: (result: Promise<HandlerResult>) => void = () => {}
  - - (result: Promise<HandlerResult>): void
    - Parameters
      - result: Promise<HandlerResult>
      Returns void
Returns void

processEvent

processEvent(event: EventIncoming, callback?: (results: Promise<HandlerResult[]>) => void): void

Inherited from AbstractRequestProcessor.processEvent
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:95
Parameters
- event: EventIncoming
- Default value callback: (results: Promise<HandlerResult[]>) => void = () => {}
  - - (results: Promise<HandlerResult[]>): void
    - Parameters
      - results: Promise<HandlerResult[]>
      Returns void
Returns void

sendCommandStatus

sendCommandStatus(success: boolean, code: number, request: CommandIncoming, ctx: HandlerContext & AutomationContextAware): Promise<any>

Inherited from AbstractRequestProcessor.sendCommandStatus
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:139
Parameters
- success: boolean
- code: number
- request: CommandIncoming
- ctx: HandlerContext & AutomationContextAware
Returns Promise<any>

sendEventStatus

sendEventStatus(success: boolean, request: EventFired<any>, event: EventIncoming, ctx: HandlerContext & AutomationContextAware): Promise<any>

Inherited from AbstractRequestProcessor.sendEventStatus
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:168
Parameters
- success: boolean
- request: EventFired<any>
- event: EventIncoming
- ctx: HandlerContext & AutomationContextAware
Returns Promise<any>

sendShutdown

sendShutdown(code: number, ctx: HandlerContext & AutomationContextAware): Promise<void>

- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:126
Parameters
- code: number
- ctx: HandlerContext & AutomationContextAware
Returns Promise<void>

Protected sendStatusMessage

sendStatusMessage(payload: any, ctx: HandlerContext & AutomationContextAware): Promise<any>

Overrides AbstractRequestProcessor.sendStatusMessage
- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:130
Parameters
- payload: any
- ctx: HandlerContext & AutomationContextAware
Returns Promise<any>

setRegistration

setRegistration(registration: RegistrationConfirmation): void

- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:114
Parameters
- registration: RegistrationConfirmation
Returns void

setRegistrationIfRequired

setRegistrationIfRequired(data: any): void

- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:120
Parameters
- data: any
Returns void

Protected setupNamespace

setupNamespace(request: any, automations: AutomationServer, invocationId?: string, ts?: number): any

Overrides AbstractRequestProcessor.setupNamespace
- Defined in lib/internal/transport/cluster/ClusterWorkerRequestProcessor.ts:150
Parameters
- request: any
- automations: AutomationServer
- Default value invocationId: string = guid()
- Default value ts: number = Date.now()
Returns any

Generated using TypeDoc