Class CorePlugin

supportedHandlers

partition

• partition(request: DataBinding): Promise<ProcessStreamResponse_Partitions>

  Parameters

  • request: DataBinding

  Returns Promise<ProcessStreamResponse_Partitions>

preprocessBinding

• preprocessBinding(
      request: DataBinding,
      preprocessStore: { [k: string]: any },
  ): Promise<PreprocessResult>

  Parameters

  • request: DataBinding
  • preprocessStore: { [k: string]: any }

  Returns Promise<PreprocessResult>

processBinding

• processBinding(
      request: DataBinding,
      preparedData: undefined | PreparedData,
  ): Promise<ProcessResult>

  Parameters

  • request: DataBinding
  • preparedData: undefined | PreparedData

  Returns Promise<ProcessResult>

shutdownServer

• shutdownServer(): void

  method used by action server only

  Returns void

start

• start(start: StartRequest): Promise<void>

  Parameters

  • start: StartRequest

  Returns Promise<void>

startServer

• startServer(port?: number): Promise<void>

  method used by action server only

  Parameters

  • Optionalport: number

  Returns Promise<void>

stateDiff

• stateDiff(config: ProcessConfigResponse): boolean

  Parameters

  • config: ProcessConfigResponse

  Returns boolean

  Deprecated

  The method should not be used, use ctx.states instead