README
¶
pipelines
A repository of various pipelining frameworks
Directories
¶
| Path | Synopsis |
|---|---|
|
Package stagedpipe offers a generic, concurrent and parallel pipeline based on a statemachine to process work.
|
Package stagedpipe offers a generic, concurrent and parallel pipeline based on a statemachine to process work. |
|
examples/etl/bostonFoodViolations/pipelined/etl
Package etl contains the ETL statemachine for translating the boston food violations file into a postgres database.
|
Package etl contains the ETL statemachine for translating the boston food violations file into a postgres database. |
|
internal/queue
Package queue provides a simple queue primitive that blocks on Pop() until an entry is available and can block on Push() when a size limit is applied.
|
Package queue provides a simple queue primitive that blocks on Pop() until an entry is available and can block on Push() when a size limit is applied. |
|
testing/client
Package client provides a fake client to a fictional "identity" service to use in testing.
|
Package client provides a fake client to a fictional "identity" service to use in testing. |
Click to show internal directories.
Click to hide internal directories.