messagequeues

package
v0.0.0-...-7cbc1ea Latest Latest
Warning

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

Go to latest
Published: May 17, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeActivemqQuery

func MakeActivemqQuery(mq *MsgQueue) service.ServiceCheck

func MakeAwsMqQuery

func MakeAwsMqQuery(mq *MsgQueue) service.ServiceCheck

func MakeRabbitmqQuery

func MakeRabbitmqQuery(mq *MsgQueue) service.ServiceCheck

Types

type MsgQueue

type MsgQueue struct {
	Type     string `json:"type"`
	Name     string `json:"name"`
	Username string `json:"username"`
	Password string `json:"password"`
	Addrs    string `json:"addrs"`
	Timeout  uint   `json:"timeout"`
	UriOnly  string `json:"uri_only"` // when db credentials are already preconfigured to a single address/URL
}

func (*MsgQueue) AwsMqDsn

func (mq *MsgQueue) AwsMqDsn() string

func (*MsgQueue) GetMqDriver

func (mq *MsgQueue) GetMqDriver() service.ServiceCheck

func (*MsgQueue) GetOrSetConnTimeout

func (mq *MsgQueue) GetOrSetConnTimeout() time.Duration

func (*MsgQueue) RabbitmqDsn

func (mq *MsgQueue) RabbitmqDsn() string

func (*MsgQueue) Uri_Only

func (mq *MsgQueue) Uri_Only() bool

Jump to

Keyboard shortcuts

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