clients

package
v0.0.0-...-a3e3982 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 18, 2020 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientRabbitMQ

type ClientRabbitMQ struct {
	// contains filtered or unexported fields
}

ClientRabbitMQ Operate Wrapper

func (*ClientRabbitMQ) BindQueue

func (r *ClientRabbitMQ) BindQueue(queue, exchange string, keys []string, nowait bool) (err error)

func (*ClientRabbitMQ) Close

func (r *ClientRabbitMQ) Close() (err error)

func (*ClientRabbitMQ) Connect

func (r *ClientRabbitMQ) Connect() (err error)

func (*ClientRabbitMQ) ConsumeQueue

func (r *ClientRabbitMQ) ConsumeQueue(queue string, message chan []byte) (err error)

func (*ClientRabbitMQ) DeclareExchange

func (r *ClientRabbitMQ) DeclareExchange(name, typ string, durable, autoDelete, nowait bool) (err error)

func (*ClientRabbitMQ) DeclareQueue

func (r *ClientRabbitMQ) DeclareQueue(name string, durable, autoDelete, exclusive, nowait bool) (err error)

func (*ClientRabbitMQ) DeleteExchange

func (r *ClientRabbitMQ) DeleteExchange(name string) (err error)

func (*ClientRabbitMQ) DeleteQueue

func (r *ClientRabbitMQ) DeleteQueue(name string) (err error)

func (*ClientRabbitMQ) Publish

func (r *ClientRabbitMQ) Publish(exchange, key string, deliveryMode, priority uint8, body string) (err error)

func (*ClientRabbitMQ) UnBindQueue

func (r *ClientRabbitMQ) UnBindQueue(queue, exchange string, keys []string) (err error)

type ExchangeEntity

type ExchangeEntity struct {
	Name       string `json:"name"`
	Type       string `json:"type"`
	Durable    bool   `json:"durable"`
	AutoDelete bool   `json:"autoDelete"`
	NoWait     bool   `json:"nowait"`
}

type MessageEntity

type MessageEntity struct {
	Exchange     string `json:"exchange"`
	Key          string `json:"key"`
	DeliveryMode uint8  `json:"deliveryMode"`
	Priority     uint8  `json:"priority"`
	Body         string `json:"body"`
}

Entity for HTTP Request Body: Message/Exchange/Queue/QueueBind JSON Input

type QueueBindEntity

type QueueBindEntity struct {
	Queue    string   `json:"queue"`
	Exchange string   `json:"exchange"`
	NoWait   bool     `json:"nowait"`
	Keys     []string `json:"keys"` // bind/routing keys
}

type QueueEntity

type QueueEntity struct {
	Name       string `json:"name"`
	Durable    bool   `json:"durable"`
	AutoDelete bool   `json:"autoDelete"`
	Exclusive  bool   `json:"exclusive"`
	NoWait     bool   `json:"nowait"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL