- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 123 for HEvent (0.17 sec)
-
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/parameters/BuildProgressListenerAdapter.java
} else { throw new IllegalArgumentException("Unexpected event type: " + event); } } private void broadcastProgressEvent(ProgressEvent event) { if (event instanceof TestProgressEvent) { testProgressListeners.getSource().statusChanged(event); } else if (event instanceof TaskProgressEvent) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 09:03:53 UTC 2024 - 67.5K bytes - Viewed (0) -
cmd/api-errors.go
apiErr = ErrAdminBucketQuotaExceeded case *event.ErrInvalidEventName: apiErr = ErrEventNotification case *event.ErrInvalidARN: apiErr = ErrARNNotification case *event.ErrARNNotFound: apiErr = ErrARNNotification case *levent.ErrInvalidARN: apiErr = ErrLambdaARNInvalid case *levent.ErrARNNotFound: apiErr = ErrLambdaARNNotFound case *event.ErrUnknownRegion: apiErr = ErrRegionNotification
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (0) -
src/internal/trace/order.go
if err := validateCtx(curCtx, event.SchedReqs{Thread: event.MustHave, Proc: event.MayHave, Goroutine: event.MayHave}); err != nil { return curCtx, false, err } o.queue.push(Event{table: evt, ctx: curCtx, base: *ev}) return curCtx, true, nil } // Next returns the next event in the ordering. func (o *ordering) Next() (Event, bool) { return o.queue.pop() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
expectEvents(t, fx, Event{Type: "xds full", ID: "*.google.com"}, Event{Type: "xds full", ID: "*.istio.io"}, Event{Type: "xds full", ID: "tcpstatic.com"}, Event{Type: "service", ID: "*.google.com", Namespace: httpDNS.Namespace}, Event{Type: "eds cache", ID: "*.google.com", Namespace: httpDNS.Namespace}, Event{Type: "service", ID: "*.istio.io", Namespace: httpDNSRR.Namespace},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// However, we then need to check if this was called as a result // of a bookmark event or regular Add/Update/Delete operation by // checking if resourceVersion here has changed. if event.Type != watch.Bookmark { c.dispatchEvent(&event) } lastProcessedResourceVersion = event.ResourceVersion metrics.EventsCounter.WithLabelValues(c.groupResource.String()).Inc() case <-bookmarkTimer.C():
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
} defer w.Stop() received := 0 resChan := w.ResultChan() for event := range resChan { received++ t.Logf("event type: %v, events received so far: %d", event.Type, received) if event.Type != watch.Added { t.Errorf("unexpected event type, expected: %s, got: %s, event: %v", watch.Added, event.Type, event) } } // Since the watch is stopped after the interval is invalidated,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
} // check if there is an event that makes this Pod schedulable based on pInfo.UnschedulablePlugins. queueingStrategy := queueSkip for event := inFlightPod.Next(); event != nil; event = event.Next() { e, ok := event.Value.(*clusterEvent) if !ok { // Must be another in-flight Pod (*v1.Pod). Can be ignored. continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
docs/bucket/notifications/README.md
Use client tools like `mc` to set and listen for event notifications using the [`event` sub-command](https://min.io/docs/minio/linux/reference/minio-mc/mc-event-add.html). MinIO SDK's [`BucketNotification` APIs](https://min.io/docs/minio/linux/developers/go/API.html#setbucketnotification-ctx-context-context-bucketname-string-config-notification-configuration-error) can also be used. The notification message MinIO sends to publish an event is a JSON message with the following [structure](http...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 84K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
addEventsFromCreatedPods := func(createdInitialPods []*example.Pod) []watch.Event { var ret []watch.Event for _, createdPod := range createdInitialPods { ret = append(ret, watch.Event{Type: watch.Added, Object: createdPod}) } return ret } initialEventsEndFromLastCreatedPod := func(createdInitialPods []*example.Pod) []watch.Event { return []watch.Event{{ Type: watch.Bookmark, Object: &example.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 21:47:24 UTC 2024 - 76.1K bytes - Viewed (0)