- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 96 for from (0.13 sec)
-
istioctl/pkg/writer/ztunnel/configdump/certificates.go
if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil } // PrintSecretSummary prints a summary of dynamic active secrets from the config dump func (c *ConfigWriter) PrintSecretSummary() error { if c.ztunnelDump == nil { return fmt.Errorf("config writer has not been primed") } secretDump := c.ztunnelDump.Certificates
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0) -
operator/cmd/mesh/operator-common.go
) type operatorCommonArgs struct { // hub is the hub for the operator image. hub string // tag is the tag for the operator image. tag string // imagePullSecrets is an array of imagePullSecret to pull operator image from the private registry imagePullSecrets []string // operatorNamespace is the namespace the operator controller is installed into. operatorNamespace 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) -
cni/pkg/nodeagent/podcgroupns_test.go
} expectedUID := "863b91d4-4b68-4efa-917f-4b560e3e86aa" if podUIDNetns[expectedUID] == (WorkloadInfo{}) { t.Fatal("expected to find pod netns under pod uid") } } // copied and modified from spire func TestGetContainerIDFromCGroups(t *testing.T) { makeCGroups := func(groupPaths []string) []Cgroup { var out []Cgroup for _, groupPath := range groupPaths { out = append(out, Cgroup{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
var getFirstPodFunc func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) (*corev1.Pod, int, error) // InferPodInfoFromTypedResource gets a pod name, from an expression like Deployment/httpbin, or Deployment/productpage-v1.bookinfo func InferPodInfoFromTypedResource(name, defaultNS string, factory cmdutil.Factory) (string, string, error) { resname, ns := inferNsInfo(name, defaultNS)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_redirect.go
} return true, val, nil } // no annotation found so use default value return false, annotationRegistry[name].defaultVal, nil } // NewRedirect returns a new Redirect Object constructed from a list of ports and annotations func NewRedirect(pi *PodInfo) (*Redirect, error) { var isFound bool var valErr error redir := &Redirect{} redir.targetPort = defaultRedirectToPort
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
cache.FlushObjectCaches() if !kubeBuilderInstalled() { return nil } return recreateTestEnv() } // getAllIstioObjects lists all Istio GVK resources from the testClient. func getAllIstioObjects() object.K8sObjects { var out object.K8sObjects for _, gvk := range append(allClusterGVKs, allNamespacedGVKs...) { objects := &unstructured.UnstructuredList{}
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) -
cni/pkg/iptables/iptables.go
"-j", "CONNMARK", "--set-xmark", inpodTproxyMark) // Handle healthcheck probes from the host node. In the host netns, before the packet enters the pod, we SNAT // the healthcheck packet to a fixed IP if the packet is coming from a node-local process with a socket. // // We do this so we can exempt this traffic from ztunnel capture/proxy - otherwise both kube-proxy (legit)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/log/uds.go
} msg.Msg = strings.TrimSpace(msg.Msg) messages = append(messages, msg) } // Lock log message printing to prevent log messages from different CNI // processes interleave. l.mu.Lock() defer l.mu.Unlock() for _, m := range messages { // There is no fatal log from CNI plugin switch m.Level { case "debug": pluginLog.LogWithTime(log.DebugLevel, m.Msg, m.Time) case "info":
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
// TestWorkloadEntryConfigure enumerates test cases based on subdirectories of testdata/vmconfig. // Each subdirectory contains two input files: workloadgroup.yaml and meshconfig.yaml that are used // to generate golden outputs from the VM command. func TestWorkloadEntryConfigure(t *testing.T) { noClusterID := "failed to automatically determine the --clusterID" files, err := os.ReadDir("testdata/vmconfig") if err != nil { t.Fatal(err) }
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) -
cni/test/install_cni.go
} } // Removes Istio CNI's config from the CNI config file func rmCNIConfig(cniConfigFilepath string, t *testing.T) { t.Helper() // Read JSON from CNI config file cniConfigMap, err := util.ReadCNIConfigMap(cniConfigFilepath) if err != nil { t.Fatal(err) } // Find Istio CNI and remove from plugin list plugins, err := util.GetPlugins(cniConfigMap) if 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)