Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 68 for Microseconds (0.3 sec)

  1. cmd/data-scanner.go

    	return &dynamicSleeper{
    		factor:    factor,
    		cycle:     make(chan struct{}),
    		maxSleep:  maxWait,
    		minSleep:  100 * time.Microsecond,
    		isScanner: isScanner,
    	}
    }
    
    // Timer returns a timer that has started.
    // When the returned function is called it will wait.
    func (d *dynamicSleeper) Timer(ctx context.Context) func() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:43:17 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    	podResources := cm.ResourceConfigForPod(pod, m.cpuCFSQuota, uint64((m.cpuCFSQuotaPeriod.Duration)/time.Microsecond), false)
    	if podResources == nil {
    		klog.ErrorS(nil, "Unable to get resource configuration", "pod", pod.Name)
    		result.Fail(fmt.Errorf("Unable to get resource configuration processing resize for pod %s", pod.Name))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue_test.go

    		p := st.MakePod().Name(fmt.Sprintf("test-pod-%v", i)).Namespace("ns1").UID(fmt.Sprintf("tp00%v", i)).Priority(highPriority).Node("node1").NominatedNodeName("node1").Obj()
    		q.Add(logger, p)
    	}
    	c.Step(time.Microsecond)
    	// Simulate a pod being popped by the scheduler, determined unschedulable, and
    	// then moved back to the active queue.
    	p1, err := q.Pop(logger)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  4. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      // Note that the APIVersion field is not related to the Subresource field and
      // it always corresponds to the version of the main resource.
      optional string subresource = 8;
    }
    
    // MicroTime is version of Time with microsecond level precision.
    //
    // +protobuf.options.marshal=false
    // +protobuf.as=Timestamp
    // +protobuf.options.(gogoproto.goproto_stringer)=false
    message MicroTime {
      // Represents seconds of UTC time since Unix epoch
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      // Note that the APIVersion field is not related to the Subresource field and
      // it always corresponds to the version of the main resource.
      optional string subresource = 8;
    }
    
    // MicroTime is version of Time with microsecond level precision.
    //
    // +protobuf.options.marshal=false
    // +protobuf.as=Timestamp
    // +protobuf.options.(gogoproto.goproto_stringer)=false
    message MicroTime {
      // Represents seconds of UTC time since Unix epoch
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 53.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation_test.go

    			for _, err := range errs {
    				t.Errorf("unexpected error: %v", err)
    			}
    
    			// test context cancellation
    			found := false
    			evalCtx, cancel := context.WithTimeout(ctx, time.Microsecond)
    			cancel()
    			errs, _ = celValidator.Validate(evalCtx, field.NewPath("root"), &s, tt.obj, nil, celconfig.RuntimeCELCostBudget)
    			for _, err := range errs {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 17:14:10 UTC 2024
    - 159.9K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.26.md

    - Protobuf serialization of metav1.MicroTime timestamps (used in `Lease` and `Event` API objects) has been corrected to truncate to microsecond precision, to match the documented behavior and JSON/YAML serialization. Any existing persisted data is truncated to microsecond when read from etcd. ([#111936](https://github.com/kubernetes/kubernetes/pull/111936), [@haoruan](https://github.com/haoruan))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 14 16:24:51 UTC 2024
    - 425.7K bytes
    - Viewed (0)
  8. api/openapi-spec/v3/apis__coordination.k8s.io__v1_openapi.json

              }
            },
            "type": "object"
          },
          "io.k8s.apimachinery.pkg.apis.meta.v1.MicroTime": {
            "description": "MicroTime is version of Time with microsecond level precision.",
            "format": "date-time",
            "type": "string"
          },
          "io.k8s.apimachinery.pkg.apis.meta.v1.ObjectMeta": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 136.6K bytes
    - Viewed (0)
  9. api/openapi-spec/v3/apis__events.k8s.io__v1_openapi.json

              }
            },
            "type": "object"
          },
          "io.k8s.apimachinery.pkg.apis.meta.v1.MicroTime": {
            "description": "MicroTime is version of Time with microsecond level precision.",
            "format": "date-time",
            "type": "string"
          },
          "io.k8s.apimachinery.pkg.apis.meta.v1.ObjectMeta": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 142.7K bytes
    - Viewed (0)
  10. src/reflect/all_test.go

    			// select will just proceed immediately. Not a big deal.
    			// For short tests we can grow [sic] the timeout a bit without fear of taking too long
    			pause := 10 * time.Microsecond
    			if testing.Short() {
    				pause = 100 * time.Microsecond
    			}
    			time.AfterFunc(pause, helper)
    		}
    
    		// Run select.
    		i, recv, recvOK, panicErr := runSelect(cases, info)
    		if panicErr != nil && !canPanic {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 218.8K bytes
    - Viewed (0)
Back to top