rabbitmqpkg

README

rabbitmq

参考文档

• watermill-amqp
• go-kratos/example:event

Documentation

Index

• func NewLogger(handler log.Logger) watermill.LoggerAdapter
• func NewPublisher(conf *Config, opts ...Option) (*amqp.Publisher, error)
• func NewPublisherAndSubscriber(conf *Config, opts ...Option) (publisher message.Publisher, subscriber message.Subscriber, err error)
• func NewPublisherAndSubscriberWithConnection(conn *ConnectionWrapper, opts ...Option) (publisher message.Publisher, subscriber message.Subscriber, err error)
• func NewPublisherWithConnection(conn *ConnectionWrapper, opts ...Option) (*amqp.Publisher, error)
• func NewSubscriber(conf *Config, opts ...Option) (*amqp.Subscriber, error)
• func NewSubscriberWithConnection(conn *ConnectionWrapper, opts ...Option) (*amqp.Subscriber, error)
• type Config
• type ConnectionWrapper
  • func NewConnection(conf *Config, opts ...Option) (*ConnectionWrapper, error)
• type Option
  • func WithKratosLogger(logger log.Logger) Option
  • func WithLogger(logger watermill.LoggerAdapter) Option
  • func WithNonDurable() Option
  • func WithTLSConfig(tlsConfig *tls.Config) Option

Functions

func NewLogger

func NewLogger(handler log.Logger) watermill.LoggerAdapter

NewLogger ...

func NewPublisher

func NewPublisher(conf *Config, opts ...Option) (*amqp.Publisher, error)

NewPublisher 发布者 注意：Close 同步调用了 conn.Close

func NewPublisherAndSubscriber

func NewPublisherAndSubscriber(conf *Config, opts ...Option) (publisher message.Publisher, subscriber message.Subscriber, err error)

NewPublisherAndSubscriber 发布订阅 注意：Close 同步调用了 conn.Close

func NewPublisherAndSubscriberWithConnection

func NewPublisherAndSubscriberWithConnection(conn *ConnectionWrapper, opts ...Option) (publisher message.Publisher, subscriber message.Subscriber, err error)

NewPublisherAndSubscriberWithConnection 发布订阅 注意：Close 同步调用了 conn.Close

func NewPublisherWithConnection

func NewPublisherWithConnection(conn *ConnectionWrapper, opts ...Option) (*amqp.Publisher, error)

NewPublisherWithConnection 发布者 注意：Close 同步调用了 conn.Close

func NewSubscriber

func NewSubscriber(conf *Config, opts ...Option) (*amqp.Subscriber, error)

NewSubscriber 订阅者 注意：Close 同步调用了 conn.Close

func NewSubscriberWithConnection

func NewSubscriberWithConnection(conn *ConnectionWrapper, opts ...Option) (*amqp.Subscriber, error)

NewSubscriberWithConnection 发布者 注意：Close 同步调用了 conn.Close

Types

type Config

type Config struct {
	Url        string
	TlsAddress string
	TlsCaPem   string
	TlsCertPem string
	TlsKeyPem  string
}

Config rabbitmq config

type ConnectionWrapper

type ConnectionWrapper struct {
	*amqp.ConnectionWrapper
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(conf *Config, opts ...Option) (*ConnectionWrapper, error)

NewConnection 链接 已默认支持重连机制： amqp.DefaultReconnectConfig

type Option

type Option func(*options)

Option is config option.

func WithKratosLogger

func WithKratosLogger(logger log.Logger) Option

func WithLogger

func WithLogger(logger watermill.LoggerAdapter) Option

WithLogger 日志

func WithNonDurable

func WithNonDurable() Option

func WithTLSConfig

func WithTLSConfig(tlsConfig *tls.Config) Option

WithTLSConfig tls