amqp10

Documentation

Index

• func SpawnQpidStatusReporter(wg *sync.WaitGroup, applicationHealth *cacheutil.ApplicationHealthCache, ...)
• func SpawnSignalHandler(finish chan bool, watchedSignals ...os.Signal)
• 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)
• type AMQPServerItem
  • func CreateMessageLoopComponents(config interface{}, finish chan bool, amqpHandler *AMQPHandler, ...) ([]reflect.SelectCase, []reflect.SelectCase, []AMQPServerItem)

Functions

func SpawnQpidStatusReporter

func SpawnQpidStatusReporter(wg *sync.WaitGroup, applicationHealth *cacheutil.ApplicationHealthCache, qpidStatusCases []reflect.SelectCase)

SpawnQpidStatusReporter builds dynamic select for reporting status of AMQP connections

func SpawnSignalHandler

func SpawnSignalHandler(finish chan bool, watchedSignals ...os.Signal)

SpawnSignalHandler spawns goroutine which will wait for interruption signal(s) and end smart gateway in case any of the signal is received

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 ...

type AMQPServerItem

type AMQPServerItem struct {
	Server     *AMQPServer
	DataSource saconfig.DataSource
}

AMQPServerItem hold information about data source which is AMQPServer listening to.

func CreateMessageLoopComponents

func CreateMessageLoopComponents(config interface{}, finish chan bool, amqpHandler *AMQPHandler, uniqueName string) ([]reflect.SelectCase, []reflect.SelectCase, []AMQPServerItem)

CreateMessageLoopComponents creates signal select cases for configured AMQP1.0 connections and connects to all of thos