Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Amqpout ¶
type Amqpout struct { AmqpConnection *amqp.Connection AmqpChannel *amqp.Channel AmqpQueue amqp.Queue Terminal chan messages.Message // contains filtered or unexported fields }
func NewAmqpout ¶
func NewAmqpout() *Amqpout
type Fileout ¶
func NewFileout ¶
func NewFileout() *Fileout
type Hdfsout ¶
func NewHdfsout ¶
func NewHdfsout() *Hdfsout
type Httpout ¶
func NewHttpout ¶
func NewHttpout() *Httpout
type Nullout ¶
func NewNullout ¶
func NewNullout() *Nullout
Click to show internal directories.
Click to hide internal directories.