- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for So (0.17 sec)
-
internal/http/listener.go
ClientWriteTimeout time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connection RecvBufSize int // SO_RECVBUF size for the socket connection, NOTE: this sets server and client connection Interface string // This is a VRF device passed via `--interface` flag
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/metrics-realtime.go
CollectedAt: UTCNow(), } cm, err := c.Times(false) if err != nil { m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (cpuTimes)", byHostName, err.Error())) } else { // not collecting per-cpu stats, so there will be only one element if len(cm) == 1 { m.Aggregated.CPU.TimesStat = &cm[0] } else { m.Errors = append(m.Errors, fmt.Sprintf("%s: Expected one CPU stat, got %d", byHostName, len(cm))) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
handler := h.listMetrics(path) if handler == nil { return notFoundHandler } return handler } // In each of the following cases, we check if the collect path is a // descendant of `path`, and if so, we add the corresponding gatherer to // the list of gatherers. This way, /api/a will return all metrics returned // by /api/a/b and /api/a/c (and any other matching descendant collector // paths).
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/grid/manager.go
type Manager struct { // ID is an instance ID, that will change whenever the server restarts. // This allows remotes to keep track of whether state is preserved. ID uuid.UUID // Immutable after creation, so no locks. targets map[string]*Connection // serverside handlers. handlers handlers // local host name. local string // Validate incoming requests. authRequest func(r *http.Request) error }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
} // Remove and return the Netns for the given uid // No need to return NetnsCloser here it will be closed automatically on GC. // (it may be used in parallel by other parts of the code, so we want it to be used only when not used) func (p *podNetnsCache) Take(uid string) Netns { // lock current pod map p.mu.Lock() defer p.mu.Unlock() if ns, ok := p.currentPodCache[uid]; ok {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/nodeagent/options.go
// 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. // // IPv6 link local ranges are designed to be collision-resistant by default, and so probably never need to be overridden DefaultHostProbeSNATIP = "169.254.7.127" DefaultHostProbeSNATIPV6 = "fd16:9254:7127:1337:ffff:ffff:ffff:ffff" )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
Namespace string InternalDebugAllIstiod bool } func (s *DebugWriter) PrintAll(drs map[string]*discovery.DiscoveryResponse) error { // Gather the statuses before printing so they may be sorted mappedResp := map[string]string{} for id, dr := range drs { for _, resource := range dr.Resources { if s.InternalDebugAllIstiod { mappedResp[id] = string(resource.Value) + "\n"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
// Note that if the ipset already exist by name, Create will not return an error. // // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps) 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) -
cni/pkg/nodeagent/cni-watcher_test.go
dpServer := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, dpServer, "istio-system") // We are not going to start the server, so the sockpath is irrelevant pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer) // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/is-dir-empty_linux.go
"syscall" ) // Returns true if no error and there is no object or prefix inside this directory func isDirEmpty(dirname string, legacy bool) bool { if legacy { // On filesystems such as btrfs, nfs this is not true, so fallback // to performing readdir() instead. entries, err := readDirN(dirname, 1) if err != nil { return false } return len(entries) == 0 } var stat syscall.Stat_t
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 15:17:08 GMT 2024 - 1.4K bytes - Viewed (0)