controller

Documentation

Index

• func Controller(cfg *config.Config, log *zap.Logger) error
• func ErrorHandler(errorChan <-chan error, cfg *config.Config, log *zap.Logger)
• func SetConcurrency(cfg *config.Config, log *zap.Logger) (int, error)

Functions

func Controller

func Controller(cfg *config.Config, log *zap.Logger) error

func ErrorHandler

func ErrorHandler(errorChan <-chan error, cfg *config.Config, log *zap.Logger)

ErrorHandler centralizes handling of certain errors that may occur during processing.

func SetConcurrency

func SetConcurrency(cfg *config.Config, log *zap.Logger) (int, error)

CalcMaxConcurrent checks if the MaxConcurrentZips is set in the config, if not it calculates an appropriate value