config

type AWSConfig struct {
	Route53                     awsRoute53Config
	SecretManager               awsSecretManagerConfig
	ConfigForOSDClusterCreation awsConfigForOSDClusterCreation
}

type AutomaticCertificateManagementConfig struct {
	RenewalWindowRatio           float64 `validate:"gte=0,lte=1"`
	EmailToSendNotificationTo    string  `validate:"required,email"`
	AcmeIssuerAccountKeyFilePath string  `validate:"required"`
	CertificateCacheTTL          time.Duration
	AcmeIssuerAccountKey         string
	MustStaple                   bool
}

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

type ClusterList []ManualCluster

type ComputeMachineConfig struct {
	ComputeMachineType      string                         `yaml:"compute_machine_type" validate:"required"`
	ComputeNodesAutoscaling *ComputeNodesAutoscalingConfig `yaml:"compute_node_autoscaling" validate:"required"`
}

type ComputeMachinesConfig struct {
	ClusterWideWorkload          *ComputeMachineConfig           `yaml:"cluster_wide_workload" validate:"required"`
	KafkaWorkloadPerInstanceType map[string]ComputeMachineConfig `yaml:"kafka_workload_per_instance_type" validate:"required"`
}

type ComputeNodesAutoscalingConfig struct {
	MaxComputeNodes int `yaml:"max_compute_nodes" validate:"gt=0,gtefield=MinComputeNodes"`
	MinComputeNodes int `yaml:"min_compute_nodes" validate:"gt=0"`
}

type DataplaneClusterConfig struct {
	ImagePullDockerConfigContent string
	ImagePullDockerConfigFile    string
	// Possible values are:
	// 'manual' to use OSD Cluster configuration file,
	// 'auto' to use dynamic scaling
	// 'none' to disabled scaling all together, useful in testing
	DataPlaneClusterScalingType                 string
	DataPlaneClusterConfigFile                  string
	ReadOnlyUserList                            userv1.OptionalNames
	ReadOnlyUserListFile                        string
	KafkaSREUsers                               userv1.OptionalNames
	KafkaSREUsersFile                           string
	ClusterConfig                               *ClusterConfig
	EnableReadyDataPlaneClustersReconcile       bool
	EnableKafkaSreIdentityProviderConfiguration bool
	Kubeconfig                                  string
	RawKubernetesConfig                         *clientcmdapi.Config
	StrimziOperatorOLMConfig                    OperatorInstallationConfig
	KasFleetshardOperatorOLMConfig              OperatorInstallationConfig
	ObservabilityOperatorOLMConfig              OperatorInstallationConfig
	DynamicScalingConfig                        DynamicScalingConfig
	NodePrewarmingConfig                        NodePrewarmingConfig
}

type DynamicScalingConfig struct {
	ComputeMachinePerCloudProvider                map[cloudproviders.CloudProviderID]ComputeMachinesConfig `yaml:"compute_machine_per_cloud_provider" validate:"required"`
	EnableDynamicScaleUpManagerScaleUpTrigger     bool                                                     `yaml:"enable_dynamic_data_plane_scale_up"`
	EnableDynamicScaleDownManagerScaleDownTrigger bool                                                     `yaml:"enable_dynamic_data_plane_scale_down"`
	NewDataPlaneOpenShiftVersion                  string                                                   `yaml:"new_data_plane_openshift_version"`
	// contains filtered or unexported fields
}

type GCPConfig struct {
	GCPCredentials GCPCredentials
	// contains filtered or unexported fields
}

type GCPCredentials struct {
	AuthProviderX509CertURL string `json:"auth_provider_x509_cert_url" validate:"required"`
	AuthURI                 string `json:"auth_uri" validate:"required"`
	ClientEmail             string `json:"client_email" validate:"required"`
	ClientID                string `json:"client_id" validate:"required"`
	ClientX509CertURL       string `json:"client_x509_cert_url" validate:"required"`
	PrivateKey              string `json:"private_key" validate:"required"`
	PrivateKeyID            string `json:"private_key_id" validate:"required"`
	ProjectID               string `json:"project_id" validate:"required"`
	TokenURI                string `json:"token_uri" validate:"required"`
	Type                    string `json:"type" validate:"required"`
}

type InstanceType types.KafkaInstanceType

type InstanceTypeConfig struct {
	Limit *int `yaml:"limit"`
	// Minimum capacity in number of kafka streaming units that should be
	// available (free) at any given moment for a supported instance type in a
	// region. If not provided, its default value is 0 which means that there is
	// no minimum available capacity required.
	// Used for dynamic scaling evaluation.
	MinAvailableCapacitySlackStreamingUnits int `yaml:"min_available_capacity_slack_streaming_units"`
}

type InstanceTypeMap map[string]InstanceTypeConfig

type InstanceTypeNodePrewarmingConfig struct {
	BaseStreamingUnitSize string `yaml:"base_streaming_unit_size"`
	NumReservedInstances  int    `yaml:"num_reserved_instances"`
}

type KafkaBillingModel struct {
	ID               string   `yaml:"id" validate:"required"`
	AMSResource      string   `yaml:"ams_resource" validate:"required,ams_resource_validator"`
	AMSProduct       string   `yaml:"ams_product" validate:"required,ams_product_validator"`
	AMSBillingModels []string `yaml:"ams_billing_models" validate:"min=1,unique,ams_billing_models_validator"`
	GracePeriodDays  int      `yaml:"grace_period_days" validate:"min=0"`
}

