agp-datapath 0.7.0

Core data plane functionality for AGP
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

# Datapath Module

This module provides the core functionalities for the gateway's data path.
It includes various components for handling messages, connections,
and pub/sub mechanisms.

## Files

### `connection.rs`

This file contains the logic for managing connections.

### `errors.rs`

This file defines error handling for the data path.

### `forwarder.rs`

This file implements the forwarding logic for messages.

### `lib.rs`

This file contains the main entry point for the data path module.

### `message_processing.rs`

This file provides utilities for processing messages.

### `messages.rs`

This file defines the structures and logic for handling messages.

### `messages/encoder.rs`

This file provides encoding utilities for messages.

### `messages/utils.rs`

This file contains utility functions for message handling.

### `pubsub.rs`

This file implements the publish-subscribe mechanism.

### `pubsub/proto.rs`

This file defines the protocol buffer for the pub/sub mechanism.

### `tables.rs`

This file contains the logic for managing various tables used in the data path.

### `tables/connection_table.rs`

This file defines the connection table management logic.

### `tables/errors.rs`

This file provides error handling for table operations.

### `tables/subscription_table.rs`

This file implements the subscription table logic.

### `tables/pool.rs`

This file contains the logic for managing object pools.

### `pubsub/gen/pubsub.proto.v1.rs`

This file contains the generated code for the pub/sub protocol buffer.

## Usage

To use this module, include it in your `Cargo.toml`:

```toml
[dependencies]
gateway-datapath = "0.1.0"
```