rabbitmq

Documentation

Index

• Constants
• func New(dsn string, opts ...Option) checker.Checker
• type Option
  • func WithInsecureSkipTLSVerify(insecureSkipTLSVerify bool) Option
  • func WithTimeout(timeout time.Duration) Option
• type RabbitMQ
  • func (r *RabbitMQ) Check(ctx context.Context) (err error)
  • func (r RabbitMQ) Identity() (string, error)

Constants

const (
	// DefaultHeartbeat is the default heartbeat duration
	DefaultHeartbeat = 10 * time.Second
	// DefaultConnectionTimeout is the default connection timeout duration
	DefaultConnectionTimeout = 3 * time.Second
	// DefaultLocale is the default connection locale
	DefaultLocale = "en_US"
	// DefaultInsecureSkipTLSVerify is the default insecure skip tls verify
	DefaultInsecureSkipTLSVerify = false
)

Functions

func New

func New(dsn string, opts ...Option) checker.Checker

New creates the RabbitMQ checker

Types

type Option

type Option func(r *RabbitMQ)

Option configures a RabbitMQ.

func WithInsecureSkipTLSVerify

func WithInsecureSkipTLSVerify(insecureSkipTLSVerify bool) Option

WithInsecureSkipTLSVerify controls whether a client verifies the server's certificate chain and hostname

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout configures a timeout for maximum amount of time a dial will wait for a connection to complete

type RabbitMQ

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

RabbitMQ represents RabbitMQ checker

func (*RabbitMQ) Check

func (r *RabbitMQ) Check(ctx context.Context) (err error)

Check checks RabbitMQ connection

func (RabbitMQ) Identity

func (r RabbitMQ) Identity() (string, error)

Identity returns the identity of the checker