Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 21 for PubSub (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top