controllers

Documentation

Index

• type AlamedaRecommendationReconciler
  • func (r *AlamedaRecommendationReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *AlamedaRecommendationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type AlamedaScalerKafkaReconciler
  • func (r *AlamedaScalerKafkaReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *AlamedaScalerKafkaReconciler) SetupWithManager(mgr ctrl.Manager) error
• type AlamedaScalerReconciler
  • func (r *AlamedaScalerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *AlamedaScalerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DeploymentConfigReconciler
  • func (r *DeploymentConfigReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *DeploymentConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DeploymentReconciler
  • func (r *DeploymentReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *DeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NamespaceReconciler
  • func (r *NamespaceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *NamespaceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NodeReconciler
  • func (r *NodeReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *NodeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type StatefulSetReconciler
  • func (r *StatefulSetReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *StatefulSetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VolumeCapacity

Types

type AlamedaRecommendationReconciler

type AlamedaRecommendationReconciler struct {
	client.Client
	Scheme        *runtime.Scheme
	DatahubClient datahub_v1alpha1.DatahubServiceClient

	ClusterUID string
}

AlamedaRecommendationReconciler reconciles a AlamedaRecommendation object

func (*AlamedaRecommendationReconciler) Reconcile

func (r *AlamedaRecommendationReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile reads that state of the cluster for a AlamedaRecommendation object and makes changes based on the state read and what is in the AlamedaRecommendation.Spec

func (*AlamedaRecommendationReconciler) SetupWithManager

func (r *AlamedaRecommendationReconciler) SetupWithManager(mgr ctrl.Manager) error

type AlamedaScalerKafkaReconciler

type AlamedaScalerKafkaReconciler struct {
	ClusterUID            string
	HasOpenShiftAPIAppsv1 bool

	K8SClient client.Client
	Scheme    *runtime.Scheme

	KafkaRepository                                 kafkarepository.KafkaRepository
	DatahubApplicationKafkaTopicSchema              datahubschemas.Schema
	DatahubApplicationKafkaTopicMeasurement         datahubschemas.Measurement
	DatahubApplicationKafkaConsumerGroupSchema      datahubschemas.Schema
	DatahubApplicationKafkaConsumerGroupMeasurement datahubschemas.Measurement

	KafkaClient      kafka.Client
	PrometheusClient prometheus.Prometheus

	ReconcileTimeout time.Duration

	Logger *log.Scope

	NeededMetrics []string
}

AlamedaScalerKafkaReconciler reconciles AlamedaScaler with Spec.Type in "kafka".

func (*AlamedaScalerKafkaReconciler) Reconcile

func (r *AlamedaScalerKafkaReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*AlamedaScalerKafkaReconciler) SetupWithManager

func (r *AlamedaScalerKafkaReconciler) SetupWithManager(mgr ctrl.Manager) error

type AlamedaScalerReconciler

type AlamedaScalerReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	ClusterUID string

	DatahubApplicationRepo *datahub_application.ApplicationRepository
	DatahubControllerRepo  *datahub_controller.ControllerRepository
	DatahubNamespaceRepo   *datahub_namespace.NamespaceRepository
	DatahubPodRepo         *datahub_pod.PodRepository

	ReconcileTimeout       time.Duration
	ForceReconcileInterval time.Duration
	// contains filtered or unexported fields
}

AlamedaScalerReconciler reconciles a AlamedaScaler object

func (*AlamedaScalerReconciler) Reconcile

func (r *AlamedaScalerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

Reconcile reads that state of the cluster for a AlamedaScaler object and makes changes based on the state read and what is in the AlamedaScaler .Spec

func (*AlamedaScalerReconciler) SetupWithManager

func (r *AlamedaScalerReconciler) SetupWithManager(mgr ctrl.Manager) error

type DeploymentConfigReconciler

type DeploymentConfigReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	ClusterUID string
}

DeploymentConfigReconciler reconciles a DeploymentConfig object

func (*DeploymentConfigReconciler) Reconcile

func (r *DeploymentConfigReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*DeploymentConfigReconciler) SetupWithManager

func (r *DeploymentConfigReconciler) SetupWithManager(mgr ctrl.Manager) error

type DeploymentReconciler

type DeploymentReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	ClusterUID string
}

DeploymentReconciler reconciles a Deployment object

func (*DeploymentReconciler) Reconcile

func (r *DeploymentReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*DeploymentReconciler) SetupWithManager

func (r *DeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error

type NamespaceReconciler

type NamespaceReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	ClusterUID string

	DatahubNamespaceRepo *datahub_namespace.NamespaceRepository
}

NamespaceReconciler reconciles a Namespace object

func (*NamespaceReconciler) Reconcile

func (r *NamespaceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*NamespaceReconciler) SetupWithManager

func (r *NamespaceReconciler) SetupWithManager(mgr ctrl.Manager) error

type NodeReconciler

type NodeReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	DatahubNodeRepo datahub_node.AlamedaNodeRepository

	Cloudprovider string
	RegionName    string
	ClusterUID    string
	// contains filtered or unexported fields
}

NodeReconciler reconciles a Node object

func (*NodeReconciler) Reconcile

func (r *NodeReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Node object and makes changes based on the state read and what is in the Node.Spec TODO(user): Modify this Reconcile function to implement your Controller logic. The scaffolding writes a Deployment as an example +kubebuilder:rbac:groups=core,resources=nodes,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=core,resources=nodes/status,verbs=get;update;patch

func (*NodeReconciler) SetupWithManager

func (r *NodeReconciler) SetupWithManager(mgr ctrl.Manager) error

type StatefulSetReconciler

type StatefulSetReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	ClusterUID string
}

StatefulSetReconciler reconciles a StatefulSet object

func (*StatefulSetReconciler) Reconcile

func (r *StatefulSetReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*StatefulSetReconciler) SetupWithManager

func (r *StatefulSetReconciler) SetupWithManager(mgr ctrl.Manager) error

type VolumeCapacity

type VolumeCapacity struct {
	Total int64
	PVC   int64
}