Interface Flow<Type, Data, CustomHeaders, CustomOptions>

Flow Source interface definition A Flow is a Source that allows to manage the flow of Jobs using init/pause" methods to control the rate of Jobs that can be processed

interface Flow<
    Type extends string = string,
    Data = any,
    CustomHeaders extends Record<string, any> = AnyHeaders,
    CustomOptions extends Record<string, any> = AnyOptions,
> {
    metrics?: Registry<"text/plain; version=0.0.4; charset=utf-8">;
    postConsume: (jobId: string) => Promise<undefined | string>;
    init(): void;
    on(event: "error", listener: (error: Crash | Error) => void): this;
    on(
        event: "status",
        listener: (status: "pass" | "fail" | "warn") => void,
    ): this;
    on(
        event: "data",
        listener: (
            job: JobRequest<Type, Data, CustomHeaders, CustomOptions>,
        ) => void,
    ): this;
    pause(): void;
    start(): Promise<void>;
    stop(): Promise<void>;
}

Type Parameters

  • Type extends string = string
  • Data = any
  • CustomHeaders extends Record<string, any> = AnyHeaders
  • CustomOptions extends Record<string, any> = AnyOptions

Hierarchy (View Summary)

Properties

metrics? postConsume

Methods

init on pause start stop

Properties

Optional Readonlymetrics

metrics?: Registry<"text/plain; version=0.0.4; charset=utf-8">

Metrics registry for this component

postConsume

postConsume: (jobId: string) => Promise<undefined | string>

Perform the task to clean the job registers after the job has been resolved

Type declaration

    • (jobId: string): Promise<undefined | string>

    • Parameters

      • jobId: string

        Job entry identification

      Returns Promise<undefined | string>

      • the job entry identification that has been correctly removed or undefined if the job was not found

Methods

init

  • init(): void

  • Enable consuming process

    Returns void

on

  • on(event: "error", listener: (error: Crash | Error) => void): this

  • Emitted when the component throw an error

    Parameters

    • event: "error"
    • listener: (error: Crash | Error) => void

    Returns this

  • on(event: "status", listener: (status: "pass" | "fail" | "warn") => void): this

  • Emitted on every status change

    Parameters

    • event: "status"
    • listener: (status: "pass" | "fail" | "warn") => void

    Returns this

  • on(
        event: "data",
        listener: (
            job: JobRequest<Type, Data, CustomHeaders, CustomOptions>,
        ) => void,
    ): this

  • Emitted when there is a new job to be managed

    Parameters

    Returns this

pause

  • pause(): void

  • Stop consuming process

    Returns void

start

  • start(): Promise<void>

  • Start the Plug and the underlayer resources, making it available

    Returns Promise<void>

stop

  • stop(): Promise<void>

  • Stop the Plug and the underlayer resources, making it unavailable

    Returns Promise<void>

Settings

Member Visibility

On This Page

Properties
Methods