| Connector | Release | Type | Protocols/Description |
|---|---|---|---|
| sources/http | 0.4.2 | Rust | HTTP Polling 1.0, 1.1, 2.0 |
| sources/mqtt | 0.5.2 | Rust | MQTT V4, V5 |
| sources/postgres | 0.3.0 | Rust | Postgres CDC |
| sources/syslog | 0.2.0 | Rust | Syslog |
| Connector | Release | Type | Protocols/Description |
|---|---|---|---|
| sinks/postgres | 0.3.0 | Rust | Postgres CDC |
| sinks/slack | 0.3.0 | Rust | Sends messages to slack |
| sinks/dynamodb | 0.3.0 | Rust | Sends messages to dynamodb |
| sinks/kafka | 0.3.2 | Rust | Sends messages to dynamodb |
| sinks/sql | 0.1.1 | Rust | Postgres/SQLite |
| Lib | path | Type | Description |
|---|---|---|---|
| fluvio-connectors-common | common | Rust | Common Metadata opts |
| Model | Language(s) | Description |
|---|---|---|
| fluvio-model-postgres | Rust | Postgres Data Model |
| fluvio-model-sql | Rust | Common SQL Model |
| Model | Language(s) | Description |
|---|---|---|
| smartmodules/json-sql | Rust | Map JSON values to SQL inserts |
| smartmodules/jolt | Rust | JSON to JSON transformation |
| Example | Language(s) | Types | Protocols/Description | Status |
|---|---|---|---|---|
| python-client-connector | Python | Source | Source random cat facts | Alpha |
| github-stars | Rust | Source and Sink | Uses the http-source connector to fetch github stars from the github API with an aggregate smartmodule. The slack-sink connector consumes the same fluvio topic sends changes to a slack channel via a filter_map smartmodule. |
Beta |
| Mock | Type | Description |
|---|---|---|
| http-json-mock | Mock | Mock used by HTTP Bats |
| Smart Stream | Description |
|---|---|
| fluvio-smartstream-map | Map |
| Helper | Type | Description |
|---|---|---|
| bats-helpers | Test | Bats Helpers |
| test-connector | Test | Test Connector |
See CONTRIBUTING.md