Versions in this module Expand all Collapse all v0 v0.2.0 Jun 5, 2020 Changes in this version + type BeanstalkController struct + Client *beanstalk.Tube + Config *oldmonkv1.ListOptions + func NewBeanstalkClient(config *oldmonkv1.ListOptions) *BeanstalkController + func (b *BeanstalkController) GetCount() int32 + func (r *BeanstalkController) Close() error + type NatsController struct + Client *nats.Conn + Config *oldmonkv1.ListOptions + func NewNatsClient(config *oldmonkv1.ListOptions) *NatsController + func (r *NatsController) Close() error + func (r *NatsController) GetCount() int32 + type QueueFactory interface + Close func() error + GetCount func() int32 + func NewQueueConnection(queueType string, config *oldmonkv1.ListOptions) QueueFactory + type RabbitmqController struct + Channel *amqp.Channel + Config *oldmonkv1.ListOptions + func NewRabbitmqClient(config *oldmonkv1.ListOptions) *RabbitmqController + func (r *RabbitmqController) Close() error + func (r *RabbitmqController) GetCount() int32 + type SqsController struct + Client *sqs.SQS + Config *oldmonkv1.ListOptions + func NewSqsClient(config *oldmonkv1.ListOptions) *SqsController + func (r *SqsController) Close() error + func (r *SqsController) GetCount() int32 v0.2.0-rc1 Jun 5, 2020
Go to main page