- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Fettig (0.29 sec)
-
cni/pkg/nodeagent/net.go
return nil, fmt.Errorf("can't find netns for pod, this is ok if this is a newly created pod (%w)", ErrPodNotFound) } return openNetns, nil } // AddPodToMesh adds a pod to mesh by // 1. Getting the netns // 2. Adding the pod's IPs to the hostnetns ipsets for node probe checks // 3. Creating iptables rules inside the pod's netns // 4. Notifying ztunnel via GRPC to create a proxy for the pod //
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
operator/cmd/mesh/manifest-generate.go
_ = cmd.PersistentFlags().MarkHidden("filter") cmd.PersistentFlags().BoolVar(&args.EnableClusterSpecific, "cluster-specific", false, "If enabled, the current cluster will be checked for cluster-specific setting detection.") } func ManifestGenerateCmd(ctx cli.Context, rootArgs *RootArgs, mgArgs *ManifestGenerateArgs) *cobra.Command { return &cobra.Command{ Use: "generate", Short: "Generates an Istio install manifest",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
func DialOptions(opts clioptions.CentralControlPlaneOptions, ns, serviceAccount string, kubeClient kube.CLIClient, ) ([]grpc.DialOption, error) { ctx := context.TODO() // If we are using the insecure 15010 don't bother getting a token if opts.Plaintext || opts.CertDir != "" { return make([]grpc.DialOption, 0), nil } // Use bearer token aud := tokenAudiences
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) -
istioctl/pkg/tag/tag_test.go
t.Run(tc.name, func(t *testing.T) { var out bytes.Buffer client := kube.NewFakeClient(tc.webhooksBefore.DeepCopyObject(), tc.namespaces.DeepCopyObject()) skipConfirmation = true err := setTag(context.Background(), client, tc.tag, tc.revision, "istio-system", false, &out, nil) if tc.error == "" && err != nil { t.Fatalf("expected no error, got %v", err) } if tc.error != "" { if err == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Nov 17 22:41:06 GMT 2023 - 8.7K bytes - Viewed (0) -
operator/cmd/mesh/install.go
type InstallArgs struct { // InFilenames is an array of paths to the input IstioOperator CR files. InFilenames []string // ReadinessTimeout is maximum time to wait for all Istio resources to be ready. wait must be true for this setting // to take effect. ReadinessTimeout time.Duration // SkipConfirmation determines whether the user is prompted for confirmation. // If set to true, the user is not prompted and a Yes response is assumed in all cases.
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/tag/tag.go
}, } cmd.PersistentFlags().BoolVarP(&skipConfirmation, "skip-confirmation", "y", false, skipConfirmationFlagHelpStr) return cmd } // setTag creates or modifies a revision tag. func setTag(ctx context.Context, kubeClient kube.CLIClient, tagName, revision, istioNS string, generate bool, w, stderr io.Writer) error { opts := &GenerateOptions{ Tag: tagName,
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) -
cni/pkg/plugin/kubernetes.go
// Some config can be passed in a kubeconfig file kubeconfig := conf.Kubernetes.Kubeconfig config, err := kube.DefaultRestConfig(kubeconfig, "") if err != nil { log.Errorf("Failed setting up kubernetes client with kubeconfig %s", kubeconfig) return nil, err } log.Debugf("istio-cni set up kubernetes client with kubeconfig %s", kubeconfig) // Create the client
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/writer/compare/sds/util.go
} // NewSecretItemBuilder returns a new builder to create a secret item func NewSecretItemBuilder() SecretItemBuilder { return &secretItemBuilder{} } // SecretItemBuilder wraps the process of setting fields for the SecretItem // and builds the Metadata fields from the cert contents behind the scenes type SecretItemBuilder interface { Name(string) SecretItemBuilder Data(string) SecretItemBuilder
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jun 06 15:14:48 GMT 2023 - 6.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
return c.deleteBrokenPod(pod) } else if c.cfg.LabelPods { return c.labelBrokenPod(pod) } return nil } // repairPod actually dynamically repairs a pod. This is done by entering the pods network namespace and setting up rules. // This differs from the general CNI plugin flow, which triggers before the pod fully starts. // Additionally, we need to jump through hoops to find the network namespace.
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) -
operator/cmd/mesh/shared.go
) // installerScope is the scope for all commands in the mesh package. var installerScope = log.RegisterScope("installer", "installer") func init() { // adding to remove message about the controller-runtime logs not getting displayed // We cannot do this in the `log` package since it would place a runtime dependency on controller-runtime for all binaries. scope := log.RegisterScope("controlleruntime", "scope for controller runtime")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 5.1K bytes - Viewed (0)