kafka

Documentation

Index

• Constants
• func NewProductMessageProcessor(log logger.Logger, cfg *config.Config, v *validator.Validate, ...) *productMessageProcessor

Constants

const (
	PoolSize = 30
)

Functions

func NewProductMessageProcessor

func NewProductMessageProcessor(log logger.Logger, cfg *config.Config, v *validator.Validate, ps *service.ProductService, metrics *metrics.WriterServiceMetrics) *productMessageProcessor