cmd

Nov 21, 2017

Changes in this version

+ var RootCmd = &cobra.Command

+ func Execute(ver string)

+ func UnPack(file *os.File, messages chan Message) (n int, err error)

+ type FileInput struct

+ func NewFileInput(path string) *FileInput

+ func (f *FileInput) Send(messages chan Message)

+ type Message struct

+ Body []byte

+ Headers map[string]interface{}

+ RoutingKey string

+ func NewMessageFromAttrs(bytes []byte, attrs map[string]string) *Message

+ type Path struct

+ func NewFileOutput(path string, batchSize int) *Path

+ func (p *Path) Receive(messages chan Message)

+ type RabbitMQ struct

+ func NewRabbitMQ(amqpURI, exchange, queue, routingKey, tag string, prefetch int, ...) *RabbitMQ

+ func (r *RabbitMQ) Consume(out chan Message)

+ func (r *RabbitMQ) Publish(in chan Message)

+ type TarballBuilder struct

+ func NewTarballBuilder(tarSize int) *TarballBuilder

+ func (t *TarballBuilder) CloseWaiter(out chan []byte)

+ func (t *TarballBuilder) Pack(messages chan Message, dir string)