- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for CLIClient (1.67 sec)
-
istioctl/pkg/multixds/gather.go
ns string, serviceAccount string, kubeClient kube.CLIClient, options Options, ) (map[string]*discovery.DiscoveryResponse, error) { return MultiRequestAndProcessXds(false, dr, centralOpts, istioNamespace, ns, serviceAccount, kubeClient, options) } type xdsAddr struct { gcpProject, host, istiod string } func getXdsAddressFromWebhooks(client kube.CLIClient) (*xdsAddr, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
"error": ErrorLevel, "critical": CriticalLevel, "off": OffLevel, } var ( loggerLevelString = "" reset = false ) func extractConfigDump(kubeClient kube.CLIClient, podName, podNamespace string, eds bool) ([]byte, error) { path := "config_dump" if eds { path += "?include_eds=true" }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
client, err := ctx.CLIClient() if err != nil { return err } l := clog.NewConsoleLogger(cmd.OutOrStdout(), cmd.OutOrStderr(), installerScope) operatorRemove(cmd, client, rootArgs, orArgs, l) return nil }, } } // operatorRemove removes the Istio operator controller from the cluster.
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) -
istioctl/pkg/waypoint/waypoint.go
return fmt.Errorf("must either specify a waypoint name or delete all using --all") } return nil }, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClient() if err != nil { return fmt.Errorf("failed to create Kubernetes client: %v", err) } ns := ctx.NamespaceOrDefault(ctx.Namespace()) // Delete all waypoints if the --all flag is set
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
"istio.io/istio/istioctl/pkg/cli" "istio.io/istio/pkg/kube" ) func getPodsNameInDefaultNamespace(ctx cli.Context, toComplete string) ([]string, error) { client, err := ctx.CLIClient() if err != nil { return nil, err } ns := ctx.NamespaceOrDefault(ctx.Namespace()) podList, err := client.Kube().CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions{}) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
istioctl/pkg/tag/revision.go
EgressGatewayPods []*PodFilteredInfo `json:"egress_gateways,omitempty"` NamespaceSummary map[string]*NsInfo `json:"namespace_summary,omitempty"` } func ListRevisionDescriptions(client kube.CLIClient) (map[string]*RevisionDescription, error) { revisions := map[string]*RevisionDescription{} // Get a list of control planes which are installed in remote clusters
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Jan 28 13:16:05 GMT 2023 - 4.5K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
"istio.io/istio/istioctl/pkg/multixds" "istio.io/istio/istioctl/pkg/util" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/kube" ) func HandlerForRetrieveDebugList(kubeClient kube.CLIClient, centralOpts clioptions.CentralControlPlaneOptions, writer io.Writer, istioNamespace string, ) (map[string]*discovery.DiscoveryResponse, error) { var namespace, serviceAccount string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
"istio.io/istio/pkg/version" ) const ( configMapKey = "mesh" injectConfigMapKey = "config" valuesConfigMapKey = "values" ) type ExternalInjector struct { client kube.CLIClient clientConfig *admissionregistration.WebhookClientConfig injectorAddress string } func (e ExternalInjector) Inject(pod *corev1.Pod, deploymentNS string) ([]byte, error) { cc := e.clientConfig if cc == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
operator/cmd/mesh/install.go
return fmt.Errorf("invalid revision specified: %v", iArgs.Revision) } return nil }, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClient() if err != nil { return err } l := clog.NewConsoleLogger(cmd.OutOrStdout(), cmd.ErrOrStderr(), installerScope) p := NewPrinterForWriter(cmd.OutOrStderr()) p.Printf("%v\n", art.IstioColoredArt())
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1)