- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for Weaver (0.17 sec)
-
cni/pkg/nodeagent/informers_test.go
fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "", ).Return(nil) server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // label the namespace
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/log/uds.go
log.Errorf("Error running UDS log server: %v", err) } }() go func() { <-stop if err := l.loggingServer.Close(); err != nil { log.Errorf("CNI log server terminated with error: %v", err) } else { log.Debug("CNI log server terminated") } }() return nil } func (l *UDSLogger) handleLog(w http.ResponseWriter, req *http.Request) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
} func (mrdir *mockInterceptRuleMgr) Program(podName, netns string, redirect *Redirect) error { mrdir.lastRedirect = append(mrdir.lastRedirect, redirect) return nil } // returns the test server URL and a dispose func for the test server func setupCNIEventClientWithMockServer(serverErr bool) (string, func() bool) { cniAddServerCalled := false // replace the global CNI client with mock
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 17.5K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
) ([]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 isMCP := strings.HasSuffix(opts.Xds, ".googleapis.com") || strings.HasSuffix(opts.Xds, ".googleapis.com:443") if isMCP { // Special credentials handling when using ASM Managed Control Plane.
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
cni/test/install_cni.go
t.Logf("Copying %v into temp k8s serviceaccount dir %v", f, tempK8sSvcAcctDir) cp(wd+k8sSvcAcctSubDir+f, tempK8sSvcAcctDir+"/"+f, t) } t.Logf("Finished pre-populating working dirs") } // create an install server instance and run it, blocking until it gets terminated // via context cancellation func startInstallServer(ctx context.Context, serverConfig *config.Config, t *testing.T) { readyFlag := &atomic.Value{}
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
return nil, nil } } func extract(gzipStream io.Reader, destination string) error { uncompressedStream, err := gzip.NewReader(gzipStream) if err != nil { return fmt.Errorf("create gzip reader: %v", err) } tarReader := tar.NewReader(uncompressedStream) for { header, err := tarReader.Next() if err == io.EOF { break } if err != nil {
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Thu Feb 22 08:32:23 GMT 2024 - 42K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
} server := restCfg.Host if strings.Contains(server, "127.0.0.1") || strings.Contains(server, "localhost") { return server, fmt.Errorf( "server in Kubeconfig is %s. This is likely not reachable from inside the cluster, "+ "if you're using Kubernetes in Docker, pass --server with the container IP for the API Server", server), nil } return server, nil, nil } const (
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret_test.go
if err != nil { t.Fatalf("could not parse k8s objects from generated YAML: %v", err) } mustFindObject(t, objs, "istio-reader-service-account", "ServiceAccount") mustFindObject(t, objs, "istio-reader-clusterrole-istio-system", "ClusterRole") mustFindObject(t, objs, "istio-reader-clusterrole-istio-system", "ClusterRoleBinding") } func mustFindObject(t test.Failer, objs object.K8sObjects, name, kind string) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 20.6K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
// - https://www.kernel.org/doc/Documentation/cgroup-v2.txt func GetCgroups(procCgroupData bytes.Buffer) ([]Cgroup, error) { reader := bytes.NewReader(procCgroupData.Bytes()) var cgroups []Cgroup scanner := bufio.NewScanner(reader) for scanner.Scan() { token := scanner.Text() substrings := strings.SplitN(token, ":", 3) if len(substrings) < 3 {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug_test.go
tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, } return tf }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 4.5K bytes - Viewed (0)