- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for PubSub (0.05 sec)
-
cmd/globals.go
// global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8) // global Listen system to send S3 API events to registered listeners globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0) // global console system to send console logs to // registered listeners globalConsoleSys *HTTPConsoleLoggerSys
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
"github.com/minio/minio/internal/event" "github.com/minio/minio/internal/grid" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/pubsub" "github.com/minio/mux" "github.com/minio/pkg/v3/logger/message/log" ) // To abstract a node over network. type peerRESTServer struct{} var ( // Types & Wrappers
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.32.md
- cloud.google.com/go/phishingprotection: v0.8.1 → v0.8.4 - cloud.google.com/go/policytroubleshooter: v1.8.0 → v1.10.2 - cloud.google.com/go/privatecatalog: v0.9.1 → v0.9.4 - cloud.google.com/go/pubsub: v1.33.0 → v1.34.0 - cloud.google.com/go/recaptchaenterprise/v2: v2.7.2 → v2.9.0 - cloud.google.com/go/recommendationengine: v0.8.1 → v0.8.4 - cloud.google.com/go/recommender: v1.10.1 → v1.12.0
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Tue Oct 29 20:17:52 UTC 2024 - 121.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.29.md
- cloud.google.com/go/phishingprotection: v0.7.0 → v0.8.1 - cloud.google.com/go/policytroubleshooter: v1.6.0 → v1.8.0 - cloud.google.com/go/privatecatalog: v0.8.0 → v0.9.1 - cloud.google.com/go/pubsub: v1.30.0 → v1.33.0 - cloud.google.com/go/pubsublite: v1.7.0 → v1.8.1 - cloud.google.com/go/recaptchaenterprise/v2: v2.7.0 → v2.7.2 - cloud.google.com/go/recommendationengine: v0.7.0 → v0.8.1
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Wed Oct 23 04:37:31 UTC 2024 - 375.1K bytes - Viewed (1) -
CHANGELOG/CHANGELOG-1.28.md
### Changed - cloud.google.com/go/bigquery: v1.8.0 → v1.50.0 - cloud.google.com/go/datastore: v1.1.0 → v1.11.0 - cloud.google.com/go/firestore: v1.1.0 → v1.9.0 - cloud.google.com/go/pubsub: v1.3.1 → v1.30.0 - cloud.google.com/go: v0.97.0 → v0.110.0 - github.com/Azure/azure-sdk-for-go: [v55.0.0+incompatible → v68.0.0+incompatible](https://github.com/Azure/azure-sdk-for-go/compare/v55.0.0...v68.0.0)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Wed Oct 23 04:34:59 UTC 2024 - 456.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/TreeRangeMapTest.java
3), rangeMap.asMapOfRanges()); assertThrows(IllegalArgumentException.class, () -> sub.put(Range.open(9, 12), 5)); RangeMap<Integer, Integer> subSub = sub.subRangeMap(Range.closedOpen(5, 5)); subSub.put(Range.closedOpen(5, 5), 6); // should be a no-op assertEquals( ImmutableMap.of( Range.open(3, 7), 1, Range.closed(7, 9),
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sun Oct 06 13:04:03 UTC 2024 - 29.9K bytes - Viewed (0)