Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 139 for lister (0.06 sec)

  1. internal/http/listener.go

    		case <-listener.ctx.Done():
    			return false
    		}
    	}
    
    	// Closure to handle TCPListener until done channel is closed.
    	handleListener := func(idx int, listener net.Listener) {
    		for {
    			conn, err := listener.Accept()
    			send(acceptResult{conn, err, idx})
    		}
    	}
    
    	// Start separate goroutine for each TCP listener to handle connection.
    	for idx, tcpListener := range listener.listeners {
    		go handleListener(idx, tcpListener)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. cmd/listen-notification-handlers.go

    			return
    		}
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cluster-usage.go

    	usageTotalBytesMD = NewGaugeMD(usageTotalBytes,
    		"Total cluster usage in bytes")
    	usageObjectsCountMD = NewGaugeMD(usageObjectsCount,
    		"Total cluster objects count")
    	usageVersionsCountMD = NewGaugeMD(usageVersionsCount,
    		"Total cluster object versions (including delete markers) count")
    	usageDeleteMarkersCountMD = NewGaugeMD(usageDeleteMarkersCount,
    		"Total cluster delete markers count")
    	usageBucketsCountMD = NewGaugeMD(usageBucketsCount,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:11:42 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cluster-config.go

    		"Reduced redundancy storage class parity")
    	configStandardParityMD = NewGaugeMD(configStandardParity,
    		"Standard storage class parity")
    )
    
    // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config
    // such as standard and RRS parity.
    func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	clusterDriveMetrics, err := c.clusterDriveMetrics.Get()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  5. docs/sts/etcd.md

      /usr/local/bin/etcd \
      --name s1 \
      --data-dir /etcd-data \
      --listen-client-urls http://0.0.0.0:2379 \
      --advertise-client-urls http://0.0.0.0:2379 \
      --listen-peer-urls http://0.0.0.0:2380 \
      --initial-advertise-peer-urls http://0.0.0.0:2380 \
      --initial-cluster s1=http://0.0.0.0:2380 \
      --initial-cluster-token tkn \
      --initial-cluster-state new
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  6. api/maven-api-core/src/main/java/org/apache/maven/api/Listener.java

    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.annotations.Nonnull;
    
    /**
     * A listener for session events.
     * TODO: open this to other events like similar to {@code org.apache.maven.eventspy.EventSpy}
     *
     * @since 4.0.0
     */
    @Experimental
    @FunctionalInterface
    @Consumer
    public interface Listener {
        void onEvent(@Nonnull Event event);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Mar 23 05:29:39 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  7. internal/bucket/replication/filter.go

    )
    
    var errInvalidFilter = Errorf("Filter must have exactly one of Prefix, Tag, or And specified")
    
    // Filter - a filter for a replication configuration Rule.
    type Filter struct {
    	XMLName xml.Name `xml:"Filter" json:"Filter"`
    	Prefix  string
    	And     And
    	Tag     Tag
    
    	// Caching tags, only once
    	cachedTags map[string]string
    }
    
    // IsEmpty returns true if filter is not set
    func (f Filter) IsEmpty() bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 28 18:25:46 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  8. cmd/metrics-v3-cluster-iam.go

    	syncSuccessesMD                          = NewCounterMD(syncSuccesses, "Number of successful IAM data syncs since server start.")
    )
    
    // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics.
    func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	m.Set(lastSyncDurationMillis, float64(atomic.LoadUint64(&globalIAMSys.LastRefreshDurationMilliseconds)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 02 08:20:42 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/filter.go

    package lifecycle
    
    import (
    	"encoding/xml"
    	"io"
    
    	"github.com/minio/minio-go/v7/pkg/tags"
    )
    
    var errInvalidFilter = Errorf("Filter must have exactly one of Prefix, Tag, or And specified")
    
    // Filter - a filter for a lifecycle configuration Rule.
    type Filter struct {
    	XMLName xml.Name `xml:"Filter"`
    	set     bool
    
    	Prefix Prefix
    
    	ObjectSizeGreaterThan int64 `xml:"ObjectSizeGreaterThan,omitempty"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:01:26 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  10. docs/de/docs/tutorial/extra-data-types.md

    # Zusätzliche Datentypen
    
    Bisher haben Sie gängige Datentypen verwendet, wie zum Beispiel:
    
    * `int`
    * `float`
    * `str`
    * `bool`
    
    Sie können aber auch komplexere Datentypen verwenden.
    
    Und Sie haben immer noch dieselbe Funktionalität wie bisher gesehen:
    
    * Großartige Editor-Unterstützung.
    * Datenkonvertierung bei eingehenden Requests.
    * Datenkonvertierung für Response-Daten.
    * Datenvalidierung.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top