controllers

package
v4.5.2003+incompatible Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2020 License: Apache-2.0 Imports: 53 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.

func SyncCAInfoWithScalerAndMachineGroup 

func SyncCAInfoWithScalerAndMachineGroup(ctx context.Context,
	clusterUID string, clnt client.Client, datahubClient *datahubpkg.Client,
	alamedaScaler autoscalingv1alpha1.AlamedaScaler,
	mgIns autoscalingv1alpha1.AlamedaMachineGroupScaler) error

Types

type AlamedaMachineGroupScalerReconciler 

type AlamedaMachineGroupScalerReconciler struct {
	client.Client
	ClusterUID       string
	DatahubClient    *datahubpkg.Client
	Log              logr.Logger
	Scheme           *runtime.Scheme
	ReconcileTimeout time.Duration
}

AlamedaMachineGroupScalerReconciler reconciles a AlamedaMachineGroupScaler object

func (*AlamedaMachineGroupScalerReconciler) Reconcile 

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

func (*AlamedaMachineGroupScalerReconciler) SetupWithManager 

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

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

	KafkaClient      kafka.Client
	PrometheusClient prometheus.Prometheus
	DatahubClient    *datahubpkg.Client
	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 AlamedaScalerNginxReconciler 

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

	ClusterUID            string
	Logger                *log.Scope
	ReconcileTimeout      time.Duration
	DatahubClient         *datahubpkg.Client
	HasOpenShiftAPIAppsv1 bool
}

AlamedaScalerNginxReconciler reconciles a AlamedaScaler object

func (*AlamedaScalerNginxReconciler) Reconcile 

func (r *AlamedaScalerNginxReconciler) 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 (*AlamedaScalerNginxReconciler) SetupWithManager 

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

type AlamedaScalerReconciler 

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

	ClusterUID            string
	DatahubClient         *datahubpkg.Client
	DatahubControllerRepo *datahub_controller.ControllerRepository
	DatahubNamespaceRepo  *datahub_namespace.NamespaceRepository
	DatahubPodRepo        *datahub_pod.PodRepository
	//onceForceReconcile     sync.Once
	ReconcileTimeout       time.Duration
	ForceReconcileInterval time.Duration
}

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 MachineReconciler 

type MachineReconciler struct {
	client.Client
	Scheme           *runtime.Scheme
	ClusterUID       string
	ReconcileTimeout time.Duration
	DatahubClient    *datahubpkg.Client
}

MachineReconciler reconciles a Machine object

func (*MachineReconciler) Reconcile 

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

func (*MachineReconciler) SetupWithManager 

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

type MachineSetReconciler 

type MachineSetReconciler struct {
	client.Client
	Scheme           *runtime.Scheme
	ClusterUID       string
	ReconcileTimeout time.Duration
	DatahubClient    *datahubpkg.Client
}

MachineSetReconciler reconciles a MachineSet object

func (*MachineSetReconciler) Reconcile 

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

func (*MachineSetReconciler) SetupWithManager 

func (r *MachineSetReconciler) 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
	DatahubClient   *datahubpkg.Client

	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.