Skip to content

Commit

Permalink
Adding docs for event retries in snap-ins (#82)
Browse files Browse the repository at this point in the history
* Init docs for snap-in configuration

* init docs and fixes

* rewrite

* review comments

* update configuration

* Add code blocks to retry mechanism

* Apply suggestions from code review

Co-authored-by: Ben Colborn <[email protected]>

* code review suggestions

* Fix as per comments

* add pages to sidebar nav

* Review comments

* Remove docs for retries for now as we finalize approach

* remove snap-components link

* Revert "Remove docs for retries for now as we finalize approach"

This reverts commit 293238b.

* fix path

* Update fern/docs/pages/retry-mechanism.mdx

Co-authored-by: Ben Colborn <[email protected]>

* Update fern/docs/pages/retry-mechanism.mdx

Co-authored-by: Ben Colborn <[email protected]>

* Update fern/docs/pages/retry-mechanism.mdx

Co-authored-by: Ben Colborn <[email protected]>

---------

Co-authored-by: Ben Colborn <[email protected]>
Co-authored-by: shashankcube <[email protected]>
  • Loading branch information
3 people authored Aug 20, 2024
1 parent 06eceba commit 2839a79
Show file tree
Hide file tree
Showing 2 changed files with 110 additions and 0 deletions.
107 changes: 107 additions & 0 deletions fern/docs/pages/retry-mechanism.mdx
Original file line number Diff line number Diff line change
@@ -0,0 +1,107 @@
# Event reliability in DevRev snap-ins

The DevRev snap-ins platform offers event reliability features to ensure smooth and resilient event processing. This document provides an overview of these features and how developers can leverage them to build reliable snap-ins.

## Getting started

To start using the event reliability features in your Snap-ins, follow these steps:

1. Update your DevRev SDK to the latest version.
2. Define retryable errors using the `FunctionExecutionError` interface in your Snap-in code.
3. Configure the retry behavior in your snap-in manifest.
4. Handle errors appropriately in your snap-in function.

## Retryable errors

Snap-ins can define retryable errors using the `FunctionExecutionError` interface provided by the DevRev SDK. This enables the platform to automatically retry events that encounter intermittent or transient errors, improving overall reliability.

## Retry configuration

Developers can configure the retry behavior of their snap-in functions using the snap-in manifest. The following options are available:

```yaml
functions:
- name: function_name
config:
runtime:
max_retries: 5 # number of retries before failing the event
min_interval: 120 # interval in seconds between each retry
```
- `max_retries`: The maximum number of retries before marking the event as failed.
- `min_interval`: The minimum interval in seconds between each retry attempt. This interval may be adjusted based on the timeout of the corresponding function.

## Error handling

The DevRev snap-in platform handles errors based on the ordering guarantees of the snap-in function.

For snap-in functions with relaxed ordering, non-retryable errors are marked as failed, and the errored event is propagated to the DevRev platform for tracking. Retryable errors are automatically retried based on the specified retry configuration. If the maximum number of retries is exhausted, the errored events are moved to a dead-letter queue (DLQ) for further handling.

## Error interface

The DevRev SDK defines the `FunctionExecutionError` type to represent errors returned from the snap-in's run function. Developers can use this type to provide additional error details and indicate whether an error is retryable.

```typescript
class FunctionExecutionError extends Error {
/**
* Toggle to determine if the event should be retried or not. If not set or set to false,
* the event is not retried.
*/
retry: boolean;
/**
* Whether to retry the event payload with updated metadata
* that platform provides. Useful when the event payload is
* not in a state to be directly processed, and may need new
* keyrings/service account tokens or new inputs.
*/
refresh?: boolean;
constructor(message: string, retry: boolean, refresh?: boolean) {
super(message);
this.retry = retry;
this.refresh = refresh;
}
}
```

## Example usage

Here's an example of how to use the `FunctionExecutionError` in your Snap-in code:

```typescript
import { FunctionExecutionError } from '@devrev/typescript-sdk/dist/snap-ins/types';
export const run = async (events: any[]) => {
/*
Put your code here to handle the event.
*/
console.log('Events: ', JSON.stringify(events));
try {
// Your event processing logic here
// ...
// Retryable error
console.log('Retrying....');
const runtimeError = new FunctionExecutionError('Runtime Retryable Error', true, false);
throw runtimeError;
// Non-retryable error
// const runtimeError = new FunctionExecutionError("Runtime Non-Retryable Error", false, false);
// throw runtimeError;
} catch (error) {
if (error instanceof FunctionExecutionError) {
throw error;
} else {
// Handle other types of errors
// ...
}
}
};
export default run;
```

In this example, the Snap-in function's `run` method processes the events and can throw a `FunctionExecutionError` to indicate whether the error is retryable or not. The Snap-in platform handles the error based on the `retry` and `refresh` properties set in the error object.
3 changes: 3 additions & 0 deletions fern/versions/public.yml
Original file line number Diff line number Diff line change
Expand Up @@ -199,6 +199,9 @@ navigation:
path: ../docs/pages/best_practices.mdx
- page: Locally testing snap-ins
path: ../docs/pages/testing.mdx
- page: Handling errors and retrying
slug: handling-errors-and-retrying
path: ../docs/pages/retry-mechanism.mdx
- page: Debugging
path: ../docs/pages/debugging.mdx
- page: Quotas and limits
Expand Down

0 comments on commit 2839a79

Please sign in to comment.