The highest tagged major version is v3.

brokers

package

v2.2.1 Latest Latest Go to latest Published: Oct 27, 2020 License: GPL-3.0 Imports: 6 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gojuukaze/YTask

Links

Open Source Insights

Documentation ¶

Index ¶

type BrokerInterface
type RabbitMqBroker
- func NewRabbitMqBroker(host, port, user, password, vhost string) RabbitMqBroker
type RedisBroker
- func NewRedisBroker(host string, port string, password string, db int, poolSize int) RedisBroker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BrokerInterface ¶

type BrokerInterface interface {
	Next(queueName string) (message.Message, error)
	Send(queueName string, msg message.Message) error
	LSend(queueName string, msg message.Message) error
	// 调用Activate后才真正建立连接
	Activate()
	SetPoolSize(int)
	GetPoolSize() int
	Clone() BrokerInterface
}

type RabbitMqBroker ¶ added in v2.1.4

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

func NewRabbitMqBroker ¶ added in v2.1.4

func NewRabbitMqBroker(host, port, user, password, vhost string) RabbitMqBroker

func (*RabbitMqBroker) Activate ¶ added in v2.1.4

func (r *RabbitMqBroker) Activate()

func (RabbitMqBroker) Clone ¶ added in v2.2.0

func (r RabbitMqBroker) Clone() BrokerInterface

func (*RabbitMqBroker) GetPoolSize ¶ added in v2.1.4

func (r *RabbitMqBroker) GetPoolSize() int

func (*RabbitMqBroker) LSend ¶ added in v2.2.0

func (r *RabbitMqBroker) LSend(queueName string, msg message.Message) error

func (*RabbitMqBroker) Next ¶ added in v2.1.4

func (r *RabbitMqBroker) Next(queueName string) (message.Message, error)

func (*RabbitMqBroker) Send ¶ added in v2.1.4

func (r *RabbitMqBroker) Send(queueName string, msg message.Message) error

func (*RabbitMqBroker) SetPoolSize ¶ added in v2.1.4

func (r *RabbitMqBroker) SetPoolSize(n int)

type RedisBroker ¶

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

func NewRedisBroker ¶

func NewRedisBroker(host string, port string, password string, db int, poolSize int) RedisBroker

func (*RedisBroker) Activate ¶

func (r *RedisBroker) Activate()

func (RedisBroker) Clone ¶ added in v2.2.0

func (r RedisBroker) Clone() BrokerInterface

func (*RedisBroker) GetPoolSize ¶

func (r *RedisBroker) GetPoolSize() int

func (*RedisBroker) LSend ¶ added in v2.2.0

func (r *RedisBroker) LSend(queueName string, msg message.Message) error

func (*RedisBroker) Next ¶

func (r *RedisBroker) Next(queueName string) (message.Message, error)

func (*RedisBroker) Send ¶

func (r *RedisBroker) Send(queueName string, msg message.Message) error

func (*RedisBroker) SetPoolSize ¶

func (r *RedisBroker) SetPoolSize(n int)

Source Files ¶

View all Source files

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