Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for PubSub (0.05 sec)

  1. 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)
  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.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)
  6. 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