Volley is a 15-crate Cargo workspace. See the full Crate Map for detailed per-crate documentation.
Status: stable = production-ready | experimental = API may change | placeholder = stub/future work
| Crate | Description | Key Types | Status |
|---|
volley-core | Stream processing engine with built-in observability and optional RocksDB state | StreamExecutionEnvironment, DataStream, KeyedStream, Operator, StreamRecord, ObservabilityConfig, RocksDbBackend | stable |
volley-derive | Procedural macros | impl_to_arrow! | stable |
| Crate | Description | Key Types | Status |
|---|
volley-connectors | Umbrella crate (memory + feature-gated re-exports) | MemorySource, MemorySink | stable |
volley-connector-kafka | Kafka source + sink (exactly-once) | KafkaSource, KafkaSink, KafkaSourceConfig | stable |
volley-connector-blob-store | Cloud blob store abstraction + decoders | NotificationSource, BlobReader, BlobWriter | stable |
volley-connector-aws-s3 | AWS S3 + SQS source | S3Source, S3BlobReader, SqsNotificationSource | stable |
volley-connector-azure-blob | Azure Blob + Queue source | AzureBlobSource, AzureBlobReader | stable |
volley-connector-gcp-gcs | GCS + Pub/Sub source | GcsSource, GcsBlobReader, PubSubNotificationSource | stable |
volley-connector-delta | Delta Lake sink (exactly-once) | DeltaSink, DeltaSinkConfig | stable |
volley-connector-iceberg | Apache Iceberg sink (REST catalog) | IcebergSink, IcebergSinkConfig | stable |
| Crate | Description | Status |
|---|
volley-k8s-operator | Kubernetes operator for VolleyApplication CRD | stable |
volley-cli | CLI tool (volley new, volley doctor) | stable |
volley-scheduler | Distributed execution (Ballista integration) | experimental |
volley-python | PyO3 Python bindings | placeholder |
| Crate | Description | Status |
|---|
volley-examples | Runnable examples and benchmarks | stable |