Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 1,387 for funcs (0.09 sec)

  1. cmd/metrics-v3-handler.go

    	globalMetricsV3Once           sync.Once
    )
    
    func newMetricsV3Server(auth func(h http.Handler) http.Handler) *metricsV3Server {
    	registry := prometheus.NewRegistry()
    	metricGroups := newMetricGroups(registry)
    	globalMetricsV3Once.Do(func() {
    		globalMetricsV3CollectorPaths = metricGroups.collectorPaths
    	})
    	return &metricsV3Server{
    		registry: registry,
    		opts: promhttp.HandlerOpts{
    			ErrorLog:            promLogger{},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  2. internal/s3select/select.go

    )
    
    var parquetSupport bool
    
    func init() {
    	parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn
    }
    
    var bufPool = sync.Pool{
    	New: func() interface{} {
    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = sync.Pool{
    	New: func() interface{} {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  3. internal/http/listener.go

    }
    
    // start - starts separate goroutine for each TCP listener.  A valid new connection is passed to httpListener.acceptCh.
    func (listener *httpListener) start() {
    	// Closure to send acceptResult to acceptCh.
    	// It returns true if the result is sent else false if returns when doneCh is closed.
    	send := func(result acceptResult) bool {
    		select {
    		case listener.acceptCh <- result:
    			// Successfully written to acceptCh
    			return true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. cmd/local-locker.go

    	}
    	return lockCopy
    }
    
    func (l *localLocker) Close() error {
    	return nil
    }
    
    // IsOnline - local locker is always online.
    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    func (l *localLocker) IsLocal() bool {
    	return true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. cmd/background-heal-ops.go

    type healRoutine struct {
    	tasks   chan healTask
    	workers int
    }
    
    func activeListeners() int {
    	// Bucket notification and http trace are not costly, it is okay to ignore them
    	// while counting the number of concurrent connections
    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. cni/pkg/iptables/iptables_e2e_test.go

    	"istio.io/istio/cni/pkg/scopes"
    	"istio.io/istio/pkg/test/util/assert"
    	dep "istio.io/istio/tools/istio-iptables/pkg/dependencies"
    )
    
    func TestIptablesCleanRoundTrip(t *testing.T) {
    	setup(t)
    	tt := struct {
    		name   string
    		config func(cfg *Config)
    	}{
    		"default",
    		func(cfg *Config) {
    			cfg.RedirectDNS = true
    		},
    	}
    
    	probeSNATipv4 := netip.MustParseAddr("169.254.7.127")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. cmd/site-replication-utils.go

    	peerResyncMap map[string]resyncState
    }
    
    func newSiteResyncMetrics(ctx context.Context) *siteResyncMetrics {
    	s := siteResyncMetrics{
    		resyncStatus:  make(map[string]SiteResyncStatus),
    		peerResyncMap: make(map[string]resyncState),
    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  8. internal/kms/kms.go

    	client     *kms.Client
    }
    
    func (c *kmsConn) Version(ctx context.Context) (string, error) {
    	resp, err := c.client.Version(ctx, &kms.VersionRequest{})
    	if len(resp) == 0 && err != nil {
    		return "", err
    	}
    	return resp[0].Version, nil
    }
    
    func (c *kmsConn) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return nil, ErrNotSupported
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. istioctl/pkg/dashboard/dashboard.go

    	}
    
    	return fmt.Errorf("failure running port forward process: %v", err)
    }
    
    func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) {
    	go func() {
    		signals := make(chan os.Signal, 1)
    		signal.Notify(signals, os.Interrupt)
    		defer signal.Stop(signals)
    		<-signals
    		fw.Close()
    	}()
    }
    
    func openBrowser(url string, writer io.Writer, browser bool) {
    	var err error
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  10. tests/query_test.go

    		t.Fatalf("Build OR condition, but got %v", result.Statement.SQL.String())
    	}
    }
    
    type Int64 int64
    
    func (v Int64) Value() (driver.Value, error) {
    	return v - 1, nil
    }
    
    func (f *Int64) Scan(v interface{}) error {
    	y := v.(int64)
    	*f = Int64(y + 1)
    	return nil
    }
    
    func TestPluck(t *testing.T) {
    	users := []*User{
    		GetUser("pluck-user1", Config{}),
    		GetUser("pluck-user2", Config{}),
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 50.4K bytes
    - Viewed (0)
Back to top