quota

var (
	MemoryLimitHumanReadableDefault = os.Getenv(MemoryLimitEnvFieldName)
	CpuSecondsLimitHumanReadable    = os.Getenv(ProcessLimitEnvFieldName)
)

var Component = &app.Component{
	Dependencies: app.Components{
		logger.Component,
		configurator.Component,
		reConfiguration.Component,
		repeater.Component,
	},
	Constructor: app.Constructor(func(container container.Container) error {
		return container.Provides(
			NewMetric,
			NewConfig,
			NewReConfigurationWithConfigurator,
			func(reConfiguration *ReConfiguration) Quota {
				return reConfiguration
			},
		)
	}),
	BindFlags: app.BindFlags(func(flagSet *pflag.FlagSet, container container.Container) error {
		return container.Invoke(func(config *Config) {
			flagSet.StringVar(&config.MemoryLimitHumanReadable, MemoryLimitHumanReadableFieldName, MemoryLimitHumanReadableDefault, "memory limit")
			flagSet.StringVar(&config.CpuSecondsLimitHumanReadable, CpuSecondsLimitHumanReadableFieldName, CpuSecondsLimitHumanReadable, "cpu limit")
			flagSet.DurationVar(&config.Delay, DelayFieldName, DelayDefault, "quota update interval")
		})
	}),
	Run: app.Run(func(container container.Container) error {
		return container.Invoke(func(
			logger logger.Logger,
			quota *ReConfiguration,
			reConfiguration reConfiguration.ReConfiguration,
			config *Config,
			configurator configurator.Configurator,
			r repeater.Repeater,
			closer closer.Closer,
		) error {
			reConfiguration.Registration(quota)
			logger.Info("quota: registration in the reConfigurator")

			r.AddProcess("quota", config.Delay, quota.Process)

			return nil
		})
	}),
}