gomq

README

gomq

golang mq adapter library, current version support kafka

Documentation

Index

• type BatchMessage
• type Consumer
• type Message
• type Producer

Types

type BatchMessage

type BatchMessage struct {
	Topic   string
	Key     []byte
	Content interface{}
}

BatchMessage .

type Consumer

type Consumer interface {
	Close()
	Messages() <-chan Message
	Errors() <-chan error
	Commit(message Message)
}

Consumer mq consumer client

type Message

type Message interface {
	Key() []byte
	Topic() string
	Value() []byte
	Offset() int64
}

Message MQ message

type Producer

type Producer interface {
	Produce(topic string, key []byte, content interface{}) error
	Batch(messages []*BatchMessage) error
}

Producer mq producer client