Versions in this module Expand all Collapse all v0 v0.1.0 Aug 6, 2024 Changes in this version + var File_queue_rocketmq_conf_proto protoreflect.FileDescriptor + func MustNewQueue(c *Conf, handler ConsumeHandler) queue.MessageQueue + func NewLogger(core zapcore.Core) rlog.Logger + func NewQueue(c *Conf, handler ConsumeHandler) (queue.MessageQueue, error) + type Conf struct + AccessKey string + Addrs []string + Broadcast bool + Channel string + Conns int32 + Expression string + GroupId string + Namespace string + SecretKey string + Topic string + func (*Conf) Descriptor() ([]byte, []int) + func (*Conf) ProtoMessage() + func (m *Conf) Validate() error + func (m *Conf) ValidateAll() error + func (x *Conf) GetAccessKey() string + func (x *Conf) GetAddrs() []string + func (x *Conf) GetBroadcast() bool + func (x *Conf) GetChannel() string + func (x *Conf) GetConns() int32 + func (x *Conf) GetExpression() string + func (x *Conf) GetGroupId() string + func (x *Conf) GetNamespace() string + func (x *Conf) GetSecretKey() string + func (x *Conf) GetTopic() string + func (x *Conf) ProtoReflect() protoreflect.Message + func (x *Conf) Reset() + func (x *Conf) String() string + type ConfMultiError []error + func (m ConfMultiError) AllErrors() []error + func (m ConfMultiError) Error() string + type ConfValidationError struct + func (e ConfValidationError) Cause() error + func (e ConfValidationError) Error() string + func (e ConfValidationError) ErrorName() string + func (e ConfValidationError) Field() string + func (e ConfValidationError) Key() bool + func (e ConfValidationError) Reason() string + type ConsumeHandle func(ctx context.Context, topic string, key, message []byte) error + type ConsumeHandler interface + Consume func(ctx context.Context, topic string, key, message []byte) error + type MessageExtTextMapCarrier struct + func (carrier *MessageExtTextMapCarrier) Get(key string) string + func (carrier *MessageExtTextMapCarrier) Keys() []string + func (carrier *MessageExtTextMapCarrier) Set(key string, value string) + type MessageTextMapCarrier struct + func (carrier *MessageTextMapCarrier) Get(key string) string + func (carrier *MessageTextMapCarrier) Keys() []string + func (carrier *MessageTextMapCarrier) Set(key string, value string) + type Pusher interface + Close func() error + Name func() string + Push func(ctx context.Context, topic string, key, value []byte) error + func MustNewPusher(c *Conf) Pusher + func NewPusher(config *Conf) (Pusher, error) + type RocketLogger struct + func (l *RocketLogger) Level(level string) + func (l RocketLogger) Debug(msg string, fields map[string]interface{}) + func (l RocketLogger) Enabled(lvl zapcore.Level) bool + func (l RocketLogger) Error(msg string, fields map[string]interface{}) + func (l RocketLogger) Fatal(msg string, fields map[string]interface{}) + func (l RocketLogger) Info(msg string, fields map[string]interface{}) + func (l RocketLogger) OutputPath(path string) (err error) + func (l RocketLogger) Warning(msg string, fields map[string]interface{})
Go to main page