producer

Documentation

Index

• type Conf
  • func FromEnv() Conf
• type Producer

Types

type Conf

type Conf struct {
	Type       string   `yaml:"type"`
	Addrs      []string `yaml:"addrs"`
	RetryTimes int      `yaml:"retry_times"`
	GroupName  string   `yaml:"group_name"`
}

func FromEnv

func FromEnv() Conf

type Producer

type Producer interface {
	SendSync(ctx context.Context, msg ...*mq.Message) (*mq.SendResult, error)
	SendAsync(ctx context.Context, callback func(ctx context.Context, result *mq.SendResult, err error), msgs ...*mq.Message) error
}