#stream #cord #platform #subscriber #broker #messages #exchange

app cord-broker

The server-side routing platform for the Cord Platform that exchanges messages between publishers and subscribers

3 unstable releases

0.3.1 Oct 18, 2022
0.3.0 Jan 25, 2022
0.1.0 Apr 1, 2020

#26 in #subscriber

MPL-2.0 license

34KB
596 lines

Cord Broker

CI Code Testing and Linting CI Security Audit on Push

Cord is a data streaming platform for composing, aggregating and distributing arbitrary streams. The Broker crate provides stream aggregation and distribution functionality for the platform. It is the central component that all clients communicate with to exchange messages.

Usage

First, start a new Cord Broker:

Docker

$ docker run -d -p 7101:7101 --rm cordproj/cord-broker:0

Cargo

$ cargo install cord-broker
$ cord-broker &

Next, use the Cord Client to interact with the Broker. The easiest way to get started is by using the Client CLI.

Subscribe to a namespace:

Docker

$ docker run --rm cordproj/cord-client:0 -a <broker_addr> sub /names

Cargo

$ cargo install cord-client
$ cord-client sub /namespaces

Publish to this namespace:

Docker

$ docker run -it --rm cordproj/cord-client:0 -a <broker_addr> pub /names
Start typing to create an event, then press enter to send it to the broker.
Use the format: NAMESPACE=VALUE

/names/first=Daz

Cargo

$ cord-client pub /names
Start typing to create an event, then press enter to send it to the broker.
Use the format: NAMESPACE=VALUE

/names/first=Daz

Dependencies

~11–21MB
~291K SLoC