Interface Jet<Type, Data, CustomHeaders, CustomOptions>

Jet Sink interface definition A Jet is a Sink that allows to manage multiple Jobs at a time using the multi method or one Job using the single method

interface Jet<
    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">;
    multi: (
        jobs: JobObject<Type, Data, CustomHeaders, CustomOptions>[],
    ) => Promise<void>;
    single: (
        job: JobObject<Type, Data, CustomHeaders, CustomOptions>,
    ) => Promise<void>;
    on(event: "error", listener: (error: Crash | Error) => void): this;
    on(
        event: "status",
        listener: (status: "pass" | "fail" | "warn") => void,
    ): this;
    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? multi single

Methods

on start stop

Properties

Optional Readonlymetrics

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

Metrics registry for this component

multi

multi: (
    jobs: JobObject<Type, Data, CustomHeaders, CustomOptions>[],
) => Promise<void>

Perform the processing of several Jobs

Type declaration

single

single: (
    job: JobObject<Type, Data, CustomHeaders, CustomOptions>,
) => Promise<void>

Perform the processing of a single Job

Type declaration

Methods

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

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