Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AliyunConsumer ¶
type AliyunConsumer struct {
// contains filtered or unexported fields
}
AliyunConsumer .
func NewAliyunConsumer ¶
func NewAliyunConsumer(cnf *config.Config) (*AliyunConsumer, error)
NewAliyunConsumer create new aliyun mq consumer
func (*AliyunConsumer) Commit ¶
func (consumer *AliyunConsumer) Commit(message mq.Message)
Commit commit current handle message as consumed
func (*AliyunConsumer) Errors ¶
func (consumer *AliyunConsumer) Errors() <-chan error
Errors return error chan
func (*AliyunConsumer) Messages ¶
func (consumer *AliyunConsumer) Messages() <-chan mq.Message
Messages return message chan
type AliyunProducer ¶
type AliyunProducer struct {
// contains filtered or unexported fields
}
AliyunProducer aliyun mq client using kafka protocol
func NewAliyunProducer ¶
func NewAliyunProducer(cnf *config.Config) (*AliyunProducer, error)
NewAliyunProducer create new aliyun mq client
func (*AliyunProducer) Batch ¶
func (producer *AliyunProducer) Batch(messages []*mq.BatchMessage) error
Batch .
Click to show internal directories.
Click to hide internal directories.