type KafkaConfig struct {
	EnableKafkaCNAMERegistration bool
	KafkaDomainName              string
	BrowserUrl                   string

	Quota                  *KafkaQuotaConfig
	SupportedInstanceTypes *KafkaSupportedInstanceTypesConfig
	EnableKafkaOwnerConfig bool
	KafkaOwnerList         []string
	KafkaOwnerListFile     string
}

type KafkaInstanceSize struct {
	Id                          string   `yaml:"id"`
	DisplayName                 string   `yaml:"display_name"`
	IngressThroughputPerSec     Quantity `yaml:"ingressThroughputPerSec"`
	EgressThroughputPerSec      Quantity `yaml:"egressThroughputPerSec"`
	TotalMaxConnections         int      `yaml:"totalMaxConnections"`
	MaxDataRetentionSize        Quantity `yaml:"maxDataRetentionSize"`
	MaxPartitions               int      `yaml:"maxPartitions"`
	MaxDataRetentionPeriod      string   `yaml:"maxDataRetentionPeriod"`
	MaxConnectionAttemptsPerSec int      `yaml:"maxConnectionAttemptsPerSec"`
	MaxMessageSize              Quantity `yaml:"maxMessageSize"`
	QuotaConsumed               int      `yaml:"quotaConsumed"`
	// DeprecatedQuotaType is deprecated. To be removed after API
	// deprecation period.
	DeprecatedQuotaType string         `yaml:"quotaType"`
	CapacityConsumed    int            `yaml:"capacityConsumed"`
	SupportedAZModes    []string       `yaml:"supportedAZModes"`
	MinInSyncReplicas   int            `yaml:"minInSyncReplicas"` // also abbreviated as ISR in Kafka terminology
	ReplicationFactor   int            `yaml:"replicationFactor"` // also abbreviated as RF in Kafka terminology
	LifespanSeconds     *int           `yaml:"lifespanSeconds"`
	MaturityStatus      MaturityStatus `yaml:"maturityStatus"`
}

type KafkaInstanceType struct {
	Id                     string              `yaml:"id"`
	DisplayName            string              `yaml:"display_name"`
	Sizes                  []KafkaInstanceSize `yaml:"sizes"`
	SupportedBillingModels []KafkaBillingModel `yaml:"supported_billing_models" validate:"min=1,unique=ID,dive"`
}

type KafkaQuotaConfig struct {
	Type                         string
	AllowDeveloperInstance       bool
	MaxAllowedDeveloperInstances int
}

type KafkaSupportedInstanceTypesConfig struct {
	Configuration     SupportedKafkaInstanceTypesConfig
	ConfigurationFile string
}

type KafkaTLSCertificateManagementConfig struct {
	CertificateAuthorityEndpoint         string
	CertificateManagementStrategy        string
	StorageType                          string
	EnableKafkaExternalCertificate       bool
	ManualCertificateManagementConfig    ManualCertificateManagementConfig
	AutomaticCertificateManagementConfig AutomaticCertificateManagementConfig
}

type KasFleetshardConfig struct {
	PollInterval   string
	ResyncInterval string
}

type ManualCertificateManagementConfig struct {
	KafkaTLSCert         string
	KafkaTLSKey          string
	KafkaTLSCertFilePath string `validate:"required"`
	KafkaTLSKeyFilePath  string `validate:"required"`
}

type ManualCluster struct {
	Name                  string                  `yaml:"name"`
	ClusterId             string                  `yaml:"cluster_id"`
	CloudProvider         string                  `yaml:"cloud_provider"`
	Region                string                  `yaml:"region"`
	MultiAZ               bool                    `yaml:"multi_az"`
	Schedulable           bool                    `yaml:"schedulable"`
	KafkaInstanceLimit    int                     `yaml:"kafka_instance_limit"`
	Status                api.ClusterStatus       `yaml:"status"`
	ProviderType          api.ClusterProviderType `yaml:"provider_type"`
	ClusterDNS            string                  `yaml:"cluster_dns"`
	SupportedInstanceType string                  `yaml:"supported_instance_type"`
}

type MaturityStatus string

type NodePrewarmingConfig struct {
	Configuration map[string]InstanceTypeNodePrewarmingConfig
	// contains filtered or unexported fields
}

type OperatorInstallationConfig struct {
	Namespace               string
	IndexImage              string
	Package                 string
	SubscriptionChannel     string
	SubscriptionConfig      *operatorsv1alpha1.SubscriptionConfig
	SubscriptionConfigFile  string
	SubscriptionStartingCSV string
}

type Plan string

type Provider struct {
	Name    string     `yaml:"name"`
	Default bool       `yaml:"default"`
	Regions RegionList `yaml:"regions"`
}

type ProviderConfig struct {
	ProvidersConfig     ProviderConfiguration
	ProvidersConfigFile string
}

type ProviderConfiguration struct {
	SupportedProviders ProviderList `yaml:"supported_providers"`
}

type ProviderList []Provider

type Quantity string

type Region struct {
	Name                   string          `yaml:"name"`
	Default                bool            `yaml:"default"`
	SupportedInstanceTypes InstanceTypeMap `yaml:"supported_instance_type"`
}

type RegionList []Region

type SupportedKafkaInstanceTypesConfig struct {
	SupportedKafkaInstanceTypes []KafkaInstanceType `yaml:"supported_instance_types"`
}