nice-grpc-client-middleware-retry

import { createChannel, createClientFactory, ClientError, Status } from 'nice-grpc'; import { retryMiddleware } from 'nice-grpc-client-middleware-retry'; // Imagine you have a generated Protobuf service definition (e.g., from ts-proto) // interface ExampleService extends Client<typeof ExampleServiceDefinition> {} // const ExampleServiceDefinition = { ... }; // Your service definition // Mock a service definition for demonstration const ExampleServiceDefinition = { name: 'ExampleService', methods: { exampleMethod: { path: '/ExampleService/ExampleMethod', requestType: {}, // replace with your actual request type responseType: {}, // replace with your actual response type options: {}, }, }, }; async function runClientWithRetries() { const address = process.env.GRPC_SERVER_ADDRESS ?? 'localhost:50051'; const channel = createChannel(address); const clientFactory = createClientFactory().use(retryMiddleware); const client = clientFactory.create(ExampleServiceDefinition, channel); let attempt = 0; try { console.log('Attempting to call exampleMethod with retries...'); const response = await client.exampleMethod({}, { // Enable retry if method is not marked as idempotent in Protobuf options retry: true, retryMaxAttempts: 3, retryableStatuses: [Status.UNAVAILABLE, Status.INTERNAL, Status.UNKNOWN], onRetry(error: ClientError, attemptNumber: number) { console.warn(`Retry attempt ${attemptNumber} due to ${Status[error.code]}: ${error.details}`); }, // Optional: Exponential backoff configuration retryDelay: 100, // initial delay in ms retryDelayMax: 1000, // max delay in ms retryDelayMultiplier: 2, // multiplier for each successive delay }); console.log('Successfully received response:', response); } catch (error) { if (error instanceof ClientError) { console.error(`Client error after all retries: ${Status[error.code]} - ${error.details}`); } else { console.error('An unexpected error occurred:', error); } } finally { channel.close(); } } runClientWithRetries();