dsh-sdk-platform-rs

Description

This library can be used to interact with the DSH Platform. It is intended to be used as a base for services that will be used to interact with DSH. Features include:

• Connect to DSH
• Fetch Kafka Properties and certificates
• Rest API Token Fetcher (to be used with dsh_rest_api_client)
• MQTT Token Fetcher
• Common functions
  • Preconfigured RDKafka client config
  • Preconfigured Reqwest client config (for schema store)
• Graceful shutdown
• Prometheus Metrics (web server and re-export of metrics crate)
• Dead Letter Queue (experimental)

Note

Rdkafka and thereby this library is dependent on CMAKE. Make sure it is installed in your environment and/or Dockerfile where you are compiling. See dockerfile for an example.

Usage

To use this SDK with the default features in your project, add the following to your Cargo.toml file:

[dependencies]
dsh_sdk = "0.4"

However, if you would like to use only specific features, you can specify them in your Cargo.toml file. For example, if you would like to use only the bootstrap feature, add the following to your Cargo.toml file:

[dependencies]
dsh_sdk = { version = "0.4", default-features = false, features = ["bootstrap"] }

See feature flags for more information on the available features.

To use this SDK in your project

use dsh_sdk::Properties;
use dsh_sdk::rdkafka::consumer::{Consumer, StreamConsumer};

fn main() -> Result<(), Box<dyn std::error::Error>>{
    let dsh_properties = Properties::get();
    // get a rdkafka consumer config for example
    let consumer: StreamConsumer = dsh_properties.consumer_rdkafka_config().create()?;
}

Connect to DSH

The SDK is compatible with running in a container on a DSH tenant, on DSH System Space, on a machine with Kafka Proxy/VPN or on a local machine to a local Kafka. See CONNECT_PROXY_VPN_LOCAL for more info.

Feature flags

The following features are available in this library and can be enabled/disabled in your Cargo.toml file.:

See api documentation for more information on how to use these features including.

Environment variables

The default RDKafka config can be overwritten by setting environment variables. See ENV_VARIABLES.md for more information.

Api doc

See the api documentation for more information on how to use this library.

Examples

See folder dsh_sdk/examples for simple examples on how to use the SDK.

Full service example

See folder example_dsh_service for a full service, including how to build the Rust project and post it to Harbor. See readme for more information.

Changelog

See CHANGELOG.md for all changes per version.

Contributing

See CONTRIBUTING.md for more information on how to contribute to this project.

License

See LICENSE for more information on the license for this project.

Security

See SECURITY.md for more information on the security policy for this project.

Copyright (c) Koninklijke KPN N.V.