rskit-provider 0.2.0-alpha.3

Provider traits (request-response, stream, sink, duplex) with a tower bridge
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

# rskit-provider — Async I/O Interaction Traits

Typed async interaction traits (`Provider`, `RequestResponse`, `Stream`, `Sink`, `Duplex`) with a Tower bridge.

[![CI](https://github.com/kbukum/rskit/actions/workflows/ci.yml/badge.svg)](https://github.com/kbukum/rskit/actions/workflows/ci.yml) [![crates.io](https://img.shields.io/crates/v/rskit-provider.svg)](https://crates.io/crates/rskit-provider) [![docs.rs](https://docs.rs/rskit-provider/badge.svg)](https://docs.rs/rskit-provider) [![License: MIT](https://img.shields.io/badge/license-MIT-blue.svg)](https://github.com/kbukum/rskit/blob/main/LICENSE) [![MSRV: 1.91](https://img.shields.io/badge/MSRV-1.91-orange.svg)](https://github.com/kbukum/rskit/blob/main/core/Cargo.toml)

## Features

- `RequestResponse<I,O>` — single request → single response
- `Stream<I,O>` — request → async stream of responses
- `Sink<I>` — fire-and-forget
- `Duplex<I,O>` — bidirectional streaming
- Tower bridge for adapting `tower::Service` to `RequestResponse`

The provider traits intentionally remain object-safe via `async-trait` because some downstream adapters store them behind `dyn` trait objects. Stream, sink, and duplex implementations must use bounded queues or downstream backpressure and surface saturation as typed `AppError` values.

Cross-cutting behavior such as retry, rate limiting, circuit breaking, logging, and tracing belongs above these L2 contracts. Compose those concerns with `rskit-resilience` tower layers before wrapping a service with `TowerProvider`.

## Usage

```toml
[dependencies]
rskit-provider = "0.2.0-alpha.3"
async-trait = "0.1"
```

```rust
use rskit_provider::{Provider, RequestResponse};

struct EchoProvider;

#[async_trait::async_trait]
impl Provider for EchoProvider {
    fn name(&self) -> &'static str {
        "echo"
    }
}

#[async_trait::async_trait]
impl RequestResponse<String, String> for EchoProvider {
    async fn execute(&self, input: String) -> rskit_errors::AppResult<String> {
        Ok(input.to_uppercase())
    }
}
```

## See Also

[Main repository README](https://github.com/kbukum/rskit)