rabbitmq

package

v0.0.0-...-92f7cd3 Latest Latest Go to latest Published: Jun 2, 2020 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Kalinin-Andrey/otus-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Client
- func NewClient(ctx context.Context, logger log.ILogger, conf config.RabbitMQ, clientType uint) (*Client, error)
type QueueClient

Constants ¶

View Source

const (
	// TypePublisher const is value of type for a publisher
	TypePublisher = 0
	// TypeConsumer const is value of type for a consumer
	TypeConsumer = 1
)

Variables ¶

View Source

var DefaultTimeout time.Duration = 30 * time.Second

DefaultTimeout is the default timeout for connection

Functions ¶

This section is empty.

Types ¶

type Client ¶

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

Client for RabbitMQ

func NewClient ¶

func NewClient(ctx context.Context, logger log.ILogger, conf config.RabbitMQ, clientType uint) (*Client, error)

NewClient returns a new instance of the Client

func (*Client) Close ¶

func (c *Client) Close() error

Close a Client obj

func (*Client) ConnectLoop ¶

func (c *Client) ConnectLoop(timeout *time.Duration) (err error)

ConnectLoop is the func for connection in a loop with timeout

func (*Client) Handle ¶

func (c *Client) Handle(fn func(<-chan amqp.Delivery), threads int) error

Handle queue

func (*Client) Publish ¶

func (c *Client) Publish(body []byte) error

Publish in queue

type QueueClient ¶

type QueueClient interface {
	Publish(body []byte) error
	Handle(fn func(<-chan amqp.Delivery), threads int) error
	Close() error
}

QueueClient interface

Source Files ¶

View all Source files

client.go

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