- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 808 for events (3.17 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
return NANOSECONDS.toMillis(stopwatch.instant - startTime); } private void assertEvents(String... events) { assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear()); } /** * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
package cmd import ( "context" ) const ( notificationCurrentSendInProgress = "current_send_in_progress" notificationEventsErrorsTotal = "events_errors_total" notificationEventsSentTotal = "events_sent_total" notificationEventsSkippedTotal = "events_skipped_total" ) var (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/event/targetlist.go
ntargets[k] = v } return ntargets } // Send - sends events to targets identified by target IDs. func (list *TargetList) Send(event Event, targetIDset TargetIDSet, sync bool) { if sync { list.sendSync(event, targetIDset) } else { list.sendAsync(event, targetIDset) } } func (list *TargetList) sendSync(event Event, targetIDset TargetIDSet) { var wg sync.WaitGroup for id := range targetIDset {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Listener.java
import org.apache.maven.api.annotations.Nonnull; /** * A listener for session events. * TODO: open this to other events like similar to {@code org.apache.maven.eventspy.EventSpy} * * @since 4.0.0 */ @Experimental @FunctionalInterface @Consumer public interface Listener { void onEvent(@Nonnull Event event);
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Mar 23 05:29:39 GMT 2023 - 1.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
throw AssertionError("full event sequence: $fullEventSequence", e) } } /** * Remove and return the next event from the recorded sequence. * * @param eventClass a class to assert that the returned event is an instance of, or null to * take any event class. * @param elapsedMs the time in milliseconds elapsed since the immediately-preceding event, or * -1L to take any duration. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/logger/help.go
Description: "mTLS certificate key for webhook authentication", Optional: true, Type: "string", Sensitive: true, }, config.HelpKV{ Key: BatchSize, Description: "Number of events per HTTP send to webhook target", Optional: true, Type: "number", }, config.HelpKV{ Key: QueueSize, Description: "configure channel queue size for webhook targets",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 20:17:46 GMT 2024 - 6.4K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
return &Watcher{ watcher: watcher, Events: fileModified, Errors: errChan, }, nil } func watchFiles(watcher *fsnotify.Watcher, fileModified chan struct{}, errChan chan error) { for { select { case event, ok := <-watcher.Events: if !ok { return } if event.Op&(fsnotify.Create|fsnotify.Write|fsnotify.Remove) != 0 { log.Infof("file modified: %v", event.Name) fileModified <- struct{}{} }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/ExecutionListener.java
void projectDiscoveryStarted(ExecutionEvent event); void sessionStarted(ExecutionEvent event); void sessionEnded(ExecutionEvent event); void projectSkipped(ExecutionEvent event); void projectStarted(ExecutionEvent event); void projectSucceeded(ExecutionEvent event); void projectFailed(ExecutionEvent event); void mojoSkipped(ExecutionEvent event);
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 2K bytes - Viewed (0) -
tests/test_tutorial/test_events/test_tutorial001.py
from fastapi.testclient import TestClient @pytest.fixture(name="app", scope="module") def get_app(): with pytest.warns(DeprecationWarning): from docs_src.events.tutorial001 import app yield app def test_events(app: FastAPI): with TestClient(app) as client: response = client.get("/items/foo") assert response.status_code == 200, response.text
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Wed Oct 18 12:36:40 GMT 2023 - 3.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
queue controllers.Queue cfg config.RepairConfig events kclient.EventRecorder repairedPods map[types.NamespacedName]types.UID } func NewRepairController(client kube.Client, cfg config.RepairConfig) (*Controller, error) { c := &Controller{ cfg: cfg, client: client, events: kclient.NewEventRecorder(client, "cni-repair"),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)