- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 66 for Network (0.19 sec)
-
cmd/metrics-v3-system-network.go
internodeRecvBytesTotalMD = NewCounterMD(internodeRecvBytesTotal, "Total number of bytes received from other peer nodes") ) // loadNetworkInternodeMetrics - reads internode network metrics. // // This is a `MetricsLoaderFn`. func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error { connStats := globalConnStats.toServerConnStats() rpcStats := rest.GetRPCStats()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 2.4K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
return cniConfig, nil } if len(template.cniNetworkConfig) > 0 { installLog.Infof("Using CNI config template from CNI_NETWORK_CONFIG environment variable.") return []byte(template.cniNetworkConfig), nil } return nil, fmt.Errorf("need CNI_NETWORK_CONFIG or CNI_NETWORK_CONFIG_FILE to be set") } func replaceCNIConfigVars(cniConfig []byte, vars cniConfigVars) []byte { cniConfigStr := string(cniConfig)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/repair/netns.go
// * use crictl to inspect the pod; this returns the bind-mounted network namespace file. // * /var/lib/cni/results shows the outputs of CNI plugins; this containers the bind-mounted network namespace file. // // Instead, we traverse the procfs. Comments on this method are inline. func getPodNetNs(pod *corev1.Pod) (string, error) { // First, find the network namespace id by looking the interface with the given Pod IP.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/admin-server-info.go
} _, present := network[nodeName] if !present { if err := isServerResolvable(endpoint, 5*time.Second); err == nil { network[nodeName] = string(madmin.ItemOnline) } else { network[nodeName] = string(madmin.ItemOffline) // log once the error peersLogOnceIf(context.Background(), err, nodeName) } } } } var memstats runtime.MemStats runtime.ReadMemStats(&memstats)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.8K bytes - Viewed (0) -
cni/pkg/log/uds.go
"encoding/json" "fmt" "io" "net/http" "strings" "sync" "time" "istio.io/istio/cni/pkg/constants" "istio.io/istio/pkg/log" "istio.io/istio/pkg/network" "istio.io/istio/pkg/uds" ) var pluginLog = log.RegisterScope("cni", "CNI network plugin") type UDSLogger struct { mu sync.Mutex loggingServer *http.Server } type cniLog struct { Level string `json:"level"`
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) -
internal/http/check_port_linux.go
defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
cmd/storage-rest-client.go
case strings.Contains(err.Error(), "server closed idle connection"): return true } return false } // Converts network error to storageErr. This function is // written so that the storageAPI errors are consistent // across network disks. func toStorageErr(err error) error { if err == nil { return nil } if isNetworkError(err) { return errDiskNotFound }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/peer-rest-client.go
return nil } gridConn.Store(gc) return gc }, } } // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints() // after verifying format.json
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
route "github.com/envoyproxy/go-control-plane/envoy/config/route/v3" hcm "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/http_connection_manager/v3" tcp "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/tcp_proxy/v3" "sigs.k8s.io/yaml" "istio.io/istio/istioctl/pkg/util/proto" "istio.io/istio/pilot/pkg/networking/util" "istio.io/istio/pilot/pkg/util/protoconv"
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/monitoring/monitoring.go
// limitations under the License. package monitoring import ( "fmt" "net" "net/http" "istio.io/istio/pkg/log" "istio.io/istio/pkg/monitoring" "istio.io/istio/pkg/network" ) func SetupMonitoring(port int, path string, stop <-chan struct{}) { if port <= 0 { return } mux := http.NewServeMux() var listener net.Listener var err error
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 07:54:01 GMT 2023 - 1.5K bytes - Viewed (0)