- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 70 for CTX (0.12 sec)
-
istioctl/pkg/xds/client.go
if isMCP { // Special credentials handling when using ASM Managed Control Plane. mem, err := getHubMembership(ctx, kubeClient) if err != nil { return nil, fmt.Errorf("failed to query Hub membership: %w", err) } aud = []string{mem.WorkloadIdentityPool} } k8sCreds, err := kubeClient.CreatePerRPCCredentials(ctx, ns, serviceAccount, aud, defaultExpirationSeconds) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
cniEventAddress: cfg.CNIEventAddress, } } func createCNIConfigFile(ctx context.Context, cfg *config.InstallConfig) (string, error) { cniConfig, err := readCNIConfigTemplate(getCNIConfigTemplate(cfg)) if err != nil { return "", err } cniConfig = replaceCNIConfigVars(cniConfig, getCNIConfigVars(cfg)) return writeCNIConfig(ctx, cniConfig, getPluginConfig(cfg)) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
cmd.PersistentFlags().StringVarP(&oiArgs.revision, "revision", "r", "", OperatorRevFlagHelpStr) cmd.PersistentFlags().BoolVar(&oiArgs.purge, "purge", false, AllOperatorRevFlagHelpStr) } 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.",
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/install.go
}, } addFlags(ic, rootArgs) addInstallFlags(ic, iArgs) return ic } // InstallCmd generates an Istio install manifest and applies it to a cluster func InstallCmd(ctx cli.Context) *cobra.Command { return InstallCmdWithArgs(ctx, &RootArgs{}, &InstallArgs{}) } func Install(kubeClient kube.CLIClient, rootArgs *RootArgs, iArgs *InstallArgs, stdOut io.Writer, l clog.Logger, p Printer, ) error {
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) -
istioctl/pkg/proxyconfig/clusters.go
func ClustersCommand(ctx cli.Context) *cobra.Command { var opts clioptions.ControlPlaneOptions cmd := &cobra.Command{ Use: "remote-clusters", Short: "Lists the remote clusters each istiod instance is connected to.", RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 2.3K bytes - Viewed (0) -
cni/test/install_cni.go
// via context cancellation func startInstallServer(ctx context.Context, serverConfig *config.Config, t *testing.T) { readyFlag := &atomic.Value{} installer := install.NewInstaller(&serverConfig.InstallConfig, readyFlag) t.Logf("CNI installer created, watching...") // installer.Run() will block indefinitely, and attempt to permanently "keep" // the CNI binary installed. if err := installer.Run(ctx); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
t.Helper() // TODO there is already probably something else that does this var out bytes.Buffer ctx := cli.NewFakeContext(&cli.NewFakeContextOption{ IstioNamespace: "istio-system", }) rootCmd := Cmd(ctx) rootCmd.SetArgs(args) client, err := ctx.CLIClientWithRevision(rev) if err != nil { return "", err } createResourceFunc(client) rootCmd.SetOut(&out)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
istioctl analyze samples/bookinfo/networking/bookinfo-gateway.yaml `, Args: cobra.NoArgs, RunE: func(c *cobra.Command, _ []string) error { istioNamespace := ctx.IstioNamespace() defaultNamespace := ctx.NamespaceOrDefault("") return validateFiles(&istioNamespace, defaultNamespace, filenames, c.OutOrStderr()) }, } flags := c.PersistentFlags()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/describe/describe_test.go
} } func verifyExecAndK8sConfigTestCaseTestOutput(t *testing.T, c execAndK8sConfigTestCase) { t.Helper() ctx := cli.NewFakeContext(&cli.NewFakeContextOption{ Namespace: c.namespace, IstioNamespace: c.istioNamespace, Results: c.configDumps, }) client, err := ctx.CLIClient() assert.NoError(t, err) // Override the Istio config factory for i := range c.istioConfigs {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 28 09:54:01 GMT 2024 - 30.4K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
}) return g } type watcher struct { resultsChan chan string errorChan chan error ctx context.Context } func withContext(ctx context.Context) *watcher { return &watcher{ resultsChan: make(chan string, 1), errorChan: make(chan error, 1), ctx: ctx, } } func (w *watcher) Go(f func(chan string) error) { go func() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0)