gomq

package module
v0.0.0-...-3a05c0e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 16, 2018 License: MIT Imports: 11 Imported by: 0

README

gomq-kafka

gomq kafka bind

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) Close

func (consumer *AliyunConsumer) Close()

Close .

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 .

func (*AliyunProducer) Produce

func (producer *AliyunProducer) Produce(topic string, key []byte, content interface{}) error

Produce produce new kafka message

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL