INNER CODE UNIT · Go

rmqSelector

rabbitmq/cluster-operator · cmd/main.go:204

	rmqSelector := labels.NewSelector().Add(*rmqLabel)

	options.Cache.ByObject = map[client.Object]cache.ByObject{
		&rabbitmqv1beta1.RabbitmqCluster{}: {},
		&appsv1.StatefulSet{}:              {Label: rmqSelector},
		&corev1.Pod{}:                      {Label: rmqSelector},
		&corev1.Service{}:                  {Label: rmqSelector},
		&corev1.ConfigMap{}:                {Label: rmqSelector},
		&corev1.Secret{}:                   {Label: rmqSelector},
		&corev1.ServiceAccount{}:           {Label: rmqSelector},
		&discoveryv1.EndpointSlice{}:       {Label: rmqSelector},
		&rbacv1.Role{}:                     {Label: rmqSelector},
		&rbacv1.RoleBinding{}:              {Label: rmqSelector},
	}

	if leaseDuration := getEnvInDuration("LEASE_DURATION"); leaseDuration != 0 {
		log.Info("manager configured with lease duration", "seconds", int(leaseDuration.Seconds()))
		options.LeaseDuration = &leaseDuration

View source record →