Documentation
¶
Overview ¶
Package src contains the implementation of the `pipedream` functionalities
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package custom contains extensions and customizations of native/third party libraries
|
Package custom contains extensions and customizations of native/third party libraries |
|
evaluate
Package evaluate provides custom functions extending the `govaluate` package
|
Package evaluate provides custom functions extending the `govaluate` package |
|
filepath
Package filepath contains custom functions extending the native `filepath` package
|
Package filepath contains custom functions extending the native `filepath` package |
|
io
Package io contains custom functions extending the native `io` package
|
Package io contains custom functions extending the native `io` package |
|
math
Package math contains custom functions extending the native `math` package
|
Package math contains custom functions extending the native `math` package |
|
stringmap
Package stringmap contains convenience functions for maps with string keys
|
Package stringmap contains convenience functions for maps with string keys |
|
strings
Package strings contains custom functions extending the native `strings` package
|
Package strings contains custom functions extending the native `strings` package |
|
Package datastream provides a composable data stream, which pipes multiple inputs to multiple outputs according to the defined compositions
|
Package datastream provides a composable data stream, which pipes multiple inputs to multiple outputs according to the defined compositions |
|
Package logging provides custom logging and activity indication
|
Package logging provides custom logging and activity indication |
|
fields
Package fields provides custom log entry fields
|
Package fields provides custom log entry fields |
|
Package middleware provides middlewares that together implement pipedream's core functionalities
|
Package middleware provides middlewares that together implement pipedream's core functionalities |
|
catch
Package catch provides a middleware for graceful handling of stderr output
|
Package catch provides a middleware for graceful handling of stderr output |
|
dir
Package dir provides a middleware for changing the current working directory
|
Package dir provides a middleware for changing the current working directory |
|
docker
Package docker provides a middleware for execution within a Docker (Compose) container
|
Package docker provides a middleware for execution within a Docker (Compose) container |
|
each
Package each provides a middleware that copies some input into several child pipes running simultaneously
|
Package each provides a middleware that copies some input into several child pipes running simultaneously |
|
env
Package env provides a middleware managing environment variables
|
Package env provides a middleware managing environment variables |
|
inherit
Package inherit provides a middleware that passes arguments from a parent to its children
|
Package inherit provides a middleware that passes arguments from a parent to its children |
|
input
Package _input provides a middleware to overwrite a pipe's input directly
|
Package _input provides a middleware to overwrite a pipe's input directly |
|
interpolate
Package interpolate provides a middleware to substitute arguments or inputs into other arguments
|
Package interpolate provides a middleware to substitute arguments or inputs into other arguments |
|
output
Package _output provides a middleware to overwrite a pipe's output directly
|
Package _output provides a middleware to overwrite a pipe's output directly |
|
pipe
Package pipe provides a middleware to execute several commands in sequence
|
Package pipe provides a middleware to execute several commands in sequence |
|
select
Package _select provides a middleware that shows a selection prompt to the user
|
Package _select provides a middleware that shows a selection prompt to the user |
|
shell
Package shell provides a middleware to execute commands in a shell
|
Package shell provides a middleware to execute commands in a shell |
|
ssh
Package ssh provides a middleware enabling remote command execution via SSH
|
Package ssh provides a middleware enabling remote command execution via SSH |
|
stack
Package stack defines a list of middleware items to be executed when a pipeline is run
|
Package stack defines a list of middleware items to be executed when a pipeline is run |
|
timer
Package timer provides a middleware that records execution time
|
Package timer provides a middleware that records execution time |
|
wait_for
Package waitformiddleware provides a middleware to defer execution until a condition is fulfilled
|
Package waitformiddleware provides a middleware to defer execution until a condition is fulfilled |
|
when
Package when provides a middleware that enables conditional execution
|
Package when provides a middleware that enables conditional execution |
|
with
Package with provides a middleware that extracts and processes input patterns
|
Package with provides a middleware that extracts and processes input patterns |
|
Package parsing provides a parser for pipeline yaml files
|
Package parsing provides a parser for pipeline yaml files |
|
Package pipeline provides models to represent pipeline files and runs
|
Package pipeline provides models to represent pipeline files and runs |
|
Package run contains the implementation of the default `pipedream` shell command, selecting, parsing and executing pipelines
|
Package run contains the implementation of the default `pipedream` shell command, selecting, parsing and executing pipelines |
|
Package version provides the implementation of the version command, providing information about the current `pipedream` command line tool installation
|
Package version provides the implementation of the version command, providing information about the current `pipedream` command line tool installation |
Click to show internal directories.
Click to hide internal directories.