- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for PubSub (0.07 sec)
-
internal/grid/connection.go
id uuid.UUID local, remote string handlers *handlers incomingBytes func(n int64) // Record incoming bytes. outgoingBytes func(n int64) // Record outgoing bytes. publisher *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType] dialer ConnDialer authFn AuthFn blockConnect chan struct{} } // newConnection will create an unconnected connection to a remote.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K 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.19.md
## Dependencies ### Added - cloud.google.com/go/bigquery: v1.0.1 - cloud.google.com/go/datastore: v1.0.0 - cloud.google.com/go/pubsub: v1.0.1 - cloud.google.com/go/storage: v1.0.0 - dmitri.shuralyov.com/gpu/mtl: 666a987 - github.com/cespare/xxhash/v2: [v2.1.1](https://github.com/cespare/xxhash/v2/tree/v2.1.1)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Wed Jan 05 05:42:32 UTC 2022 - 489.7K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.26.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/census-instrumentation/opencensus-proto: [v0.2.1 → v0.4.1](https://github.com/census-instrumentation/opencensus-proto/compare/v0.2.1...v0.4.1)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Thu Mar 14 16:24:51 UTC 2024 - 425.7K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.23.md
- sigs.k8s.io/kustomize/kustomize/v4: v4.2.0 → v4.4.1 - sigs.k8s.io/kustomize/kyaml: v0.11.0 → v0.13.0 ### Removed - cloud.google.com/go/datastore: v1.1.0 - cloud.google.com/go/pubsub: v1.2.0 - github.com/alecthomas/units: [f65c72e](https://github.com/alecthomas/units/tree/f65c72e) - github.com/coreos/bbolt: [v1.3.2](https://github.com/coreos/bbolt/tree/v1.3.2)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Tue Feb 28 21:06:52 UTC 2023 - 424.5K bytes - Viewed (0) -
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) -
CHANGELOG/CHANGELOG-1.20.md
- rsc.io/quote/v3: v3.1.0 - rsc.io/sampler: v1.3.0 ### Changed - cloud.google.com/go/bigquery: v1.0.1 → v1.4.0 - cloud.google.com/go/datastore: v1.0.0 → v1.1.0 - cloud.google.com/go/pubsub: v1.0.1 → v1.2.0 - cloud.google.com/go/storage: v1.0.0 → v1.6.0 - cloud.google.com/go: v0.51.0 → v0.54.0
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Wed Jan 19 21:05:45 UTC 2022 - 409K 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)