rabbitmq

Documentation

Index

• func Read(c *cli.Context) error
• func Write(c *cli.Context) error
• type Options
• type RabbitMQ
  • func (r *RabbitMQ) Read() error
  • func (r *RabbitMQ) Write(value []byte) error
• type Reader

Functions

func Read

func Read(c *cli.Context) error

func Write

func Write(c *cli.Context) error

Types

type Options

type Options struct {
	Action              string
	Address             string
	ExchangeName        string
	RoutingKey          string
	QueueName           string
	QueueDurable        bool
	QueueAutoDelete     bool
	QueueExclusive      bool
	Follow              bool
	LineNumbers         bool
	OutputType          string
	Convert             string
	ProtobufDir         string
	ProtobufRootMessage string
	InputFile           string
	InputData           string
	InputType           string
}

type RabbitMQ

type RabbitMQ struct {
	Options *Options
	Channel *amqp.Channel
	MsgDesc *desc.MessageDescriptor
	// contains filtered or unexported fields
}

func (*RabbitMQ) Read

func (r *RabbitMQ) Read() error

func (*RabbitMQ) Write

func (r *RabbitMQ) Write(value []byte) error

type Reader

type Reader struct {
	Channel *amqp.Channel
}