Versions in this module Expand all Collapse all v1 v1.1.0 Oct 25, 2019 Changes in this version + type AMQPHandler struct + func NewAMQPHandler(source string) *AMQPHandler + func (a *AMQPHandler) Collect(ch chan<- prometheus.Metric) + func (a *AMQPHandler) Describe(ch chan<- *prometheus.Desc) + func (a *AMQPHandler) GetTotalMsgProcessed() int + func (a *AMQPHandler) GetTotalMsgRcv() int + func (a *AMQPHandler) GetTotalReconnectCount() int + func (a *AMQPHandler) IncTotalMsgProcessed() + func (a *AMQPHandler) IncTotalMsgRcv() + func (a *AMQPHandler) IncTotalReconnectCount() + type AMQPSender struct + func NewAMQPSender(urlStr string, debug bool) *AMQPSender + func (as *AMQPSender) Close() + func (as *AMQPSender) GetAckChannel() chan electron.Outcome + func (as *AMQPSender) Send(jsonmsg string) + type AMQPServer struct + func NewAMQPServer(urlStr string, debug bool, msgcount int, prefetch int, ...) *AMQPServer + func (s *AMQPServer) Close() + func (s *AMQPServer) GetDoneChan() chan bool + func (s *AMQPServer) GetHandler() *AMQPHandler + func (s *AMQPServer) GetNotifier() chan string + func (s *AMQPServer) GetStatus() chan int + func (s *AMQPServer) UpdateMinCollectInterval(interval float64) Incompatible versions in this module v2.0.0+incompatible Jul 10, 2020 v2.0.0-beta1+incompatible Mar 10, 2020
Go to main page