Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 133 for forwardly (0.25 sec)

  1. cmd/tier-last-day-stats.go

    	UpdatedAt time.Time
    }
    
    func (l *lastDayTierStats) addStats(ts tierStats) {
    	now := time.Now()
    	l.forwardTo(now)
    
    	nowIdx := now.Hour()
    	l.Bins[nowIdx] = l.Bins[nowIdx].add(ts)
    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    	since := t.Sub(l.UpdatedAt).Hours()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  3. internal/s3select/sql/value.go

    		}
    		if a.IsMissing() {
    			return v.IsMissing(), nil
    		}
    		// Forward to Equal
    		op = opEq
    	case opIsNot:
    		if a.IsNull() {
    			// Missing is not null
    			return !v.IsNull() && !v.IsMissing(), nil
    		}
    		if a.IsMissing() {
    			return !v.IsMissing(), nil
    		}
    		// Forward to not equal.
    		op = opIneq
    	default:
    	}
    
    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)
  4. cmd/globals.go

    	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.
    	globalServiceFreeze atomic.Value
    
    	// Only needed for tracking
    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)
  5. cmd/object-api-errors.go

    	return "Object name too long: " + e.Bucket + "/" + e.Object
    }
    
    // Error returns string an error formatted as the given text.
    func (e ObjectNamePrefixAsSlash) Error() string {
    	return "Object name contains forward slash as prefix: " + e.Bucket + "/" + e.Object
    }
    
    // AllAccessDisabled All access to this object has been disabled
    type AllAccessDisabled GenericError
    
    // Error returns string an error formatted as the given text.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  6. docs/config/README.md

    ```
    KEY:
    etcd  federate multiple clusters for IAM and Bucket DNS
    
    ARGS:
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    		bucket:    bucketName,
    	}
    
    	err := listPathRaw(ctx, listPathRawOptions{
    		disks:          disks,
    		bucket:         bucketName,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       listingQuorum,
    		reportNotFound: false,
    		agreed:         fn,
    		partial: func(entries metaCacheEntries, _ []error) {
    			entry, ok := entries.resolve(&resolver)
    			if ok {
    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)
  8. helm-releases/minio-2.0.0.tgz

    commands: 1. export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "release={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}") 2. kubectl port-forward $POD_NAME 9000 --namespace {{ .Release.Namespace }} Read more about port forwarding here: http://kubernetes.io/docs/user-guide/kubectl/kubectl_port-forward/ You can now access Minio server on http://localhost:9000. Follow the below steps to connect to Minio server with mc client: 1. Download the Minio mc client - https://d...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Aug 26 07:36:46 GMT 2021
    - 13.6K bytes
    - Viewed (0)
  9. helm-releases/minio-1.0.3.tgz

    commands: 1. export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "release={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}") 2. kubectl port-forward $POD_NAME 9000 --namespace {{ .Release.Namespace }} Read more about port forwarding here: http://kubernetes.io/docs/user-guide/kubectl/kubectl_port-forward/ You can now access Minio server on http://localhost:9000. Follow the below steps to connect to Minio server with mc client: 1. Download the Minio mc client - https://d...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 24 19:04:07 GMT 2021
    - 13.6K bytes
    - Viewed (0)
  10. helm-releases/minio-3.3.3.tgz

    commands: 1. export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "release={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}") 2. kubectl port-forward $POD_NAME 9000 --namespace {{ .Release.Namespace }} Read more about port forwarding here: http://kubernetes.io/docs/user-guide/kubectl/kubectl_port-forward/ You can now access MinIO server on http://localhost:9000. Follow the below steps to connect to MinIO server with mc client: 1. Download the MinIO mc client - https://d...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 11 17:28:02 GMT 2021
    - 14.6K bytes
    - Viewed (0)
Back to top