- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 236 for sekonda (0.15 sec)
-
helm/minio/templates/_helper_create_svcacct.txt
STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed attempts: $ATTEMPTS\" ; if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 2 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active return 0 } # checkSvcacctExists ()
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 23:20:50 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
return } if pingInterval < 1 { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidQueryParams), r.URL) return } t := time.NewTicker(time.Duration(pingInterval) * time.Second) defer t.Stop() emptyEventTicker = t.C } else { // Deprecated Apr 2023 t := time.NewTicker(500 * time.Millisecond) defer t.Stop() keepAliveTicker = t.C } enc := json.NewEncoder(w)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/globals.go
globalProxyEndpoints []ProxyEndpoint globalInternodeTransport http.RoundTripper globalRemoteTargetTransport http.RoundTripper globalDNSCache = &dnscache.Resolver{ Timeout: 5 * time.Second, } globalForwarder *handlers.Forwarder globalTierConfigMgr *TierConfigMgr globalConsoleSrv *consoleapi.Server // handles service freeze or un-freeze S3 API calls.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
mu.Lock() offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected)) mu.Unlock() return } ctx, cancel := context.WithTimeout(ctx, 2*time.Second) defer cancel() err := clnt.Verify(ctx, srcCfg) mu.Lock() if err != nil { bootstrapTraceMsg(fmt.Sprintf("clnt.Verify: %v, endpoint: %s", err, clnt)) if !isNetworkError(err) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/event/target/webhook.go
func (target *WebhookTarget) Store() event.TargetStore { return target.store } func (target *WebhookTarget) isActive() (bool, error) { conn, err := net.DialTimeout("tcp", target.addr, 5*time.Second) if err != nil { if xnet.IsNetworkOrHostDown(err, false) { return false, store.ErrNotConnected } return false, err } defer conn.Close() return true, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/s3select/sql/value.go
_, ok = b.value.([]byte) case []Value: _, ok = b.value.([]Value) default: ok = reflect.TypeOf(v.value) == reflect.TypeOf(b.value) } return ok } // ToBool returns the bool value; second return value refers to if the bool // conversion succeeded. func (v Value) ToBool() (val bool, ok bool) { val, ok = v.value.(bool) return } // ToTimestamp returns the timestamp value if present.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 20.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
// to avoid multiple pool leaders herding to update around the same // time. r := rand.New(rand.NewSource(time.Now().UnixNano())) randSleepFor := func() time.Duration { return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64()) } timer := time.NewTimer(randSleepFor()) defer timer.Stop() var ( quit bool traceMsg string ) for { select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/replication/minio-replication-node.json
"type": "prometheus", "uid": "${DS_PROMETHEUS}" }, "exemplar": true, "expr": "sum by (server,endpoint) (minio_cluster_replication_link_downtime_duration_seconds{job=\"$scrape_jobs\"})", "interval": "1m", "intervalFactor": 2, "legendFormat": "{{server,endpoint}}", "refId": "A" } ],
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:15:39 GMT 2024 - 57.5K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if opts.Cached { listBucketsCache.InitOnce(time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func() ([]BucketInfo, error) { ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() buckets, err = z.s3Peer.ListBuckets(ctx, opts) if err != nil { return nil, err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
helm-releases/minio-5.0.5.tgz
myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed attempts: $ATTEMPTS\" ; if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active return 0 } # checkBucketExists ($bucket) # Check if the bucket exists, by using the exit code of `mc ls` checkBucketExists() { BUCKET=$1 CMD=$(${MC} stat myminio/$BUCKET...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 03 20:54:02 GMT 2023 - 20.3K bytes - Viewed (0)