- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Aare (0.34 sec)
-
operator/cmd/mesh/manifest_shared_test.go
testenv *envtest.Environment testClient client.Client allNamespacedGVKs = append(helmreconciler.NamespacedResources(), schema.GroupVersionKind{Group: "", Version: "v1", Kind: "Endpoints"}) // CRDs are not in the prune list, but must be considered for tests. allClusterGVKs = helmreconciler.ClusterResources ) func init() { if kubeBuilderInstalled() {
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) -
istioctl/pkg/writer/envoy/configdump/listener.go
} func getMatches(f *listener.FilterChainMatch) string { match := f if match == nil { match = &listener.FilterChainMatch{} } // filterChaince also has SuffixLen, SourceType, SourcePrefixRanges which are not rendered. descrs := []string{} if len(match.ServerNames) > 0 { descrs = append(descrs, fmt.Sprintf("SNI: %s", strings.Join(match.ServerNames, ","))) } if len(match.TransportProtocol) > 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
s.currentPodSnapshot.UpsertPodCacheWithNetns(uid, wl) } return nil } func realDependencies() *dep.RealDependencies { return &dep.RealDependencies{ CNIMode: false, // we are in cni, but as we do the netns ourselves, we should keep this as false. NetworkNamespace: "", } } // Remove pod from mesh: pod is not deleted, we just want to remove it from the mesh.
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) -
istioctl/pkg/workload/workload_test.go
} const goldenSuffix = ".golden" // 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")
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/pkg/nodeagent/informers_test.go
NodeName: NodeName, }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
ext: ext, nlDeps: nlDeps, cfg: cfg, } // By detecting iptables versions *here* once-for-all we are // committing to using the same binary/variant (legacy or nft) // within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to // redetect for each pod anyway. //
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/nodeagent/net_test.go
netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns runtime.GC() assertNSClosed(t, closed) } func TestServerDeletePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent) // All this to say, that we want to make sure that message to ztunnel are sent from a single goroutine // so we don't mix messages and acks. // nolint: unparam func (z *ztunnelServer) handleConn(ctx context.Context, conn *ZtunnelConnection) error { defer conn.Close()
Go - Registered: Wed May 08 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
"Address to listen on. Only accepts IP address or localhost as a value. "+ "When localhost is supplied, istioctl will try to bind on both 127.0.0.1 and ::1 "+ "and will fail if neither of these address are available to bind.") dashboardCmd.PersistentFlags().BoolVar(&browser, "browser", true, "When --browser is supplied as false, istioctl dashboard will not open the browser. "+
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
operator/cmd/mesh/install.go
// cluster. See GenManifests for more description of the manifest generation process. // // force validation warnings are written to logger but command is not aborted // DryRun all operations are done but nothing is written // // Returns final IstioOperator after installation if successful.
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)