Documentation
¶
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 transmitts data to chan
func NewChanSink ¶
func NewChanSink(out chan interface{}) *ChanSink
NewChanSink returns new ChanSink instance
type FileSink ¶
type FileSink struct {
// contains filtered or unexported fields
}
FileSink stores items to file
func NewFileSink ¶
NewFileSink returns new FileSink instance
type NetSink ¶
type NetSink struct {
// contains filtered or unexported fields
}
NetSink downstreams input events to a network soket
func NewNetSink ¶
NewNetSink creates a new NetSink
type NothingSink ¶
type NothingSink struct {
// contains filtered or unexported fields
}
IgnoreSink sends items to /dev/null
func NewNothingSink ¶
func NewNothingSink() *NothingSink
NewIgnoreSink returns new IgnoreSink instance
func (*NothingSink) In ¶
func (n *NothingSink) In() chan<- interface{}
In returns channel for receiving data
type PulsarSink ¶
type PulsarSink struct {
// contains filtered or unexported fields
}
PulsarSink connector
func NewPulsarSink ¶
func NewPulsarSink(clientOptions *pulsar.ClientOptions, producerOptions *pulsar.ProducerOptions) *PulsarSink
NewPulsarSink creates a new PulsarSink
func (*PulsarSink) In ¶
func (ps *PulsarSink) In() chan<- interface{}
In returns channel for receiving data
type RedisSink ¶
type RedisSink struct {
// contains filtered or unexported fields
}
RedisSink implements Redis Pub/Sub Sink
func NewRedisSink ¶
NewRedisSink returns new RedisSink instance
type StdoutSink ¶
type StdoutSink struct {
// contains filtered or unexported fields
}
IgnoreSink sends items to /dev/null
func (*StdoutSink) In ¶
func (ignore *StdoutSink) In() chan<- interface{}
In returns channel for receiving data
Source Files
Click to show internal directories.
Click to hide internal directories.