consumer

Documentation

Index

• type Consumer
  • func New(cfg config.Consumer, opts ...Option) (*Consumer, error)
  • func (c *Consumer) Close()
  • func (c *Consumer) Register(cb callback.Callback)
  • func (c *Consumer) Run(ctx context.Context)
• type Option
  • func Register(cb callback.Callback) Option
  • func WaitGroup(wg *sync.WaitGroup) Option

Types

type Consumer

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

func New

func New(cfg config.Consumer, opts ...Option) (*Consumer, error)

func (*Consumer) Close

func (c *Consumer) Close()

func (*Consumer) Register

func (c *Consumer) Register(cb callback.Callback)

func (*Consumer) Run

func (c *Consumer) Run(ctx context.Context)

type Option

type Option func(*Consumer)

func Register

func Register(cb callback.Callback) Option

func WaitGroup

func WaitGroup(wg *sync.WaitGroup) Option