rocketmq

package

v0.1.1 Latest Latest Go to latest Published: Mar 4, 2026 License: MIT Imports: 19 Imported by: 0

Details

View Source

const Name = "rocketmq"

Name is the name registered for redis

This section is empty.

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 struct {
	// contains filtered or unexported fields
}

func (carrier *MessageExtTextMapCarrier) Get(key string) string

Get returns the value associated with the passed key.

func (carrier *MessageExtTextMapCarrier) Keys() []string

Keys lists the keys stored in this carrier.

func (carrier *MessageExtTextMapCarrier) Set(key string, value string)

Set stores the key-value pair.

type MessageTextMapCarrier struct {
	// contains filtered or unexported fields
}

func (carrier *MessageTextMapCarrier) Get(key string) string

Get returns the value associated with the passed key.

func (carrier *MessageTextMapCarrier) Keys() []string

Keys lists the keys stored in this carrier.

func (carrier *MessageTextMapCarrier) Set(key string, value string)

Set stores the key-value pair.

type RocketLogger struct {
	// contains filtered or unexported fields
}

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{})