config

type AssessmentSchedule struct {
	// Delay indicates the number of seconds to delay before assessing the status of the child resource to determine healthiness
	Delay time.Duration
	// End indicates the time delta from `Delay` that the assessment window has to be successful within
	End time.Duration
	// Period indicates the minimum window of time for which there must be consecutive success before we can declare
	// the resource successful
	Period time.Duration
	// Interval indicates how often to assess the child status once the first assessment has been performed and before the end
	Interval time.Duration
}

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

type DefaultAssessmentSchedule struct {
	Kind string `json:"kind" mapstructure:"kind"`

	// The Schedule variables defines time information used when assessing a child health status.
	// It is a string with 3 comma-separated integer values representing the following:
	// 1. AssessmentDelay: indicates the amount of seconds to delay before assessing the status of the child resource to determine healthiness
	// 2. AssessmentPeriod: indicates the amount of seconds to perform assessments for after the first assessment has been performed
	//    (if failure is indicated before that, it will not continue however)
	// 3. AssessmentInterval: indicates how often to assess the child status once the first assessment has been performed and before the end
	// of the assessments window defined by adding the AssessmentDelay seconds to the AssessmentPeriod seconds
	// NOTE: the order of the values is important since each value represents a specific amount of time
	// Example: "120,60,10" => delay assessment by 120s, assess for 60s, assess every 10s
	// 0 can be used for AssessmentDelay to mean no delay
	// 0 can be used for AssessmentPeriod to not require a period of time to wait before assessment
	// Don't use 0 for AssessmentInterval: if the result is initially "unknown", this value is still needed as a requeing time interval for checking
	Schedule string `json:"schedule" mapstructure:"schedule"`
}

type GlobalConfig struct {
	LogLevel          string `json:"logLevel" mapstructure:"logLevel"`
	IncludedResources string `json:"includedResources" mapstructure:"includedResources"`
	// List of Numaflow Controller image names to look for
	NumaflowControllerImageNames []string `json:"numaflowControllerImageNames" mapstructure:"numaflowControllerImageNames"`
	// If user's config doesn't exist or doesn't specify strategy, this is the default
	DefaultUpgradeStrategy USDEUserStrategy `json:"defaultUpgradeStrategy" mapstructure:"defaultUpgradeStrategy"`

	// Configuration related to the Progressive strategy
	Progressive ProgressiveConfig `json:"progressive" mapstructure:"progressive"`

	// Configuration specific to Pipeline Type
	Pipeline PipelineConfig `json:"pipeline" mapstructure:"pipeline"`

	// List of permitted Kinds for Riders
	PermittedRiders string `json:"permittedRiders" mapstructure:"permittedRiders"`

	// FeatureFlagDisableAnalysisRunsForPipeline is a temporary feature flag to turn off analysis runs for Pipeline type
	FeatureFlagDisableAnalysisRunsForPipeline bool `json:"featureFlagDisableAnalysisRunsForPipeline" mapstructure:"featureFlagDisableAnalysisRunsForPipeline"`
}

type NamespaceConfig struct {
	UpgradeStrategy USDEUserStrategy `json:"upgradeStrategy,omitempty" yaml:"upgradeStrategy,omitempty"`
}

type NumaflowControllerDefinitionConfig struct {
	ControllerDefinitions []apiv1.ControllerDefinitions `json:"controllerDefinitions" yaml:"controllerDefinitions"`
}

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

type Option func(*options)

type PipelineConfig struct {
	// RecycleScaleFactor is a percentage of Pipeline's original vertex scale that it will scale down by while it's being paused
	// before deleting.
	// Note that the Pipeline's pauseGracePeriodSeconds will be multiplied by the inverse fraction.
	// If not defined, default to 50
	RecycleScaleFactor *int32 `json:"recycleScaleFactor,omitempty"`

	// MaxRecyclableDurationMinutes is the period of time for which we will retry force draining a Pipeline, after it gets marked "Recyclable"
	MaxRecyclableDurationMinutes *int32 `json:"maxRecyclableDurationMinutes,omitempty"`

	// RecyclableStartTime is the time when the Pipeline was marked as recyclable
	// ForceDrainFailureWaitDuration is the duration to wait after a force drain failure before deleting.
	// If not defined, default to 15 seconds
	ForceDrainFailureWaitDuration *int32 `json:"forceDrainFailureWaitDuration,omitempty"`

	// KeepUndrainedPipelines controls whether pipelines that could not be drained are kept
	// after maxRecyclableDurationMinutes has elapsed rather than deleted.
	KeepUndrainedPipelines bool `json:"keepUndrainedPipelines"`
}

type ProgressiveConfig struct {
	// schedules for assessing upgrading child (one schedule per Kind)
	DefaultAssessmentSchedule []DefaultAssessmentSchedule `json:"defaultAssessmentSchedule" mapstructure:"defaultAssessmentSchedule"`

	// timeout duration which AnalysisRuns cannot continue to run after
	AnalysisRunTimeout string `json:"analysisRunTimeout" mapstructure:"analysisRunTimeout"`
}

type SpecField struct {
	Path             string `json:"path" yaml:"path"`
	IncludeSubfields bool   `json:"includeSubfields,omitempty" yaml:"includeSubfields,omitempty"`
}

type USDEConfig map[string]USDEResourceConfig

type USDEResourceConfig struct {
	// Recreate indicates fields that require the resource to be recreated upon modification.
	// For PPND strategy, this list is checked before the other two lists.
	Recreate []SpecField `json:"recreate,omitempty" yaml:"recreate,omitempty"`
	// DataLoss represents fields that, when changed, may result in data loss.
	// For PPND strategy, this list is checked after the 'recreate' list.
	DataLoss []SpecField `json:"dataLoss,omitempty" yaml:"dataLoss,omitempty"`
	// Progressive contains fields that can be updated without requiring a full resource recreation and by performing an in-place update.
	// For PPND strategy, this list is checked after the other two lists.
	Progressive []SpecField `json:"progressive,omitempty" yaml:"progressive,omitempty"`
}

type USDEUserStrategy string