ringline-grpc 0.3.0

Sans-IO gRPC client framing layer
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
50
51
52
53
54
55

# ringline-grpc

**Sans-IO gRPC client framing layer.**

A pure sans-IO gRPC client framing layer built on top of
[`ringline-h2`](https://docs.rs/ringline-h2). Has no protobuf dependency -- the
caller provides raw `&[u8]` message bodies and handles serialization externally.

## Architecture

```text
  TCP + TLS bytes
       |
  +----v-----------+
  | ringline-h2    |  HTTP/2 framing + HPACK
  +----+-----------+
       |
  +----v-----------+
  | ringline-grpc  |  gRPC message framing + status codes
  | GrpcConnection |  GrpcEvent: Response, Message, Status, etc.
  +----------------+
```

## Quick Start

```rust,ignore
use ringline_grpc::{GrpcConnection, GrpcEvent, Settings};

let mut grpc = GrpcConnection::new(Settings::client_default());

// Send the connection preface to the transport.
let preface = grpc.take_pending_send();
transport_send(&preface);

// Send a unary request (codec-agnostic: caller provides raw bytes).
let stream_id = grpc.send_unary("my.Service", "MyMethod", &request_bytes, &[])?;
transport_send(&grpc.take_pending_send());

// Feed received bytes and drain events.
grpc.recv(&received_data)?;
while let Some(event) = grpc.poll_event() {
    match event {
        GrpcEvent::Message { stream_id, data } => { /* decoded message */ }
        GrpcEvent::Status { stream_id, status, message, .. } => { /* done */ }
        _ => {}
    }
}
```

## Features

- gRPC length-prefixed message framing (encode + decode)
- Status code and trailing metadata extraction
- Codec-agnostic: works with protobuf, flatbuffers, or any serialization format
- Built on ringline-h2 for HTTP/2 transport