consumer

Documentation

Index

• type Conf
  • func FromEnv() Conf
• type Consumer

Types

type Conf

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

func FromEnv

func FromEnv() Conf

type Consumer

type Consumer interface {
	Shutdown() error
	Subscribe(topic string, callback func(ctx context.Context, msgs ...*mq.MessageExt) (int, error)) error
}