GetPipeline

Source: src/AWS/OSIS/GetPipeline.ts

Runtime binding for osis:GetPipeline.

Reads the bound Pipeline’s live detail — status, capacity, ingest endpoint URLs, and destinations — so an ops function can health-check the pipeline or discover its ingest endpoints at runtime. The pipeline name is injected from the binding. Provide the implementation with Effect.provide(AWS.OSIS.GetPipelineHttp).

Monitoring a Pipeline

// init — bind the operation to the pipeline
const getPipeline = yield* AWS.OSIS.GetPipeline(pipeline);

// runtime
const { Pipeline } = yield* getPipeline();
if (Pipeline?.Status !== "ACTIVE") {
  yield* Effect.logWarning(`pipeline is ${Pipeline?.Status}`);
}