- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 110 for notifiers (0.28 sec)
-
pkg/kubelet/certificate/kubelet.go
keyFile string dynamicCertificateContent *dynamiccertificates.DynamicCertKeyPairContent currentTLSCertificate atomic.Pointer[tls.Certificate] } // Enqueue implements the functions to be notified when the serving cert content changes. func (m *kubeletServerCertificateDynamicFileManager) Enqueue() { certContent, keyContent := m.dynamicCertificateContent.CurrentCertKeyContent()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
nanos: Long, ) { taskRunner.assertThreadHoldsLock() check(waitingCoordinatorTask == null) if (nanos == 0L) return // Yield until notified, interrupted, or the duration elapses. val waitUntil = nanoTime + nanos val self = currentTask waitingCoordinatorTask = self waitingCoordinatorNotified = false
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go
if err != nil { t.Fatalf("failed creating the server: %v", err) } // add poststart hook to know when the server is up. startedCh := make(chan struct{}) s.AddPostStartHookOrDie("test-notifier", func(context server.PostStartHookContext) error { close(startedCh) return nil }) preparedServer := s.PrepareRun() preparedServerErrors := make(chan error) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 15:52:39 UTC 2024 - 13.8K bytes - Viewed (0) -
analysis/analysis-api-impl-base/tests/org/jetbrains/kotlin/analysis/api/impl/base/test/cases/components/testUtils.kt
import org.jetbrains.kotlin.analysis.api.impl.base.KaMapBackedSubstitutor import org.jetbrains.kotlin.analysis.api.renderer.declarations.impl.KaDeclarationRendererForSource import org.jetbrains.kotlin.analysis.api.renderer.declarations.modifiers.renderers.KaRendererKeywordFilter import org.jetbrains.kotlin.analysis.api.resolution.KaApplicableCallCandidateInfo import org.jetbrains.kotlin.analysis.api.resolution.KaCall
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Jun 05 16:16:39 UTC 2024 - 15.3K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/provider/KotlinScriptEvaluator.kt
} @Synchronized override fun onReuse() { scope?.let { // Recreate the script scope and ClassLoader, so that things that use scopes are notified that the scope exists it.onReuse() require(loadedClass!!.classLoader == it.localClassLoader) } } private fun prepareClassLoaderScope() =
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 10:23:24 UTC 2024 - 17.1K bytes - Viewed (0) -
cmd/batch-rotate.go
Prefix string `yaml:"prefix" json:"prefix"` Encryption BatchJobKeyRotateEncryption `yaml:"encryption" json:"encryption"` } // Notify notifies notification endpoint if configured regarding job failure or success. func (r BatchJobKeyRotateV1) Notify(ctx context.Context, ri *batchJobInfo) error { return notifyEndpoint(ctx, ri, r.Flags.Notify.Endpoint, r.Flags.Notify.Token)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/build/DefaultBuildLifecycleController.java
return ExecutionResult.maybeFailing(() -> buildListener.buildFinished(buildResult)); }); } /** * <p>Adds a listener to this build instance. The listener is notified of events which occur during the execution of the build. * See {@link org.gradle.api.invocation.Gradle#addListener(Object)} for supported listener types.</p> *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 11:17:11 UTC 2024 - 16.5K bytes - Viewed (0) -
platforms/software/build-init/src/integTest/groovy/org/gradle/buildinit/plugins/BuildInitInteractiveIntegrationTest.groovy
* limitations under the License. */ package org.gradle.buildinit.plugins import org.gradle.buildinit.plugins.fixtures.ScriptDslFixture import org.gradle.buildinit.plugins.internal.modifiers.BuildInitDsl import org.gradle.integtests.fixtures.executer.ExecutionResult import org.gradle.integtests.fixtures.executer.GradleHandle import org.gradle.integtests.fixtures.executer.UnexpectedBuildFailure
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 10 12:58:10 UTC 2024 - 18.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/groovy/scripts/internal/DefaultScriptCompilationHandler.java
} @Override public void onReuse() { if (scriptClass != null) { // Recreate the script scope and ClassLoader, so that things that use scopes are notified that the scope exists scope.onReuse(); assert scriptClass.getClassLoader() == scope.getLocalClassLoader(); } } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 20.6K bytes - Viewed (0) -
src/crypto/tls/quic.go
Kind: QUICHandshakeDone, }) } func (c *Conn) quicRejectedEarlyData() { c.quic.events = append(c.quic.events, QUICEvent{ Kind: QUICRejectedEarlyData, }) } // quicWaitForSignal notifies the QUICConn that handshake progress is blocked, // and waits for a signal that the handshake should proceed. // // The handshake may become blocked waiting for handshake bytes
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0)