controllers

package
v4.2.711+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 20, 2020 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetAlamedaScalerControllerName 

func GetAlamedaScalerControllerName(ctx context.Context, k8sClient client.Client, objectMeta metav1.ObjectMeta) (string, error)

func IsMonitoredByAlamedaScalerController 

func IsMonitoredByAlamedaScalerController(obj metav1.ObjectMeta, name string) bool

IsMonitoredByAlamedaScalerController returns if the object is monitored by the provided name of AlamdeScaler controller.

func RegisterAlamedaScalerController 

func RegisterAlamedaScalerController(name string, f ListMonitoringAlamedaScaler)

RegisterAlamedaScalerController registers the controller name to listCandidatesFunctionMap with function provieded in arg 2.

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 ListMonitoringAlamedaScaler 

type ListMonitoringAlamedaScaler = func(context.Context, client.Client, metav1.ObjectMeta) ([]autoscalingv1alpha1.AlamedaScaler, 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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.