Documentation ¶
Index ¶
Constants ¶
View Source
const ( KAFKA = 1 ROCKET = 2 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncProducer ¶
type AsyncProducer interface { Send(ctx context.Context, topicName string, msg *Message) error Close() error }
AsyncProducer 异步生产接口
func NewAsyncProducer ¶
func NewAsyncProducer(broker int, conf Config) AsyncProducer
NewAsyncProducer 创建AsyncProducer
type CallbackHandler ¶
CallbackHandler 消费回调函数
type Config ¶
type Config struct { Broker string `toml:"broker"` Endpoints []string `toml:"endpoints"` AccessKey string `toml:"access_key"` SecretKey string `toml:"secret_key"` Instance string `toml:"instance"` Group string `toml:"group"` Topics []TopicConfig `toml:"topics"` }
Config 消息队列配置项
type Consumer ¶
type Consumer interface { Recv(topicName string, h CallbackHandler) error Start() error Close() error }
Consumer 消费接口
type GroupHandler ¶
type GroupHandler struct { TopicName string CallbackHandler CallbackHandler ConsumerGroup sarama.ConsumerGroup }
GroupHandler 回调封装 sarama约定
func (*GroupHandler) Cleanup ¶
func (*GroupHandler) Cleanup(sarama.ConsumerGroupSession) error
Cleanup ...
func (*GroupHandler) ConsumeClaim ¶
func (g *GroupHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim 回调函数执行
func (*GroupHandler) Setup ¶
func (*GroupHandler) Setup(sarama.ConsumerGroupSession) error
Setup ...
type KafkaAsyncProducer ¶
type KafkaAsyncProducer struct {
// contains filtered or unexported fields
}
KafkaAsyncProducer kafka异步生产者结构
func NewKafkaAsyncProducer ¶
func NewKafkaAsyncProducer(conf Config) (*KafkaAsyncProducer, error)
NewKafkaAsyncProducer 创建KafkaAsyncProducer
type KafkaConsumer ¶
type KafkaConsumer struct {
// contains filtered or unexported fields
}
KafkaConsumer kafka消费者结构
func NewKafkaConsumer ¶
func NewKafkaConsumer(conf *Config) (*KafkaConsumer, error)
NewKafkaConsumer 创建KafkaConsumer
func (*KafkaConsumer) Recv ¶
func (c *KafkaConsumer) Recv(name string, callback CallbackHandler) error
Recv 消费消息 设置回调函数
type KafkaEvent ¶
KafkaEvent kafka消息事件
type KafkaSyncProducer ¶
type KafkaSyncProducer struct {
// contains filtered or unexported fields
}
KafkaSyncProducer kafka同步生产者结构
func NewKafkaSyncProducer ¶
func NewKafkaSyncProducer(conf *Config) (*KafkaSyncProducer, error)
NewKafkaSyncProducer 创建KafkaSyncProducer
type SyncProducer ¶
type SyncProducer interface { Send(ctx context.Context, topicName string, msg *Message) error Close() error }
SyncProducer 同步生产接口
func NewSyncProducer ¶
func NewSyncProducer(broker int, conf *Config) SyncProducer
NewSyncProducer 创建SyncProducer
type TopicConfig ¶
TopicConfig topic配置
Click to show internal directories.
Click to hide internal directories.