Documentation
¶
Overview ¶
Package extension provides basic connector implementations.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChanSink ¶
type ChanSink struct {
Out chan interface{}
}
ChanSink represents an outbound connector that streams items to a channel.
func NewChanSink ¶
func NewChanSink(out chan interface{}) *ChanSink
NewChanSink returns a new ChanSink instance.
type ChanSource ¶
type ChanSource struct {
// contains filtered or unexported fields
}
ChanSource represents an inbound connector that streams items from a channel.
func NewChanSource ¶
func NewChanSource(in chan interface{}) *ChanSource
NewChanSource returns a new ChanSource instance.
func (*ChanSource) Out ¶
func (cs *ChanSource) Out() <-chan interface{}
Out returns an output channel for sending data.
type FileSink ¶
type FileSink struct {
// contains filtered or unexported fields
}
FileSink represents an outbound connector that writes items to a file.
func NewFileSink ¶
NewFileSink returns a new FileSink instance.
type FileSource ¶
type FileSource struct {
// contains filtered or unexported fields
}
FileSource represents an inbound connector that reads items from a file.
func NewFileSource ¶
func NewFileSource(fileName string) *FileSource
NewFileSource returns a new FileSource instance.
func (*FileSource) Out ¶
func (fs *FileSource) Out() <-chan interface{}
Out returns an output channel for sending data.
type IgnoreSink ¶
type IgnoreSink struct {
// contains filtered or unexported fields
}
IgnoreSink represents a simple outbound connector that discards all of the incoming items.
func NewIgnoreSink ¶
func NewIgnoreSink() *IgnoreSink
NewIgnoreSink returns a new IgnoreSink instance.
func (*IgnoreSink) In ¶
func (ignore *IgnoreSink) In() chan<- interface{}
In returns an input channel for receiving data.
type NetSink ¶
type NetSink struct {
// contains filtered or unexported fields
}
NetSink represents an outbound network socket connector.
func NewNetSink ¶
NewNetSink returns a new instance of NetSink.
type NetSource ¶
type NetSource struct {
// contains filtered or unexported fields
}
NetSource represents an inbound network socket connector.
func NewNetSource ¶
NewNetSource returns a new instance of NetSource.
type StdoutSink ¶
type StdoutSink struct {
// contains filtered or unexported fields
}
StdoutSink represents a simple outbound connector that sends incoming items to standard output.
func NewStdoutSink ¶
func NewStdoutSink() *StdoutSink
NewStdoutSink returns a new StdoutSink instance.
func (*StdoutSink) In ¶
func (stdout *StdoutSink) In() chan<- interface{}
In returns an input channel for receiving data.
Source Files