# Functions
NewChanSink returns a new ChanSink connector.
NewChanSource returns a new ChanSource connector.
NewFileSink returns a new FileSink connector.
NewFileSource returns a new FileSource connector.
NewIgnoreSink returns a new IgnoreSink connector.
NewReaderSource returns a new ReaderSource connector.
NewStdoutSink returns a new StdoutSink connector.
NewWriterSink returns a new WriterSink connector.
WithContext configures the options with a context.
WithContextCancel configures the options with a context cancellation function.
WithLogger configures the options with a custom logger.
WithRetryFunc configures the options with a custom retry function.
# Structs
ChanSink represents an outbound connector that writes streaming data to a channel.
ChanSource represents an inbound connector that creates a stream of elements from a channel.
FileSink represents an outbound connector that writes streaming data to a file.
FileSource represents an inbound connector that creates a stream of elements from a file.
IgnoreSink represents a simple outbound connector that discards all elements of a stream.
ReaderSource represents an inbound connector that reads elements from an io.Reader.
StdoutSink represents a simple outbound connector that writes streaming data to standard output.
WriterSink represents an outbound connector that writes data to an io.WriteCloser.
# Type aliases
ElementReader reads and parses an element from the provided io.Reader.
Opt is a functional option type used to configure an options.