tremor-runtime

tremor-runtime copied to clipboard

Error improvements to pipelines

1

# Pull request ## Description Added clear messages for errors in pipelines when the input `port` doesn't exist, added `port` to `ConnectInput` and weaved them together with existing code ##...

carolgeng

GCL - concurrent requests

1

Signed-off-by: Ramona Łuczkiewicz # Pull request ## Description ## Related * [RFC](https://rfcs.tremor.rs/0000-.../) * Related Issues: fixes #000, closed #000 * Related [docs PR](https://github.com/tremor-rs/tremor-www-docs/pull/000) ## Checklist * [ ] The RFC,...

ramonacat

Initial work for pluggable logging - exploring tremor-pipeline

1

Signed-off-by: Perle_nwar # Pull request ## Description ## Related * [RFC](https://rfcs.tremor.rs/0000-.../) * Related Issues: fixes #000, closed #000 * Related [docs PR](https://github.com/tremor-rs/tremor-www-docs/pull/000) ## Checklist * [x] The RFC, if required,...

znwar

Make `gcs_streamer` and `s3_streamer` only ack upon finished uploads

1

# Pull request ## Description Also: * Log sink errors on `error` level * upgrade `serial_test` to 0.9, suspected an issue with it, so i tried upgrading to fix it...

mfelsche

String formatting with args not working in definitions

4

**Problem** Take this example config that tries to take the args values and format a string from them in the connector config: ```tremor define flow snot flow define connector client...

mfelsche

Ensure all linked transports track the request event_id at the response

1

**Describe the problem you are trying to solve** The rest onramp uses the response event_id to find out to which request this incoming response belongs. This requires each linked transport...

mfelsche

array concatinate intrinsics

3

**Describe the problem you are trying to solve** We have no way of adding to an array aside of `array:::push` and `array::concatinate`; those are not great from a performance standpoint,...

Licenser

**Describe the problem you are trying to solve** Consider the following script snippet: ```tremor let event.foo["nested"] = event.foo["nested"] + [1, 2, 3]; ``` This is a recurring pattern as our...

mfelsche

DRAFT: Initial attempt at concurrent gRPC for GCL writer

1

Signed-off-by: Darach Ennis # Pull request Attempt to add bounded concurrent in flight requests to GCL writer which is the first gRPC / tonic based connector to require it. As...

darach

Plugin Development Kit ( PDK )

11

**Describe the problem you are trying to solve** The plugin development kit ( PDK ) is an interface that allows developers to develop plugins to tremor with a minimal set...

darach