_rabbitmq

Documentation

Index

• func ParseRabbiMQMgmtUrl(dsn string) (*rabbithole.Client, error)
• type RabbitMQPS
  • func NewRabbitMQPS() *RabbitMQPS
  • func (this *RabbitMQPS) EnableMgmtUrlFlag() *RabbitMQPS
  • func (this *RabbitMQPS) GetInstance() *amqp.Connection
  • func (this *RabbitMQPS) GetMgmtInstance() *rabbithole.Client
  • func (this *RabbitMQPS) HandleCommand(cmd *cli.Command) error
  • func (this *RabbitMQPS) HandleContext(cCtx *cli.Context) error
  • func (this *RabbitMQPS) SetCategory(category string) *RabbitMQPS
  • func (this *RabbitMQPS) SetPrefix(prefix string) *RabbitMQPS

Functions

func ParseRabbiMQMgmtUrl

func ParseRabbiMQMgmtUrl(dsn string) (*rabbithole.Client, error)

Types

type RabbitMQPS

type RabbitMQPS struct {
	RabbitMQUrl helpers.FlagHelper

	RabbitMQMgmtUrl helpers.FlagHelper
	// contains filtered or unexported fields
}

func NewRabbitMQPS

func NewRabbitMQPS() *RabbitMQPS

func (*RabbitMQPS) EnableMgmtUrlFlag

func (this *RabbitMQPS) EnableMgmtUrlFlag() *RabbitMQPS

func (*RabbitMQPS) GetInstance

func (this *RabbitMQPS) GetInstance() *amqp.Connection

func (*RabbitMQPS) GetMgmtInstance

func (this *RabbitMQPS) GetMgmtInstance() *rabbithole.Client

func (*RabbitMQPS) HandleCommand

func (this *RabbitMQPS) HandleCommand(cmd *cli.Command) error

func (*RabbitMQPS) HandleContext

func (this *RabbitMQPS) HandleContext(cCtx *cli.Context) error

func (*RabbitMQPS) SetCategory

func (this *RabbitMQPS) SetCategory(category string) *RabbitMQPS

func (*RabbitMQPS) SetPrefix

func (this *RabbitMQPS) SetPrefix(prefix string) *RabbitMQPS