queue

Documentation

Index

• func GetSender() messaging.MessageSender
• func ReturnSender(sender messaging.MessageSender)
• func SendMessage(ctx context.Context, msg *messaging.DoneMessage) error
• func SetBrokerList(broker string)
• func SetTopic(topicName string)
• type QueueMessageConsumer
  • func NewQueueMessageConsumer() (*QueueMessageConsumer, error)
  • func (q *QueueMessageConsumer) Close() error
  • func (q *QueueMessageConsumer) ConsumeDoneMessages(handler func(*messaging.DoneMessage) error) error
• type QueueMessageSender
  • func NewQueueMessageSender() (*QueueMessageSender, error)
  • func (q *QueueMessageSender) Close() error
  • func (q *QueueMessageSender) SendDoneMessage(ctx context.Context, done *messaging.DoneMessage) error

Functions

func GetSender

func GetSender() messaging.MessageSender

GetSender gets a sender from the pool

func ReturnSender

func ReturnSender(sender messaging.MessageSender)

ReturnSender returns a sender to the pool

func SendMessage

func SendMessage(ctx context.Context, msg *messaging.DoneMessage) error

SendMessage sends a message using a pooled sender

func SetBrokerList

func SetBrokerList(broker string)

SetBrokerList sets the Kafka broker address

func SetTopic

func SetTopic(topicName string)

SetTopic sets the Kafka topic name

Types

type QueueMessageConsumer

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

QueueMessageConsumer implements the MessageConsumer interface for consuming messages from Kafka

func NewQueueMessageConsumer

func NewQueueMessageConsumer() (*QueueMessageConsumer, error)

NewQueueMessageConsumer creates a new Kafka consumer

func (*QueueMessageConsumer) Close

func (q *QueueMessageConsumer) Close() error

Close closes the Kafka consumer

func (*QueueMessageConsumer) ConsumeDoneMessages

func (q *QueueMessageConsumer) ConsumeDoneMessages(handler func(*messaging.DoneMessage) error) error

ConsumeDoneMessages starts consuming DoneMessages from Kafka

type QueueMessageSender

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

QueueMessageSender implements the MessageSender interface for sending messages to Kafka

func NewQueueMessageSender

func NewQueueMessageSender() (*QueueMessageSender, error)

NewQueueMessageSender creates a new QueueMessageSender with an initialized Kafka producer

func (*QueueMessageSender) Close

func (q *QueueMessageSender) Close() error

Close closes the Kafka producer

func (*QueueMessageSender) SendDoneMessage

func (q *QueueMessageSender) SendDoneMessage(ctx context.Context, done *messaging.DoneMessage) error

SendDoneMessage sends the DoneMessage to the Kafka queue