- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 492 for CLOCK (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)