@effect-aws/client-kafkaconnect

Installation

npm install --save @effect-aws/client-kafkaconnect

Usage

With default KafkaConnectClient instance:

import { KafkaConnect } from "@effect-aws/client-kafkaconnect";

const program = KafkaConnect.listConnectors(args);

const result = pipe(
  program,
  Effect.provide(KafkaConnect.defaultLayer),
  Effect.runPromise,
);

With custom KafkaConnectClient instance:

import { KafkaConnect } from "@effect-aws/client-kafkaconnect";

const program = KafkaConnect.listConnectors(args);

const result = await pipe(
  program,
  Effect.provide(
    KafkaConnect.baseLayer(() => new KafkaConnectClient({ region: "eu-central-1" })),
  ),
  Effect.runPromise,
);

With custom KafkaConnectClient configuration:

import { KafkaConnect } from "@effect-aws/client-kafkaconnect";

const program = KafkaConnect.listConnectors(args);

const result = await pipe(
  program,
  Effect.provide(KafkaConnect.layer({ region: "eu-central-1" })),
  Effect.runPromiseExit,
);

or use KafkaConnect.baseLayer((default) => new KafkaConnectClient({ ...default, region: "eu-central-1" }))