package
0.0.0-20230925091837-55f7a6b23beb
Repository: https://github.com/xdbfoundation/go.git
Documentation: pkg.go.dev
# Variables
ErrShutdown is an error send to post-processing hook when pipeline has been shutdown.
# Structs
BufferedReadWriter implements Reader and Writer and acts like a pipe.
No description provided by the author
No description provided by the author
Store allows storing data connected to pipeline execution.
# Interfaces
PipelineInterface is an interface that defines common pipeline methods in structs that embed Pipeline.
Processor defines methods required by the processing pipeline.
Reader interface placeholder.
Writer interface placeholder.