README
¶
orchestration
Provides various generalized channel based orchestration packages
Directories
¶
| Path | Synopsis |
|---|---|
|
internal
|
|
|
simple
Package simple provides a simple channeled orchestrator that can you can dial up or down parrallel operations and can multiplex to have large concurrent pipelines.
|
Package simple provides a simple channeled orchestrator that can you can dial up or down parrallel operations and can multiplex to have large concurrent pipelines. |
|
linear
|
|
|
promise
Package promise provides a processing pipeline where every input results in a response as a promise.
|
Package promise provides a processing pipeline where every input results in a response as a promise. |
|
promise/examples/stroke
DON'T USE THIS EXAMPLE FOR PROMISE....
|
DON'T USE THIS EXAMPLE FOR PROMISE.... |
|
promise/examples/stroke/pipeline
This is really the wrong use case for this type of Pipeline, but I wanted to see if I could make it work and wanted to test various error conditions I knew I would discover while I wrote out all the enumerators.
|
This is really the wrong use case for this type of Pipeline, but I wanted to see if I could make it work and wanted to test various error conditions I knew I would discover while I wrote out all the enumerators. |
|
streaming
Package streaming provides a processing pipeline where your stream a group of inputs to be processed by a Pipeline.
|
Package streaming provides a processing pipeline where your stream a group of inputs to be processed by a Pipeline. |
|
streaming/examples/stroke
This takes some health data on strokes you can find at: https://www.kaggle.com/fedesoriano/stroke-prediction-dataset It converts that data to a standard format with enumerators in the first stage and then writes out some stats in the second stage (how many were Males, Females, Married, ...).
|
This takes some health data on strokes you can find at: https://www.kaggle.com/fedesoriano/stroke-prediction-dataset It converts that data to a standard format with enumerators in the first stage and then writes out some stats in the second stage (how many were Males, Females, Married, ...). |
|
streaming/examples/stroke/pipeline
This takes some health data on strokes you can find at: https://www.kaggle.com/fedesoriano/stroke-prediction-dataset It converts that data to a standard format with enumerators in the first stage and then writes out some stats in the second stage (how many were Males, Females, Married, ...).
|
This takes some health data on strokes you can find at: https://www.kaggle.com/fedesoriano/stroke-prediction-dataset It converts that data to a standard format with enumerators in the first stage and then writes out some stats in the second stage (how many were Males, Females, Married, ...). |
Click to show internal directories.
Click to hide internal directories.