rabbitdriver

package
v0.1.4 Latest Latest
Warning

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

Go to latest
Published: Nov 23, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package rabbitdriver contains RabbitMQ driver for unifrost.StreamHandler

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

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

Client handles the subscriptions to rabbit amqp topics

func NewClient

func NewClient(ctx context.Context, rabbitConn *amqp.Connection, opts ...Option) (*Client, error)

NewClient returns *rabbitmq.Client, also creates a RabbitMQ broker subscription client.

Additional configuration options can be added with rabbitpubsub.Option functions.

func (*Client) Close

func (client *Client) Close(ctx context.Context) error

Close closes the connection to rabbit amqp server

func (*Client) Subscribe

func (client *Client) Subscribe(ctx context.Context, topic string) (*pubsub.Subscription, error)

Subscribe method subscribes to the rabbit amqp topic

type Option

type Option func(*Client) error

Option is a self-refrential function for configuration parameters

Jump to

Keyboard shortcuts

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