Group: Enrichmeai Culvert

Sort by:Popular▼

✓Popular✓Newest

The cloud-neutral kernel of the Culvert framework, Java edition. Defines the eleven Protocol interfaces (Source, Sink, Transform, Pipeline, PipelineStage, RuntimeContext, JobControlRepository, BlobStore, Warehouse, ...

Abstract JUnit contract test classes that every Culvert framework implementation must pass. Cloud adapter modules extend the relevant contract test class and supply the adapter under test; the abstract tests prove the adapter ...

Reusable Testcontainers fixtures for the Culvert framework's integration tests. Provides emulator containers (BigQuery via goccy/bigquery-emulator, GCS via fsouza/fake-gcs-server) plus helpers that build GCP SDK clients ...

Google Cloud Storage adapter for the Culvert framework. Provides GcsBlobStore, a BlobStore implementation that wraps com.google.cloud.storage.Storage.

AWS Athena adapter for the Culvert framework. Sprint-21 module (epic #144, T21.5, issue #149).

AWS CloudWatch adapter for the Culvert framework. Sprint-21 module (epic #144, T21.6).

AWS DynamoDB adapter for the Culvert framework. Sprint-21 module (epic #144, T21.4 / issue #148).

AWS S3 adapter for the Culvert framework. Implements the same BlobStore contract as data-pipeline-gcp-gcs over AWS S3 (AWS SDK v2).

AWS Secrets Manager adapter for the Culvert framework. Sprint-21 deliverable (epic #144, T21.2): AwsSecretsManagerProvider, a SecretProvider implementation that wraps ...

AWS SQS adapter for the Culvert framework. Provides SqsSource (Source implementation wrapping an SqsClient for synchronous receive + eager delete) and SqsSink (Sink implementation wrapping an SqsClient for batched ...

Azure Blob Storage adapter SKELETON for the Culvert framework. Sprint-8 deliverable — proves the cloud-neutral design works against Azure by implementing the BlobStore contract over com.azure:azure-storage-blob.

Google Cloud BigQuery adapter for the Culvert framework. Provides BigQueryWarehouse, a Warehouse implementation that wraps com.google.cloud.bigquery.BigQuery.

Google Cloud Dataflow adapter for the Culvert framework. Provides DataflowPipeline, a Pipeline implementation that holds the stage topology (per the Pipeline contract — name + stages + validate) plus utility methods for ...

Google Cloud observability adapters for the Culvert framework. Provides CloudTraceObservabilityHook (ObservabilityHook implementation backed by OpenTelemetry exporting spans to Cloud Trace via the GCP exporter) and ...

Google Cloud Pub/Sub adapter for the Culvert framework. Provides PubSubSource (Source implementation wrapping a SubscriberStub for synchronous pull) and PubSubSink (Sink implementation wrapping a Publisher).

Google Cloud Secret Manager adapter for the Culvert framework. Provides SecretManagerProvider, a SecretProvider implementation that wraps com.google.cloud.secretmanager.v1.SecretManagerServiceClient.

Parent POM for the Culvert framework's Java libraries (cloud-neutral data pipeline framework). Modules: data-pipeline-core-java, and future data-pipeline-gcp-dataflow-java, data-pipeline-gcp-bigquery-java, ...

Scheduler-agnostic orchestration layer for the Culvert framework. Provides a cloud-neutral DAG model (DagSpec / TaskSpec) and a Pipeline -> DagSpec translator (T11.1).

Mockito-helper fixture builders for the Culvert framework contracts. Consumers use these helpers to mock SecretProvider, Warehouse, BlobStore, JobControlRepository, and FinOpsSink in their own unit tests without repeating the ...