consumer

Documentation

Index

• type Config
• type Consumer
  • func NewDbConsumer(n uint64, batchSize uint64, consumerTimeout time.Duration, repo repo.EventRepo, ...) Consumer

Types

type Config

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

type Consumer

type Consumer interface {
	Start()
	Close()
}

func NewDbConsumer

func NewDbConsumer(
	n uint64,
	batchSize uint64,
	consumerTimeout time.Duration,
	repo repo.EventRepo,
	events chan<- model.ParcelEvent) Consumer