saramaframe

Documentation

Index

• Constants
• func WrapasyncProducerInput(p *asyncProducer) chan<- *sarama.ProducerMessage
• func WrappartitionConsumerMessages(child *partitionConsumer) <-chan *sarama.ConsumerMessage
• func WrapsyncProducerSendMessage(sp *syncProducer, msg *sarama.ProducerMessage) (partition int32, offset int64, err error)
• func WrapsyncProducerSendMessages(sp *syncProducer, msgs []*sarama.ProducerMessage) (err error)

Constants

const (
	SaramaProducerIndexContext = tingyun3.StorageMQKafka + 0
	SaramaConsumerIndexContext = tingyun3.StorageMQKafka + 1
	SaramaConsumerIndexStore   = tingyun3.StorageMQKafka + 2
)

Functions

func WrapasyncProducerInput

func WrapasyncProducerInput(p *asyncProducer) chan<- *sarama.ProducerMessage

func WrappartitionConsumerMessages

func WrappartitionConsumerMessages(child *partitionConsumer) <-chan *sarama.ConsumerMessage

func WrapsyncProducerSendMessage

func WrapsyncProducerSendMessage(sp *syncProducer, msg *sarama.ProducerMessage) (partition int32, offset int64, err error)

func WrapsyncProducerSendMessages

func WrapsyncProducerSendMessages(sp *syncProducer, msgs []*sarama.ProducerMessage) (err error)