src

package

v0.31.0 Latest Latest Go to latest Published: Feb 6, 2021 License: GPL-2.0, GPL-3.0 Imports: 0 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Layer9Berlin/pipedream

Links

Open Source Insights

Documentation ¶

Overview ¶

Implementation of the `pipedream` functionalities

Source Files ¶

View all Source files

src.go

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Path	Synopsis
custom Extensions and customizations of native/third party libraries	Extensions and customizations of native/third party libraries
evaluate Custom functions extending the `govaluate` package	Custom functions extending the `govaluate` package
filepath Custom functions extending the native `filepath` package	Custom functions extending the native `filepath` package
io Custom functions extending the native `io` package	Custom functions extending the native `io` package
math Custom functions extending the native `math` package	Custom functions extending the native `math` package
stringmap Convenience functions for maps with string keys	Convenience functions for maps with string keys
strings Custom functions extending the native `strings` package	Custom functions extending the native `strings` package
datastream Provides a composable data stream, which pipes multiple inputs to multiple outputs according to the defined compositions	Provides a composable data stream, which pipes multiple inputs to multiple outputs according to the defined compositions
logging Provides custom logging and activity indication	Provides custom logging and activity indication
fields Provides custom log entry fields	Provides custom log entry fields
middleware Each middleware provides an implementation slice, performing side effects and adapting the run based on provided arguments	Each middleware provides an implementation slice, performing side effects and adapting the run based on provided arguments
catch The `catch` middleware enables graceful handling of stderr output	The `catch` middleware enables graceful handling of stderr output
catcheach The `catchEach` middleware enables graceful handling of stderr output based on regex patterns	The `catchEach` middleware enables graceful handling of stderr output based on regex patterns
dir The `dir` middleware allows for changing the current working directory	The `dir` middleware allows for changing the current working directory
docker The `docker` middleware enables execution within a Docker (Compose) container	The `docker` middleware enables execution within a Docker (Compose) container
each The `each` middleware copies some input into several child pipes running simultaneously	The `each` middleware copies some input into several child pipes running simultaneously
env The `env` middleware manipulates environment variables	The `env` middleware manipulates environment variables
inherit The `inherit` middleware passes arguments from a parent to its children	The `inherit` middleware passes arguments from a parent to its children
input The `input` middleware overwrites a pipe's input directly	The `input` middleware overwrites a pipe's input directly
interpolate The `interpolate` middleware substitutes arguments or inputs into other arguments	The `interpolate` middleware substitutes arguments or inputs into other arguments
output The `output` middleware overwrites a pipe's output directly	The `output` middleware overwrites a pipe's output directly
pipe The `pipe` middleware executes several commands in sequence	The `pipe` middleware executes several commands in sequence
select The `select` middleware shows selection prompts to the user	The `select` middleware shows selection prompts to the user
shell The `shell` middleware executes commands in a shell	The `shell` middleware executes commands in a shell
ssh The `ssh` middleware enables remote command execution via SSH	The `ssh` middleware enables remote command execution via SSH
stack Defines a list of middleware items to be executed when a pipeline is run	Defines a list of middleware items to be executed when a pipeline is run
sync The `sync` middleware defers execution until a condition is fulfilled	The `sync` middleware defers execution until a condition is fulfilled
timer The `timer` middleware records execution time	The `timer` middleware records execution time
when The `when` middleware enables conditional execution	The `when` middleware enables conditional execution
with The `with` middleware extracts and processes input patterns	The `with` middleware extracts and processes input patterns
parser Provides a parser for pipeline yaml files	Provides a parser for pipeline yaml files
pipeline Provides a model representing a pipeline definition that defines default arguments for a pipeline identifier Provides a representation of a yaml pipeline file as a Go struct Provides models to represent pipeline files and runs Provides a model representing a pipeline run	Provides a model representing a pipeline definition that defines default arguments for a pipeline identifier Provides a representation of a yaml pipeline file as a Go struct Provides models to represent pipeline files and runs Provides a model representing a pipeline run
run Implementation of the default shell command, selecting, parsing and executing pipelines	Implementation of the default shell command, selecting, parsing and executing pipelines
version Implementation of the version command, providing information about the current pipedream command line tool installation	Implementation of the version command, providing information about the current pipedream command line tool installation