Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for notreally (0.21 sec)

  1. istioctl/pkg/writer/ztunnel/configdump/workload.go

    		return svc.Name
    	}
    
    	return "NA" // Shouldn't normally reach here
    }
    
    func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string {
    	if svc.Waypoint == nil {
    		return "None"
    	}
    
    	if svc, ok := services[svc.Waypoint.Destination]; ok {
    		return svc.Name
    	}
    
    	return "NA" // Shouldn't normally reach here
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    	// Set some defaults
    	s := &Server{
    		ctx:        ctx,
    		kubeClient: client,
    		isReady:    ready,
    		dataplane: &meshDataplane{
    			kubeClient: client.Kube(),
    			netServer:  netServer,
    		},
    	}
    	s.NotReady()
    	s.handlers = setupHandlers(s.ctx, s.kubeClient, s.dataplane, args.SystemNamespace)
    
    	cniServer := startCniPluginServer(ctx, pluginSocket, s.handlers, s.dataplane)
    	err = cniServer.Start()
    	if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  3. src/cmd/cgo/godefs.go

    	if err != nil {
    		return "<" + err.Error() + ">"
    	}
    	return gofmtBuf.String()
    }
    
    // gofmtLineReplacer is used to put a gofmt-formatted string for an
    // AST expression onto a single line. The lexer normally inserts a
    // semicolon at each newline, so we can replace newline with semicolon.
    // However, we can't do that in cases where the lexer would not insert
    // a semicolon. We only have to worry about cases that can occur in an
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Sep 08 14:33:35 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables.go

    	// healthcheck port, just like we used to. Otherwise, we can't assume it's local-node privileged traffic, and will capture and process it normally.
    	//
    	// All this is necessary because quite often apps use the same port for healthchecks as they do for reg. traffic, and
    	// we cannot make assumptions there.
    
    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)
  5. cni/pkg/nodeagent/options.go

    )
    
    const (
    	// to reliably identify kubelet healthprobes from inside the pod (versus standard kube-proxy traffic,
    	// since the IP is normally the same), we SNAT identified host probes in the host netns to a fixed
    	// APIPA/"link-local" IP.
    	//
    	// It doesn't matter what this IP is, so long as it's not routable and doesn't collide with anything else.
    	//
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  6. docs/sts/assume-role.go

    	minioClient, err := minio.New(stsEndpointURL.Host, opts)
    	if err != nil {
    		log.Fatalf("Error initializing client: %v", err)
    	}
    
    	// Use minIO Client object normally like the regular client.
    	if bucketToList == "" {
    		bucketToList = minioUsername
    	}
    	fmt.Printf("Calling list objects on bucket named `%s` with temp creds:\n===\n", bucketToList)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 16:09:55 GMT 2024
    - 4K bytes
    - Viewed (1)
  7. cni/pkg/install/install.go

    	default:
    		// Valid configuration; set isReady to true and wait for modifications before checking again
    		setReady(in.isReady)
    		cniInstalls.With(resultLabel.Value(resultSuccess)).Increment()
    		// Pod set to "NotReady" before termination
    		return watcher.Wait(ctx)
    	}
    }
    
    // checkValidCNIConfig returns an error if an invalid CNI configuration is detected
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  8. src/archive/zip/writer.go

    	if w.cw.count != 0 {
    		panic("zip: SetOffset called after data was written")
    	}
    	w.cw.count = n
    }
    
    // Flush flushes any buffered data to the underlying writer.
    // Calling Flush is not normally necessary; calling Close is sufficient.
    func (w *Writer) Flush() error {
    	return w.cw.w.(*bufio.Writer).Flush()
    }
    
    // SetComment sets the end-of-central-directory comment field.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 04 14:28:57 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  9. src/archive/tar/reader.go

    	// Externally, Next iterates through the tar archive as if it is a series of
    	// files. Internally, the tar format often uses fake "files" to add meta
    	// data that describes the next file. These meta data "files" should not
    	// normally be visible to the outside. As such, this loop iterates through
    	// one or more "header files" until it finds a "normal file".
    	format := FormatUSTAR | FormatPAX | FormatGNU
    	for {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  10. src/cmd/cgo/gcc.go

    	c.float64 = c.Ident("float64")
    	c.complex64 = c.Ident("complex64")
    	c.complex128 = c.Ident("complex128")
    	c.void = c.Ident("void")
    	c.string = c.Ident("string")
    	c.goVoid = c.Ident("_Ctype_void")
    
    	// Normally cgo translates void* to unsafe.Pointer,
    	// but for historical reasons -godefs uses *byte instead.
    	if *godefs {
    		c.goVoidPtr = &ast.StarExpr{X: c.byte}
    	} else {
    		c.goVoidPtr = c.Ident("unsafe.Pointer")
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Nov 02 16:43:23 GMT 2023
    - 97K bytes
    - Viewed (0)
Back to top