rabbitmqStreams

Documentation

Index

• Variables
• func NewClient(opts *cli.Options) (*stream.Environment, error)
• func Read(opts *cli.Options, md *desc.MessageDescriptor) error
• func Write(opts *cli.Options, md *desc.MessageDescriptor) error
• type RabbitMQStreams
  • func (r *RabbitMQStreams) Read() error
  • func (r *RabbitMQStreams) Write(value []byte) error

Variables

var (
	ErrMissingDeclareSize = errors.New("You must specify --declare-stream-size if you specify" +
		" the --declare-stream option")
)

Functions

func NewClient

func NewClient(opts *cli.Options) (*stream.Environment, error)

func Read

func Read(opts *cli.Options, md *desc.MessageDescriptor) error

func Write

func Write(opts *cli.Options, md *desc.MessageDescriptor) error

Types

type RabbitMQStreams

type RabbitMQStreams struct {
	Client   *stream.Environment
	Producer *stream.Producer
	Options  *cli.Options
	MsgDesc  *desc.MessageDescriptor
	// contains filtered or unexported fields
}

func (*RabbitMQStreams) Read

func (r *RabbitMQStreams) Read() error

func (*RabbitMQStreams) Write

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