rocketmq

Documentation

Index

• Constants
• type QLoger
  • func (q *QLoger) Debug(msg string, fields map[string]interface{})
  • func (q *QLoger) Error(msg string, fields map[string]interface{})
  • func (q *QLoger) Fatal(msg string, fields map[string]interface{})
  • func (q *QLoger) Info(msg string, fields map[string]interface{})
  • func (q *QLoger) Level(level string)
  • func (q *QLoger) OutputPath(path string) (err error)
  • func (q *QLoger) Warning(msg string, fields map[string]interface{})
• type RocketConsumerOptions
• type RocketMQ
  • func NewRocketMQ(ctx context.Context, urls []string, credentials *primitive.Credentials, ...) (*RocketMQ, error)
  • func (r *RocketMQ) Consumer(ctx context.Context, topicName string, f queueLib.ConsumerFunc, ...)
  • func (r *RocketMQ) Publish(ctx context.Context, message messageLib.IMessage, ...) error
  • func (r *RocketMQ) RpcRequest(ctx context.Context, key string, data []byte, ...) ([]byte, error)
  • func (r *RocketMQ) Run(ctx context.Context)
  • func (r *RocketMQ) Shutdown(ctx context.Context)
  • func (r *RocketMQ) String() string
• type RocketProducerOptions

Constants

const (
	// PanicLevel level, highest level of severity. Logs and then calls panic with the
	// message passed to Debug, Info, ...
	PanicLevel = iota
	// FatalLevel level. Logs and then calls `logger.Exit(1)`. It will exit even if the
	// logging level is set to Panic.
	FatalLevel
	// ErrorLevel level. Logs. Used for errors that should definitely be noted.
	// Commonly used for hooks to send errors to an error tracking service.
	ErrorLevel
	// WarnLevel level. Non-critical entries that deserve eyes.
	WarnLevel
	// InfoLevel level. General operational entries about what's going on inside the
	// application.
	InfoLevel
	// DebugLevel level. Usually only enabled when debugging. Very verbose logging.
	DebugLevel
	// TraceLevel level. Designates finer-grained informational events than the Debug.
	TraceLevel
)

Types

type QLoger

type QLoger struct {
	Ctx    context.Context
	Logger *glog.Logger
}

func (*QLoger) Debug

func (q *QLoger) Debug(msg string, fields map[string]interface{})

func (*QLoger) Error

func (q *QLoger) Error(msg string, fields map[string]interface{})

func (*QLoger) Fatal

func (q *QLoger) Fatal(msg string, fields map[string]interface{})

func (*QLoger) Info

func (q *QLoger) Info(msg string, fields map[string]interface{})

func (*QLoger) Level

func (q *QLoger) Level(level string)

func (*QLoger) OutputPath

func (q *QLoger) OutputPath(path string) (err error)

func (*QLoger) Warning

func (q *QLoger) Warning(msg string, fields map[string]interface{})

type RocketConsumerOptions

type RocketConsumerOptions struct {
	GroupName         string
	MaxReconsumeTimes int32
}

type RocketMQ

type RocketMQ struct {
	Urls []string

	Credentials *primitive.Credentials
	// contains filtered or unexported fields
}

RocketMQ cache implement

func NewRocketMQ

func NewRocketMQ(
	ctx context.Context,
	urls []string,
	credentials *primitive.Credentials,
	logger *glog.Logger,
) (*RocketMQ, error)

func (*RocketMQ) Consumer

func (r *RocketMQ) Consumer(ctx context.Context, topicName string, f queueLib.ConsumerFunc, optionFuncs ...func(*queueLib.ConsumeOptions))

Consumer 监听消费者

func (*RocketMQ) Publish

func (r *RocketMQ) Publish(ctx context.Context, message messageLib.IMessage, optionFuncs ...func(*queueLib.PublishOptions)) error

Publish 消息入生产者

func (*RocketMQ) RpcRequest

func (r *RocketMQ) RpcRequest(ctx context.Context, key string, data []byte, optionFuncs ...func(*queueLib.ClientOptions)) ([]byte, error)

func (*RocketMQ) Run

func (r *RocketMQ) Run(ctx context.Context)

func (*RocketMQ) Shutdown

func (r *RocketMQ) Shutdown(ctx context.Context)

func (*RocketMQ) String

func (r *RocketMQ) String() string

type RocketProducerOptions

type RocketProducerOptions struct {
	GroupName  string
	RetryTimes int
}