Versions in this module Expand all Collapse all v0 v0.1.0 Sep 28, 2021 Changes in this version + type Config struct + Addresses []string + Consumer *ConsumerConfig + Producer *ProducerConfig + func DefaultConfig() Config + func RawConfig(key string) Config + type ConsumerConfig struct + AccessKey string + Addr []string + Capacity int64 + DialTimeout time.Duration + Enable bool + Group string + Name string + Rate float64 + Reconsume int32 + RwTimeout time.Duration + SecretKey string + Shadow Shadow + SubExpression string + Topic string + WaitMaxDuration time.Duration + func DefaultConsumerConfig() ConsumerConfig + func RawConsumerConfig(key string) ConsumerConfig + func StdPushConsumerConfig(name string) *ConsumerConfig + func (conf *ConsumerConfig) Build() *PushConsumer + type FlowInfo struct + Addr []string + Group string + GroupType string + Name string + Topic string + type Producer struct + func GetProducer(name string) *Producer + func InvokerProducer(name string) *Producer + func StdNewProducer(name string) *Producer + func (pc *Producer) Close() error + func (pc *Producer) Send(msg []byte) error + func (pc *Producer) SendMsg(msg *primitive.Message) (*primitive.SendResult, error) + func (pc *Producer) SendWithContext(ctx context.Context, msg []byte) error + func (pc *Producer) SendWithResult(msg []byte, tag string) (*primitive.SendResult, error) + func (pc *Producer) SendWithTag(msg []byte, tag string) error + func (pc *Producer) Start() error + func (pc *Producer) WithInterceptor(fs ...primitive.Interceptor) *Producer + type ProducerConfig struct + AccessKey string + Addr []string + DialTimeout time.Duration + Group string + Name string + Retry int + RwTimeout time.Duration + SecretKey string + Shadow Shadow + Topic string + func DefaultProducerConfig() ProducerConfig + func RawProducerConfig(key string) ProducerConfig + func StdProducerConfig(name string) *ProducerConfig + func (conf *ProducerConfig) Build() *Producer + type PushConsumer struct + func GetConsumer(name string) *PushConsumer + func (cc *PushConsumer) Close() error + func (cc *PushConsumer) Start() error + func (cc *PushConsumer) Subscribe(topic string, f func(context.Context, *primitive.MessageExt) error) *PushConsumer + func (cc *PushConsumer) WithInterceptor(fs ...primitive.Interceptor) *PushConsumer + type Shadow struct + Mode string + WitheTopics []string
Go to main page