- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 250 for notifiers (0.15 sec)
-
pkg/kubelet/eviction/memory_threshold_notifier.go
klog.V(3).InfoS("Eviction manager: setting notifier to capacity", "notifier", m.Description(), "capacity", memcgThreshold.String()) if m.notifier != nil { m.notifier.Stop() } newNotifier, err := m.factory.NewCgroupNotifier(m.cgroupPath, memoryUsageAttribute, memcgThreshold.Value()) if err != nil { return err } m.notifier = newNotifier go m.notifier.Start(m.events) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 21 00:36:14 UTC 2021 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/interfaces.go
Enqueue() } // Notifier is a way to add listeners type Notifier interface { // AddListener is adds a listener to be notified of potential input changes. // This is a noop on static providers. AddListener(listener Listener) } // CAContentProvider provides ca bundle byte content type CAContentProvider interface { Notifier // Name is just an identifier. Name() string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/initialization/DefaultBuildCancellationTokenSpec.groovy
then: !token.cancellationRequested when: token.cancel() then: token.cancellationRequested } def 'cancel notifies callbacks'() { def token = new DefaultBuildCancellationToken() def callback1 = Mock(Runnable) def callback2 = Mock(Runnable) token.addCallback(callback1)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat May 23 09:27:48 UTC 2015 - 3.7K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/api/internal/provider/ValueSourceProviderFactory.java
import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; import javax.annotation.Nullable; /** * Service to create providers from {@link ValueSource}s. * * Notifies interested parties when values are obtained from their sources. * * @since 6.1 */ @ServiceScope(Scope.Build.class) public interface ValueSourceProviderFactory {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:26:25 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/kubelet/eviction/types.go
// ThresholdNotifier manages CgroupNotifiers based on memory eviction thresholds, and performs a function // when memory eviction thresholds are crossed type ThresholdNotifier interface { // Start calls the notifier function when the CgroupNotifier notifies the ThresholdNotifier that an event occurred Start() // UpdateThreshold updates the memory cgroup threshold based on the metrics provided.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 7.1K bytes - Viewed (0) -
platforms/documentation/docs/src/docsTest/java/org/gradle/docs/samples/RunNotifierWrapper.java
private final RunNotifier notifier; public RunNotifierWrapper(RunNotifier notifier) { this.notifier = notifier; } @Override public void fireTestSuiteStarted(Description description) { notifier.fireTestSuiteStarted(description); } @Override public void fireTestSuiteFinished(Description description) { notifier.fireTestSuiteFinished(description); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 2.9K bytes - Viewed (0) -
maven-model/src/test/java/org/apache/maven/model/NotifierTest.java
import static org.junit.jupiter.api.Assertions.assertTrue; /** * Tests {@code Notifier}. * */ class NotifierTest { @Test void testHashCodeNullSafe() { new Notifier().hashCode(); } @Test void testEqualsNullSafe() { assertFalse(new Notifier().equals(null)); new Notifier().equals(new Notifier()); } @Test void testEqualsIdentity() {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 1.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/classpath/InstrumentedTest.groovy
class InstrumentedTest extends Specification { @Rule final SetSystemProperties systemProperties = new SetSystemProperties() def cleanup() { InstrumentedInputs.discardListener() } def "notifies listener when system property is used"() { def listener = withInstrumentedInputsListener() System.setProperty("prop", "value") when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Nov 11 00:37:04 UTC 2023 - 7.9K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/model/internal/registry/ModelGraphTest.groovy
class ModelGraphTest extends RegistrySpec { def graph = new ModelGraph(root()) def nodes = [:] def setup() { nodes[graph.root.path] = graph.root } def "notifies listener when node added"() { def listener = allAcceptingListener() def a = node("a") def b = node("b") given: graph.addListener(listener) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 7.8K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/TestResultProcessor.java
*/ @UsedByScanPlugin("test-distribution, test-retry") public interface TestResultProcessor { /** * Notifies this processor that a test has started execution. */ @UsedByScanPlugin("test-distribution") void started(TestDescriptorInternal test, TestStartEvent event); /** * Notifies this processor that a test has completed execution. */ @UsedByScanPlugin("test-distribution")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 20:33:30 UTC 2024 - 1.7K bytes - Viewed (0)