Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 492 for CLOCK (0.06 sec)

  1. pkg/kubelet/active_deadline.go

    	recorder record.EventRecorder,
    	clock clock.Clock,
    ) (*activeDeadlineHandler, error) {
    
    	// check for all required fields
    	if clock == nil || podStatusProvider == nil || recorder == nil {
    		return nil, fmt.Errorf("required arguments must not be nil: %v, %v, %v", clock, podStatusProvider, recorder)
    	}
    	return &activeDeadlineHandler{
    		clock:             clock,
    		podStatusProvider: podStatusProvider,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 10 10:20:09 UTC 2021
    - 3.2K bytes
    - Viewed (0)
  2. pkg/kubelet/util/queue/work_queue.go

    }
    
    type basicWorkQueue struct {
    	clock clock.Clock
    	lock  sync.Mutex
    	queue map[types.UID]time.Time
    }
    
    var _ WorkQueue = &basicWorkQueue{}
    
    // NewBasicWorkQueue returns a new basic WorkQueue with the provided clock
    func NewBasicWorkQueue(clock clock.Clock) WorkQueue {
    	queue := make(map[types.UID]time.Time)
    	return &basicWorkQueue{queue: queue, clock: clock}
    }
    
    func (q *basicWorkQueue) GetWork() []types.UID {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 10 10:20:09 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  3. pkg/kubelet/util/queue/work_queue_test.go

    	// Dial the time to 1 hour ahead.
    	clock.Step(time.Hour)
    	expected = []types.UID{types.UID("foo3"), types.UID("foo4")}
    	compareResults(t, expected, q.GetWork())
    	compareResults(t, []types.UID{}, q.GetWork())
    }
    
    func TestNewBasicWorkQueue(t *testing.T) {
    	tests := []struct {
    		clock             clock.Clock
    		expectedWorkQueue WorkQueue
    	}{
    		{
    			clock:             clock.RealClock{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. platforms/core-runtime/build-profile/src/main/java/org/gradle/profile/ProfileCoordinator.java

    import org.gradle.internal.time.Clock;
    
    @ServiceScope(Scope.BuildTree.class)
    public class ProfileCoordinator implements RootBuildLifecycleListener {
        private final BuildProfile profile;
        private final ReportGeneratingProfileListener generator;
        private final Clock clock;
    
        public ProfileCoordinator(BuildProfile profile, ReportGeneratingProfileListener generator, Clock clock) {
            this.profile = profile;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 02:21:10 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  5. platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/services/DefaultStyledTextOutputFactory.java

    import org.gradle.internal.time.Clock;
    
    public class DefaultStyledTextOutputFactory extends AbstractStyledTextOutputFactory implements StyledTextOutputFactory {
        private final OutputEventListener outputEventListener;
        private final Clock clock;
    
        public DefaultStyledTextOutputFactory(OutputEventListener outputEventListener, Clock clock) {
            this.outputEventListener = outputEventListener;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:05:18 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting_test.go

    		}
    	}()
    	clock.Run(nil)
    	expectGotValue(t, gots, aval)
    	goGetAndExpect(t, clock, counter, wr, gots, aval)
    	later := time.Now()
    	bval := &later
    	func() {
    		lock.Lock()
    		defer lock.Unlock()
    		if wr.Set(bval) {
    			t.Error("second Set() returned true")
    		}
    	}()
    	goGetAndExpect(t, clock, counter, wr, gots, aval)
    	counter.Add(1) // account for unblocking the receive on doneCh
    	close(doneCh)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 10 14:37:53 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  7. platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/junit/JUnitTestClassProcessor.java

    import org.gradle.internal.id.IdGenerator;
    import org.gradle.internal.time.Clock;
    
    public class JUnitTestClassProcessor extends AbstractJUnitTestClassProcessor {
    
        private final IdGenerator<?> idGenerator;
        private final JUnitSpec spec;
        private final Clock clock;
    
        public JUnitTestClassProcessor(JUnitSpec spec, IdGenerator<?> idGenerator, ActorFactory actorFactory, Clock clock) {
            super(actorFactory);
            this.spec = spec;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 15:59:04 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go

    	})
    }
    
    // TestableConfig carries the parameters to an implementation that is testable
    type TestableConfig struct {
    	// Name of the controller
    	Name string
    
    	// Clock to use in timing deliberate delays
    	Clock clock.PassiveClock
    
    	// AsFieldManager is the string to use in the metadata for
    	// server-side apply.  Normally this is
    	// `ConfigConsumerAsFieldManager`.  This is exposed as a parameter
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache.go

    }
    
    // NewLRUExpireCacheWithClock creates an expiring cache with the given size, using the specified clock to obtain the current time.
    func NewLRUExpireCacheWithClock(maxSize int, clock Clock) *LRUExpireCache {
    	if maxSize <= 0 {
    		panic("maxSize must be > 0")
    	}
    
    	return &LRUExpireCache{
    		clock:   clock,
    		maxSize: maxSize,
    		entries: map[interface{}]*list.Element{},
    	}
    }
    
    type cacheEntry struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 03 18:40:48 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  10. platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/services/LoggingBackedStyledTextOutput.java

        private final LogLevel logLevel;
        private final Clock clock;
        private final StringBuilder buffer = new StringBuilder();
        private List<StyledTextOutputEvent.Span> spans = new ArrayList<StyledTextOutputEvent.Span>();
        private Style style = Style.Normal;
    
        public LoggingBackedStyledTextOutput(OutputEventListener listener, String category, LogLevel logLevel, Clock clock) {
            this.listener = listener;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:05:18 UTC 2023
    - 2.8K bytes
    - Viewed (0)
Back to top