Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 205 for lister (0.04 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. istioctl/pkg/util/configdump/cluster.go

    	for i := range dac {
    		dac[i].Cluster.TypeUrl = v3.ClusterType
    	}
    	sort.Slice(dac, func(i, j int) bool {
    		cluster := &cluster.Cluster{}
    		err = dac[i].Cluster.UnmarshalTo(cluster)
    		if err != nil {
    			return false
    		}
    		name := cluster.Name
    		err = dac[j].Cluster.UnmarshalTo(cluster)
    		if err != nil {
    			return false
    		}
    		return name < cluster.Name
    	})
    	if stripVersions {
    		for i := range dac {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  3. cni/pkg/pluginlistener/listener.go

    	if err := os.MkdirAll(filepath.Dir(path), 0o750); err != nil {
    		// If we cannot create it, just warn here - we will fail later if there is a real error
    		log.Warnf("Failed to create directory for %v: %v", path, err)
    	}
    
    	var err error
    	listener, err := net.Listen("unix", path)
    	if err != nil {
    		return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err)
    	}
    
    	// Update file permission so that cni plugin has permission to access it.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/cluster.go

    	if err != nil {
    		return nil, err
    	}
    	clusters := make([]*cluster.Cluster, 0)
    	for _, c := range clusterDump.DynamicActiveClusters {
    		if c.Cluster != nil {
    			clusterTyped := &cluster.Cluster{}
    			// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    			c.Cluster.TypeUrl = v3.ClusterType
    			err = c.Cluster.UnmarshalTo(clusterTyped)
    			if err != nil {
    				return nil, err
    			}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu May 11 05:38:17 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  5. 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)
  6. istioctl/pkg/multicluster/cluster.go

    import (
    	"context"
    
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/client-go/kubernetes"
    )
    
    // Use UUID of kube-system Namespace as unique identifier for cluster.
    // (see https://docs.google.com/document/d/1F__vEKeI41P7PPUCMM9PVPYY34pyrvQI5rbTJVnS5c4)
    func clusterUID(client kubernetes.Interface) (types.UID, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 02 03:11:58 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. istioctl/pkg/writer/compare/cluster.go

    Xiaopeng Han <******@****.***> 1710237729 +0800
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 1.9K bytes
    - Viewed (0)
Back to top