Anthony Dodd
Anthony Dodd
Allow users to define a time-based SLA on a Pipeline. ### Abstract - Pipelines are multi-stage, and stage handlers may exist as part of various different microservices each with their...
- [ ] Establish a pattern for tracing integration server-side and client-side such that events can be linked to parent traces and such.
- Deregister pipeline & stream consumer group metrics once https://github.com/metrics-rs/metrics/issues/243 lands.
- [x] Stream: build and push Docker container images to ghcr.io. - [x] Operator: build and push Docker container images to ghcr.io. - [x] Operator Chart: build and push packaged...
- Define a new `Schema` CRD. - The name of the Schema will correspond with the CloudEvents `type` field. - Stream CRD will be updated to include a field `schemaValidation:...
Transactional Pipeline -> Stream outputs. Introduce the new `streamOutput` field for pipeline stages. - Stream outputs will be required to be supplied as part of the pipeline `ack` payload, just...
Catalog can use simple u64 IDs for relations, types, edges &c. Data will be encoded using a simple multi-byte key for efficient storage and scanning. Edges will be stored as...
- Stream & Pipeline consumers should be able to nack an event with a delay. - Stream controllers will need to be updated to use a different tracking mechanism for...