Class Base<T>Abstract

constructor

• new Base<T extends Plugs.Sink.Any<string, any, AnyHeaders, AnyOptions>>(
      plug: T,
      options?: SinkOptions,
  ): Base<T>

• Create a new instance for a firehose sink

  Type Parameters

  • T extends Plugs.Sink.Any<string, any, AnyHeaders, AnyOptions>

  Parameters

  • plug: T

    sink plug instance
  • Optionaloptions: SinkOptions

    sink options

  Returns Base<T>

ReadonlyplugWrapper

checks

• get checks(): Checks<any>

• Return the status of the stream in a standard format

  Returns Checks<any>

  check object as defined in the draft standard https://datatracker.ietf.org/doc/html/draft-inadarei-api-health-check-05

componentId

• get componentId(): string

• Component identification

  Returns string

metrics

• get metrics(): undefined | Registry<"text/plain; version=0.0.4; charset=utf-8">

• Metrics registry for this component

  Returns undefined | Registry<"text/plain; version=0.0.4; charset=utf-8">

name

• get name(): string

• Component name

  Returns string

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>