| 1 | import * as Layer from "effect/Layer"; |
| 2 | import { ConnectWrite } from "./Connect.ts"; |
| 3 | import { |
| 4 | KAFKA_CONNECT_ACTIONS, |
| 5 | KAFKA_WRITE_CLUSTER_ACTIONS, |
| 6 | KAFKA_WRITE_TOPIC_ACTIONS, |
| 7 | KAFKA_WRITE_TRANSACTION_ACTIONS, |
| 8 | makeKafkaConnectHttpBinding, |
| 9 | } from "./ConnectHttp.ts"; |
| 10 | |
| 11 | export const ConnectWriteHttp = Layer.effect( |
| 12 | ConnectWrite, |
| 13 | makeKafkaConnectHttpBinding({ |
| 14 | tag: "AWS.Kafka.ConnectWrite", |
| 15 | clusterActions: [...KAFKA_CONNECT_ACTIONS, ...KAFKA_WRITE_CLUSTER_ACTIONS], |
| 16 | topicActions: KAFKA_WRITE_TOPIC_ACTIONS, |
| 17 | transactionActions: KAFKA_WRITE_TRANSACTION_ACTIONS, |
| 18 | }), |
| 19 | ); |