Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProducerMessage ¶
func NewProducerMessage() *pulsar.ProducerMessage
Types ¶
type Config ¶
type Config struct { ClientOptions pulsar.ClientOptions ConsumerOptions pulsar.ConsumerOptions ProducerOptions pulsar.ProducerOptions }
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
func (*Producer) DeferredEnqueue ¶
func (*Producer) EnqueueMessage ¶
func (this *Producer) EnqueueMessage(m *pulsar.ProducerMessage) error
func (*Producer) MultiEnqueue ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) MultiEnqueue ¶
Click to show internal directories.
Click to hide internal directories.