mq

Documentation

Index

• type ConsumerHandlerImpl
  • func NewConsumerHandler(MysqlManager *dao.MysqlManagerImpl, MinioClient *minio.Client, ...) *ConsumerHandlerImpl
• type ConsumerManager
• type DLQConsumerManager
  • func NewDLQConsumerManager(conn *amqp.Connection, deadLetterExchange, Exchange string) *DLQConsumerManager
  • func (d *DLQConsumerManager) Consume(ctx context.Context, _ string, h *ConsumerHandlerImpl) error
• type PublisherManagerImpl
  • func NewPublisherManager(conn *amqp.Connection, exchange string) *PublisherManagerImpl
  • func (p *PublisherManagerImpl) Send(ctx context.Context, RoomId int64) error
• type SubscriberManagerImpl
  • func NewSubscriberManager(conn *amqp.Connection, exchange string, dlxExchange string) *SubscriberManagerImpl
  • func (s *SubscriberManagerImpl) Consume(ctx context.Context, _ string, h *ConsumerHandlerImpl) error
  • func (s *SubscriberManagerImpl) SubscribeCh() <-chan amqp.Delivery

Types

type ConsumerHandlerImpl

type ConsumerHandlerImpl struct {
	MysqlManager   *dao.MysqlManagerImpl
	MinioClient    *minio.Client
	SummaryManager *eino.BotManagerImpl
}

func NewConsumerHandler

func NewConsumerHandler(MysqlManager *dao.MysqlManagerImpl, MinioClient *minio.Client, SummaryManager *eino.BotManagerImpl) *ConsumerHandlerImpl

type ConsumerManager

type ConsumerManager interface {
	Consume(ctx context.Context, topic string, handler *ConsumerHandlerImpl) error
}

type DLQConsumerManager

type DLQConsumerManager struct {
	DeadLetterExchange string
	Exchange           string
	// contains filtered or unexported fields
}

func NewDLQConsumerManager

func NewDLQConsumerManager(conn *amqp.Connection, deadLetterExchange, Exchange string) *DLQConsumerManager

func (*DLQConsumerManager) Consume

func (d *DLQConsumerManager) Consume(ctx context.Context, _ string, h *ConsumerHandlerImpl) error

type PublisherManagerImpl

type PublisherManagerImpl struct {
	Exchange string
	// contains filtered or unexported fields
}

func NewPublisherManager

func NewPublisherManager(conn *amqp.Connection, exchange string) *PublisherManagerImpl

func (*PublisherManagerImpl) Send

func (p *PublisherManagerImpl) Send(ctx context.Context, RoomId int64) error

type SubscriberManagerImpl

type SubscriberManagerImpl struct {
	Exchange           string
	DeadLetterExchange string
	// contains filtered or unexported fields
}

func NewSubscriberManager

func NewSubscriberManager(conn *amqp.Connection, exchange string, dlxExchange string) *SubscriberManagerImpl

func (*SubscriberManagerImpl) Consume

func (s *SubscriberManagerImpl) Consume(ctx context.Context, _ string, h *ConsumerHandlerImpl) error

func (*SubscriberManagerImpl) SubscribeCh

func (s *SubscriberManagerImpl) SubscribeCh() <-chan amqp.Delivery