- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for Content (0.24 sec)
-
istioctl/pkg/tag/tag.go
} return removeTag(context.Background(), kubeClient.Kube(), args[0], skipConfirmation, cmd.OutOrStdout()) }, } cmd.PersistentFlags().BoolVarP(&skipConfirmation, "skip-confirmation", "y", false, skipConfirmationFlagHelpStr) return cmd } // setTag creates or modifies a revision tag.
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
if _, err := kubeClient.Kube().CoreV1().Namespaces().Update(context.Background(), nsObj, metav1.UpdateOptions{}); err != nil { return fmt.Errorf("failed to update namespace %s: %v", ns, err) } return nil } func namespaceIsLabeledAmbient(kubeClient kube.CLIClient, ns string) (bool, error) { nsObj, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.Background(), ns, metav1.GetOptions{}) if errors.IsNotFound(err) {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:40 GMT 2024 - 15K bytes - Viewed (0) -
licenses/cel.dev/expr/LICENSE
names, trademarks, service marks, or product names of the Licensor, except as required for reasonable and customary use in describing the origin of the Work and reproducing the content of the NOTICE file. 7. Disclaimer of Warranty. Unless required by applicable law or agreed to in writing, Licensor provides the Work (and each Contributor provides its Contributions) on an "AS IS" BASIS,
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 08 17:05:56 GMT 2024 - 11.1K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
} return nsNameList, nil } func getNamespaces(ctx context.Context, client kube.CLIClient) ([]corev1.Namespace, error) { nslist, err := client.Kube().CoreV1().Namespaces().List(ctx, metav1.ListOptions{}) if err != nil { return []corev1.Namespace{}, err } return nslist.Items, nil } func ValidNamespaceArgs(_ *cobra.Command, ctx cli.Context, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
ztunnelServer *fakeZtunnel iptablesConfigurator *iptables.IptablesConfigurator nlDeps *fakeIptablesDeps ipsetDeps *ipset.MockedIpsetDeps } func getTestFixure(ctx context.Context) netTestFixture { podNsMap := newPodNetnsCache(openNsTestOverride) nlDeps := &fakeIptablesDeps{} iptablesConfigurator, _ := iptables.NewIptablesConfigurator(nil, &dependencies.DependenciesStub{}, nlDeps)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 14.3K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
) var ztunnelConnected = monitoring.NewGauge("ztunnel_connected", "number of connections to ztunnel") type ZtunnelServer interface { Run(ctx context.Context) PodDeleted(ctx context.Context, uid string) error PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error Close() error } /* To clean up stale ztunnels we may need to ztunnel to send its (uid, bootid / boot time) to us
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
port := 15014 pod, err := client.Kube().CoreV1().Pods(ns).Get(context.Background(), name, metav1.GetOptions{}) if err != nil { return port } return kube.FindIstiodMonitoringPort(pod) } // port-forward to SkyWalking UI on istio-system func skywalkingDashCmd(ctx cli.Context) *cobra.Command { var opts clioptions.ControlPlaneOptions cmd := &cobra.Command{ Use: "skywalking",
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// redetect for each pod anyway. // // Extreme corner case: // If for some reason your host had both binaries, and you were injecting out-of-band // iptables rules within a pod context into `legacy` tables, but your host context preferred // `nft`, we would still inject our rules in-pod into nft tables, which is a bit wonky. // // But that's stunningly unlikely (and would still work either way)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 01:42:30 GMT 2024 - 19.2K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
pods, err := kubeClient.GetIstioPods(context.TODO(), podNamespace, metav1.ListOptions{ FieldSelector: "metadata.name=" + podName, }) if err != nil { return nil, fmt.Errorf("failed to get pod: %s", err) } if len(pods) != 1 { return nil, fmt.Errorf("expecting only 1 pod for %s.%s, found: %d", podName, podNamespace, len(pods)) } data, err := kubeClient.EnvoyDo(context.TODO(), podName, podNamespace, "GET", "config_dump")
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0) -
cni/pkg/util/podutil.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package util import ( "context" "fmt" "net/netip" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/kubernetes"
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0)