Categorygithub.com/onexstack/onexpkgstreamsconnectorextension
package
0.2.0-alpha.14
Repository: https://github.com/onexstack/onex.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
11
Dependents
0
Files
315 SLOC

# Functions

NewChanSink returns a new ChanSink instance.
NewChanSource returns a new ChanSource instance.
NewFileSink returns a new FileSink instance.
NewFileSource returns a new FileSource instance.
NewIgnoreSink returns a new IgnoreSink instance.
NewNetSink returns a new instance of NetSink.
NewNetSource returns a new instance of NetSource.
NewStdoutSink returns a new StdoutSink instance.

# Constants

TCP connection type.
UDP connection type.

# Structs

ChanSink represents an outbound connector that streams items to a channel.
ChanSource represents an inbound connector that streams items from a channel.
FileSink represents an outbound connector that writes items to a file.
FileSource represents an inbound connector that reads items from a file.
IgnoreSink represents a simple outbound connector that discards all of the incoming items.
NetSink represents an outbound network socket connector.
NetSource represents an inbound network socket connector.
StdoutSink represents a simple outbound connector that sends incoming items to standard output.

# Type aliases

ConnType represents a connection type.