- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Subscriber (0.28 sec)
-
cmd/peer-rest-server.go
// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write() ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool { if ev.S3.Bucket.Name != "" && values.Get(peerRESTListenBucket) != "" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/background-heal-ops.go
} func activeListeners() int { // Bucket notification and http trace are not costly, it is okay to ignore them // while counting the number of concurrent connections return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers()) } func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) { // No need to wait run at full speed. if maxIO <= 0 { return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } } }() peers, _ := newPeerRestClients(globalEndpoints) err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool { if ev.S3.Bucket.Name != "" && bucketName != "" { if ev.S3.Bucket.Name != bucketName { return false } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
return s.iptablesConfigurator.CreateInpodRules(&HostProbeSNATIP) }); err != nil { log.Errorf("failed to update POD inpod: %s/%s %v", pod.Namespace, pod.Name, err) return err } log.Debug("notifying subscribed node proxies") if err := s.sendPodToZtunnelAndWaitForAck(ctx, pod, openNetns); err != nil { // we must return PartialAdd error here. the pod was injected with iptables rules,
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.1K bytes - Viewed (1) -
docs/en/docs/help-fastapi.md
Or would you like to get help with **FastAPI**? There are very simple ways to help (several involve just one or two clicks). And there are several ways to get help too. ## Subscribe to the newsletter You can subscribe to the (infrequent) [**FastAPI and friends** newsletter](newsletter.md){.internal-link target=_blank} to stay updated about: * News about FastAPI and friends 🚀 * Guides 📝 * Features ✨
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 13.7K bytes - Viewed (0) -
ReadMe.md
* [Kotlin YouTube Channel](https://www.youtube.com/channel/UCP7uiEZIqci43m22KDl0sNw) * [Forum](https://discuss.kotlinlang.org/) * [Kotlin Blog](https://blog.jetbrains.com/kotlin/) * [Subscribe to Kotlin YouTube channel](https://www.youtube.com/channel/UCP7uiEZIqci43m22KDl0sNw) * [Follow Kotlin on Twitter](https://twitter.com/kotlin) * [Public Slack channel](https://slack.kotlinlang.org/)
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Apr 11 14:28:46 GMT 2024 - 8.7K bytes - Viewed (0) -
cmd/admin-handlers.go
}, nil) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // Publish bootstrap events that have already occurred before client could subscribe. if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) { go globalBootstrapTracer.Publish(ctx, globalTrace) } for _, peer := range peers { if peer == nil { continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
maven-core/src/test/java/org/apache/maven/project/PomConstructionTest.java
assertEquals(1, ((List<?>) pom.getValue("mailingLists")).size()); assertEquals("project-mailing-list", pom.getValue("mailingLists[1]/name")); assertEquals("subscribe@", pom.getValue("mailingLists[1]/subscribe")); assertEquals("unsubscribe@", pom.getValue("mailingLists[1]/unsubscribe")); assertEquals("post@", pom.getValue("mailingLists[1]/post"));
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 93.2K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
XML - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Apr 23 13:29:46 GMT 2024 - 115.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.29.md
- `EnqueueExtensions` from plugins other than `PreEnqueue`, `PreFilter`, `Filter`, `Reserve` and `Permit` are now ignored. It reduces the number of kinds of cluster events the scheduler needs to subscribe/handle. ([#121571](https://github.com/kubernetes/kubernetes/pull/121571), [@sanposhiho](https://github.com/sanposhiho))
Plain Text - Registered: Fri Apr 26 09:05:10 GMT 2024 - Last Modified: Tue Apr 16 21:41:06 GMT 2024 - 299.9K bytes - Viewed (1)