postprocessingqueue

Documentation

Index

• func NewConsumer(cfg *config.Config, coverageManager core.CoverageManager, ...) core.QueueConsumer
• func NewProducer(cfg *config.Config, logger lumber.Logger) core.QueueProducer

Functions

func NewConsumer

func NewConsumer(cfg *config.Config,
	coverageManager core.CoverageManager,
	runner core.K8sRunner,
	logger lumber.Logger) core.QueueConsumer

NewConsumer return a new taskqueue consumer.

func NewProducer

func NewProducer(cfg *config.Config,
	logger lumber.Logger) core.QueueProducer

NewProducer return a new post processing queue producer.