amqp10

Documentation

Index

• type AMQPHandler
  • 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
  • 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
  • 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)

Types

type AMQPHandler

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

AMQPHandler ...

func NewAMQPHandler

func NewAMQPHandler(source string) *AMQPHandler

NewAMQPHandler ...

func (*AMQPHandler) Collect

func (a *AMQPHandler) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*AMQPHandler) Describe

func (a *AMQPHandler) Describe(ch chan<- *prometheus.Desc)

Describe ...

func (*AMQPHandler) GetTotalMsgProcessed

func (a *AMQPHandler) GetTotalMsgProcessed() int

GetTotalMsgProcessed ...

func (*AMQPHandler) GetTotalMsgRcv

func (a *AMQPHandler) GetTotalMsgRcv() int

GetTotalMsgRcv ...

func (*AMQPHandler) GetTotalReconnectCount

func (a *AMQPHandler) GetTotalReconnectCount() int

GetTotalReconnectCount ...

func (*AMQPHandler) IncTotalMsgProcessed

func (a *AMQPHandler) IncTotalMsgProcessed()

IncTotalMsgProcessed ...

func (*AMQPHandler) IncTotalMsgRcv

func (a *AMQPHandler) IncTotalMsgRcv()

IncTotalMsgRcv ...

func (*AMQPHandler) IncTotalReconnectCount

func (a *AMQPHandler) IncTotalReconnectCount()

IncTotalReconnectCount ...

type AMQPSender

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

AMQPSender msgcount -1 is infinite

func NewAMQPSender

func NewAMQPSender(urlStr string, debug bool) *AMQPSender

NewAMQPSender ...

func (*AMQPSender) Close

func (as *AMQPSender) Close()

Close connections it is exported so users can force close

func (*AMQPSender) GetAckChannel

func (as *AMQPSender) GetAckChannel() chan electron.Outcome

GetAckChannel returns electron.Outcome channel for receiving ACK when debug mode is turned on

func (*AMQPSender) Send

func (as *AMQPSender) Send(jsonmsg string)

Send starts amqp server

type AMQPServer

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

AMQPServer msgcount -1 is infinite

func NewAMQPServer

func NewAMQPServer(urlStr string, debug bool, msgcount int, prefetch int, amqpHanlder *AMQPHandler, uniqueName string) *AMQPServer

NewAMQPServer ...

func (*AMQPServer) Close

func (s *AMQPServer) Close()

Close connections it is exported so users can force close

func (*AMQPServer) GetDoneChan

func (s *AMQPServer) GetDoneChan() chan bool

GetDoneChan ...

func (*AMQPServer) GetHandler

func (s *AMQPServer) GetHandler() *AMQPHandler

GetHandler ...

func (*AMQPServer) GetNotifier

func (s *AMQPServer) GetNotifier() chan string

GetNotifier Get notifier

func (*AMQPServer) GetStatus

func (s *AMQPServer) GetStatus() chan int

GetStatus Get Status

func (*AMQPServer) UpdateMinCollectInterval

func (s *AMQPServer) UpdateMinCollectInterval(interval float64)

UpdateMinCollectInterval ...