operator

Documentation

Index

• Constants
• func RunOperator(ctx context.Context, cc *controllercmd.ControllerContext) error
• type TargetConfigReconciler
  • func NewTargetConfigReconciler(ctx context.Context, ...) (*TargetConfigReconciler, error)
  • func (c *TargetConfigReconciler) Run(workers int, stopCh <-chan struct{})

Constants

const (
	DefaultImage    = "gcr.io/k8s-staging-kueue/kueue"
	PromNamespace   = "openshift-monitoring"
	PromRouteName   = "prometheus-k8s"
	PromTokenPrefix = "prometheus-k8s-token"
)

Functions

func RunOperator

func RunOperator(ctx context.Context, cc *controllercmd.ControllerContext) error

Types

type TargetConfigReconciler

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

func NewTargetConfigReconciler

func NewTargetConfigReconciler(
	ctx context.Context,
	operatorConfigClient operatorconfigclientv1.ExtendedjobmanagerV1Interface,
	operatorClientInformer operatorclientinformers.ExtendedJobManagerInformer,
	kubeInformersForNamespaces v1helpers.KubeInformersForNamespaces,
	extendedJobManagerClient *operatorclient.ExtendedJobManagerClient,
	kubeClient kubernetes.Interface,
	osrClient openshiftrouteclientset.Interface,
	dynamicClient dynamic.Interface,
	eventRecorder events.Recorder,
) (*TargetConfigReconciler, error)

func (*TargetConfigReconciler) Run

func (c *TargetConfigReconciler) Run(workers int, stopCh <-chan struct{})

Run starts the runner and blocks until stopCh is closed.