controller

package
v0.0.0-...-2d1874a Latest Latest
Warning

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

Go to latest
Published: Oct 22, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const (
	BoskosIdLabel             = "boskos-lease-id"
	JobNameLabel              = "job-name"
	ALLOW_MULTI_TO_USE_SINGLE = false

	// PROW_JOB_PERIODICAL_URL is used to generate URL for periodical jobs.  Need to supply PROW_JOB_URL_PREFIX_KEY, PROW_GS_BUCKET_KEY, PROW_JOB and PROW_BUILD_ID.
	PROW_JOB_PERIODICAL_URL = "%vgs/%v/logs/%v/%v"

	// PROW_JOB_PRESUBMIT_URL is used to generate URL for presubmit jobs.  Need to supply PROW_JOB_URL_PREFIX_KEY, PROW_GS_BUCKET_KEY,GIT_ORG, GIT_REPO, GIT_PR, PROW_JOB, and PROW_BUILD_ID.
	PROW_JOB_PRESUBMIT_URL = "%vgs/%v/pr-logs/pull/%v_%v/%v/%v/%v"

	PROW_JOB_TYPE_KEY       = "prow-job-type"
	PROW_JOB_KEY            = "prow-job-name"
	PROW_JOB_URL_PREFIX_KEY = "prow-url-prefix"
	PROW_GS_BUCKET_KEY      = "prow-gs-bucket"
	PROW_BUILD_ID_KEY       = "prow-build-id"
	GIT_ORG_KEY             = "git-org"
	GIT_REPO_KEY            = "git-repo"
	GIT_PR_KEY              = "git-pr"

	DEFAULT_PROW_JOB_URL_PREFIX = "https://prow.ci.openshift.org/view/"
	DEFAULT_PROW_GS_BUCKET      = "test-platform-results"
	PERIODICAL_JOB_TYPE         = "periodic"
	PRESUBMIT_JOB_TYPE          = "presubmit"
)

Variables

View Source
var (
	PoolMemoryAvailable = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "pool_memory_available",
		Help: "The amount of memory available in a pool",
	}, []string{"namespace", "pool"})

	PoolMemoryTotal = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "pool_memory_total",
		Help: "The total amount of memory of a pool",
	}, []string{"namespace", "pool"})

	PoolCpusAvailable = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "pool_cpus_available",
		Help: "The amount of cpus available in a pool",
	}, []string{"namespace", "pool"})

	PoolCpusTotal = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "pool_cpus_total",
		Help: "The total amount of cpus of a pool",
	}, []string{"namespace", "pool"})

	PoolNetworksAvailable = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "pool_networks_available",
		Help: "Number of currently used networks",
	}, []string{"namespace", "pool"})

	LeasesInUse = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "leases_in_use",
		Help: "Number of leases in use",
	}, []string{"namespace", "pool"})

	LeaseCounts = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "leases_counts",
		Help: "Counts of active leases",
	}, []string{"namespace", "networkType", "phase"})
)

Functions

func InitMetrics

func InitMetrics()

Types

type LeaseReconciler

type LeaseReconciler struct {
	client.Client
	Scheme         *runtime.Scheme
	Recorder       record.EventRecorder
	RESTMapper     meta.RESTMapper
	UncachedClient client.Client

	// Namespace is the namespace in which the ControlPlaneMachineSet controller should operate.
	// Any ControlPlaneMachineSet not in this namespace should be ignored.
	Namespace string

	// OperatorName is the name of the ClusterOperator with which the controller should report
	// its status.
	OperatorName string

	// ReleaseVersion is the version of current cluster operator release.
	ReleaseVersion string

	// Option to allow multi-tenant lease to use single-tenant networks
	AllowMultiToUseSingle bool
}

func (*LeaseReconciler) Reconcile

func (l *LeaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*LeaseReconciler) SetupWithManager

func (l *LeaseReconciler) SetupWithManager(mgr ctrl.Manager) error

type NamespaceReconciler

type NamespaceReconciler struct {
	client.Client
	Scheme         *runtime.Scheme
	Recorder       record.EventRecorder
	RESTMapper     meta.RESTMapper
	UncachedClient client.Client

	// Namespace is the namespace in which the ControlPlaneMachineSet controller should operate.
	// Any ControlPlaneMachineSet not in this namespace should be ignored.
	Namespace string

	// OperatorName is the name of the ClusterOperator with which the controller should report
	// its status.
	OperatorName string

	// ReleaseVersion is the version of current cluster operator release.
	ReleaseVersion string
}

func (*NamespaceReconciler) PruneAbandonedLeases

func (l *NamespaceReconciler) PruneAbandonedLeases(ctx context.Context)

func (*NamespaceReconciler) SetupWithManager

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

type NetworkReconciler

type NetworkReconciler struct {
	client.Client
	Scheme         *runtime.Scheme
	Recorder       record.EventRecorder
	RESTMapper     meta.RESTMapper
	UncachedClient client.Client

	// Namespace is the namespace in which the ControlPlaneMachineSet controller should operate.
	// Any ControlPlaneMachineSet not in this namespace should be ignored.
	Namespace string

	// OperatorName is the name of the ClusterOperator with which the controller should report
	// its status.
	OperatorName string

	// ReleaseVersion is the version of current cluster operator release.
	ReleaseVersion string
}

func (*NetworkReconciler) Reconcile

func (l *NetworkReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NetworkReconciler) SetupWithManager

func (l *NetworkReconciler) SetupWithManager(mgr ctrl.Manager) error

type PoolReconciler

type PoolReconciler struct {
	client.Client
	Scheme         *runtime.Scheme
	Recorder       record.EventRecorder
	RESTMapper     meta.RESTMapper
	UncachedClient client.Client

	// Namespace is the namespace in which the ControlPlaneMachineSet controller should operate.
	// Any ControlPlaneMachineSet not in this namespace should be ignored.
	Namespace string

	// OperatorName is the name of the ClusterOperator with which the controller should report
	// its status.
	OperatorName string

	// ReleaseVersion is the version of current cluster operator release.
	ReleaseVersion string
}

func (*PoolReconciler) Reconcile

func (l *PoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PoolReconciler) SetupWithManager

func (l *PoolReconciler) SetupWithManager(mgr ctrl.Manager) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL