- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for Controller (0.68 sec)
-
operator/cmd/mesh/manifest_shared_test.go
"k8s.io/apimachinery/pkg/types" "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/scheme" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client/fake" "sigs.k8s.io/controller-runtime/pkg/client/interceptor" "sigs.k8s.io/controller-runtime/pkg/envtest" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/operator/pkg/apis/istio/v1alpha1" "istio.io/istio/operator/pkg/cache"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
operator/cmd/mesh/operator.go
) // OperatorCmd is a group of commands related to installation and management of the operator controller. func OperatorCmd(ctx cli.Context) *cobra.Command { oc := &cobra.Command{ Use: "operator", Short: "Commands related to Istio operator controller.", Long: "The operator command installs, dumps, removes and shows the status of the operator controller.", } odArgs := &operatorDumpArgs{} oiArgs := &operatorInitArgs{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 1.5K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
if already { l.LogAndPrintf("Operator controller is already installed in %s namespace.", oiArgs.common.operatorNamespace) l.LogAndPrintf("Upgrading operator controller in namespace: %s using image: %s/operator:%s", oiArgs.common.operatorNamespace, oiArgs.common.hub, oiArgs.common.tag) } else { l.LogAndPrintf("Installing operator controller in namespace: %s using image: %s/operator:%s",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0) -
operator/cmd/mesh/operator-common.go
imagePullSecrets []string // operatorNamespace is the namespace the operator controller is installed into. operatorNamespace string // watchedNamespaces is the namespaces the operator controller watches, could be namespace list separated by comma. watchedNamespaces string // istioNamespace is deprecated, use watchedNamespaces instead. istioNamespace string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Dec 17 02:25:04 GMT 2022 - 3.8K bytes - Viewed (0) -
operator/cmd/mesh/root.go
HubFlagHelpStr = `The hub for the operator controller image.` TagFlagHelpStr = `The tag for the operator controller image.` ImagePullSecretsHelpStr = `The imagePullSecrets are used to pull the operator image from the private registry,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/cmd/root.go
// Repair registerBooleanParameter(constants.RepairEnabled, true, "Whether to enable race condition repair or not") registerBooleanParameter(constants.RepairDeletePods, false, "Controller will delete pods when detecting pod broken by race condition") registerBooleanParameter(constants.RepairLabelPods, false, "Controller will label pods when detecting pod broken by race condition")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/repair/monitoring.go
resultSuccess = "success" resultSkip = "skip" resultFail = "fail" podsRepaired = monitoring.NewSum( "istio_cni_repair_pods_repaired_total", "Total number of pods repaired by repair controller", )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 1K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
func operatorRemoveCmd(ctx cli.Context, rootArgs *RootArgs, orArgs *operatorRemoveArgs) *cobra.Command { return &cobra.Command{ Use: "remove", Short: "Removes the Istio operator controller from the cluster.", Long: "The remove subcommand removes the Istio operator controller from the cluster.", Args: func(cmd *cobra.Command, args []string) error { if orArgs.revision == "" && !orArgs.purge {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.4K bytes - Viewed (0) -
operator/cmd/mesh/operator_test.go
// limitations under the License. package mesh import ( "os" "path/filepath" "strings" "testing" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/rest" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/yaml" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/operator/pkg/util" "istio.io/istio/operator/pkg/util/clog" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/env"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 6.4K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
FieldSelector: strings.Join(fieldSelectors, ","), }) c.queue = controllers.NewQueue("repair pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)