- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 1,387 for funcs (0.09 sec)
-
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) -
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) -
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) -
cmd/local-locker.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 10.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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)