- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 589 for seni (3.54 sec)
-
tests/integration/telemetry/api/accesslogs_test.go
} } else { http = echo.HTTP{ Path: "/" + testID, } } // For positive test, we use the same ID and repeatedly send requests and check the count // Retry a bit to get the logs. There is some delay before they are output(MeshConfig will not take effect immediately),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/metrics.go
func networkMetricsPrometheus(ch chan<- prometheus.Metric) { connStats := globalConnStats.toServerConnStats() // Network Sent/Received Bytes (internode) ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(interNodeNamespace, "tx", "bytes_total"), "Total number of bytes sent to the other peer nodes by current MinIO server instance", nil, nil), prometheus.CounterValue,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/zdsapi/zds.pb.go
} func (x *AddWorkload) GetWorkloadInfo() *WorkloadInfo { if x != nil { return x.WorkloadInfo } return nil } // Keep workload that we can't find in the fd cache. This can only be sent before SnapshotSent is sent // to signal ztunnel to not delete the workload if it has it. type KeepWorkload struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 02:27:10 UTC 2024 - 25.8K bytes - Viewed (0) -
manifests/addons/dashboards/ztunnel-dashboard.gen.json
"type": "timeseries" }, { "datasource": { "type": "datasource", "uid": "-- Mixed --" }, "description": "Bytes sent and recieved per instance", "fieldConfig": { "defaults": { "custom": { "fillOpacity": 10, "gradientMode": "hue",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/kubelet/pleg/generic_test.go
} } func TestRelisting(t *testing.T) { testPleg := newTestGenericPLEG() pleg, runtime := testPleg.pleg, testPleg.runtime ch := pleg.Watch() // The first relist should send a PodSync event to each pod. runtime.AllPodList = []*containertest.FakePod{ {Pod: &kubecontainer.Pod{ ID: "1234", Containers: []*kubecontainer.Container{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 24.8K bytes - Viewed (0) -
cmd/http-stats.go
internodeInputBytes: s.getInternodeInputBytes(), // Traffic internode received internodeOutputBytes: s.getInternodeOutputBytes(), // Traffic internode sent s3InputBytes: s.getS3InputBytes(), // Traffic S3 received s3OutputBytes: s.getS3OutputBytes(), // Traffic S3 sent } } // Prepare new ConnStats structure func newConnStats() *connStats { return &connStats{} } type bucketS3RXTX struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 06:25:13 UTC 2024 - 11.5K bytes - Viewed (0) -
src/internal/fuzz/worker.go
// Worker terminated by a signal that probably wasn't caused by a // specific input to the fuzz function. For example, on Linux, // the kernel (OOM killer) may send SIGKILL to a process using a lot // of memory. Or the shell might send SIGHUP when the terminal // is closed. Don't record a crasher. return fmt.Errorf("fuzzing process terminated by unexpected signal; no crash will be recorded: %v", w.waitErr) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
cmd/data-scanner.go
return s.newCache, nil } // sendUpdate() should be called on a regular basis when the newCache contains more recent total than previously. // May or may not send an update upstream. func (f *folderScanner) sendUpdate() { // Send at most an update every minute. if f.updates == nil || time.Since(f.lastUpdate) < time.Minute { return } if flat := f.updateCache.sizeRecursive(f.newCache.Info.Name); flat != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
credentials auth.Credentials, t *testing.T, ) { // test cases with sample input and expected output. testCases := []struct { method string bucketName string accessKey string secretKey string // Sent body body []byte // Expected response expectedRespStatus int lifecycleResponse []byte errorResponse APIErrorResponse shouldPass bool }{ // GET empty credentials {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/api/admissionregistration/v1alpha1/types.go
) // MatchPolicyType specifies the type of match policy. // +enum type MatchPolicyType string const ( // Exact means requests should only be sent to the webhook if they exactly match a given rule. Exact MatchPolicyType = "Exact" // Equivalent means requests should be sent to the webhook if they modify a resource listed in rules via another API group or version. Equivalent MatchPolicyType = "Equivalent" ) // +genclient
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 05 20:06:13 UTC 2023 - 33.8K bytes - Viewed (0)