Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,12 @@ tracing-subscriber = "0.3.18"
kafka = ["samsa"]

[[example]]
name = "loader"
path = "example/loader.rs"
name = "shakespeare_consumer"
path = "example/shakespeare_consumer.rs"

[[example]]
name = "shakespeare_loader"
path = "example/shakespeare_loader.rs"

[[example]]
name = "stocks"
Expand Down
7 changes: 7 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,17 +13,24 @@ A stream is an asyncronous iterator. It is any structure that implements the Str
#### Table
A table is a streaming data structure that keeps the latest state for each incoming key. The structure can be referenced like a map/dictionary, and also lets the incoming messages flow through through to be used elsewhere.

![table](img/table.png)

#### Actor
An actor is a `tokio` task that executes a stream. It accepts a input stream and returns an output stream. Actors do the work that is defined on a stream.

These are useful when you want to build complex stream processing pipelines. One use case is to break up processing into multiple steps so that you can do things with the partial results.

![actor](img/actor.png)

#### Sink
Sinks accept streams and dump the data elsewhere. Typically these are where the flow of the data in an rstreams program terminate.

![sink](img/sink.png)

#### Source
Sources get data from elsewhere and return that data in a stream. Typically these are at the beginning of flow in an rstreams program.

![source](img/source.png)

## Current supported features

Expand Down
Binary file added img/actor.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added img/sink.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added img/source.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added img/table.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.