Documentation
¶
Index ¶
- Constants
- func MustNewPusher(c *queue.Conf) queue.Pusher
- func MustNewQueue(c *queue.Conf) queue.MessageQueue
- func NewLogger(core zapcore.Core) rlog.Logger
- func NewPusher(config *queue.Conf) (queue.Pusher, error)
- func NewQueue(c *queue.Conf) (queue.MessageQueue, error)
- type MessageExtTextMapCarrier
- type MessageTextMapCarrier
- type RocketLogger
- 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) Level(level string)
- func (l RocketLogger) OutputPath(path string) (err error)
- func (l RocketLogger) Warning(msg string, fields map[string]interface{})
Constants ¶
View Source
const Name = "rocketmq"
Name is the name registered for redis
Variables ¶
This section is empty.
Functions ¶
func MustNewQueue ¶
func MustNewQueue(c *queue.Conf) queue.MessageQueue
Types ¶
type MessageExtTextMapCarrier ¶
type MessageExtTextMapCarrier struct {
// contains filtered or unexported fields
}
func (*MessageExtTextMapCarrier) Get ¶
func (carrier *MessageExtTextMapCarrier) Get(key string) string
Get returns the value associated with the passed key.
func (*MessageExtTextMapCarrier) Keys ¶
func (carrier *MessageExtTextMapCarrier) Keys() []string
Keys lists the keys stored in this carrier.
func (*MessageExtTextMapCarrier) Set ¶
func (carrier *MessageExtTextMapCarrier) Set(key string, value string)
Set stores the key-value pair.
type MessageTextMapCarrier ¶
type MessageTextMapCarrier struct {
// contains filtered or unexported fields
}
func (*MessageTextMapCarrier) Get ¶
func (carrier *MessageTextMapCarrier) Get(key string) string
Get returns the value associated with the passed key.
func (*MessageTextMapCarrier) Keys ¶
func (carrier *MessageTextMapCarrier) Keys() []string
Keys lists the keys stored in this carrier.
func (*MessageTextMapCarrier) Set ¶
func (carrier *MessageTextMapCarrier) Set(key string, value string)
Set stores the key-value pair.
type RocketLogger ¶
type RocketLogger struct {
// contains filtered or unexported fields
}
func (RocketLogger) Debug ¶
func (l RocketLogger) Debug(msg string, fields map[string]interface{})
func (RocketLogger) Error ¶
func (l RocketLogger) Error(msg string, fields map[string]interface{})
func (RocketLogger) Fatal ¶
func (l RocketLogger) Fatal(msg string, fields map[string]interface{})
func (RocketLogger) Info ¶
func (l RocketLogger) Info(msg string, fields map[string]interface{})
func (*RocketLogger) Level ¶
func (l *RocketLogger) Level(level string)
func (RocketLogger) OutputPath ¶
func (l RocketLogger) OutputPath(path string) (err error)
func (RocketLogger) Warning ¶
func (l RocketLogger) Warning(msg string, fields map[string]interface{})
Source Files
Click to show internal directories.
Click to hide internal directories.