Search Options

Results per page
Sort
Preferred Languages
Advance

Results 891 - 900 of 1,385 for _func (0.04 sec)

  1. cmd/metrics-v3-api.go

    )
    
    // loadAPIRequestsHTTPMetrics - reads S3 HTTP metrics.
    //
    // This is a `MetricsLoaderFn`.
    //
    // This includes node level S3 HTTP metrics.
    //
    // This function currently ignores `opts`.
    func loadAPIRequestsHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	// Collect node level S3 HTTP metrics.
    	httpStats := globalHTTPStats.toServerHTTPStats(false)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-drive.go

    		"Average time for write requests served on a drive",
    		allDriveLabels...)
    	drivePercUtilMD = NewGaugeMD(drivePercUtil,
    		"Percentage of time the disk was busy",
    		allDriveLabels...)
    )
    
    func getCurrentDriveIOStats() map[string]madmin.DiskIOStats {
    	var types madmin.MetricType = madmin.MetricsDisk
    	driveRealtimeMetrics := collectLocalMetrics(types, collectMetricsOpts{
    		hosts: map[string]struct{}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. cmd/xl-storage_test.go

    	}
    
    	for _, testCase := range testCases {
    		gotErr := checkPathLength(testCase.path)
    		t.Run("", func(t *testing.T) {
    			if gotErr != testCase.expectedErr {
    				t.Errorf("Expected %s, got %s", testCase.expectedErr, gotErr)
    			}
    		})
    	}
    }
    
    // Tests validate volume name.
    func TestIsValidVolname(t *testing.T) {
    	testCases := []struct {
    		volName    string
    		shouldPass bool
    	}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users.go

    // ImportIAM - imports all IAM info into MinIO
    func (a adminAPIHandlers) ImportIAM(w http.ResponseWriter, r *http.Request) {
    	a.importIAM(w, r, "")
    }
    
    // ImportIAMV2 - imports all IAM info into MinIO
    func (a adminAPIHandlers) ImportIAMV2(w http.ResponseWriter, r *http.Request) {
    	a.importIAM(w, r, "v2")
    }
    
    // ImportIAM - imports all IAM info into MinIO
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils_gen.go

    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z MRFReplicateEntry) Msgsize() (s int) {
    	s = 1 + 2 + msgp.StringPrefixSize + len(z.Bucket) + 2 + msgp.StringPrefixSize + len(z.Object) + 3 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *ReplicateDecision) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 61.1K bytes
    - Viewed (0)
  6. internal/config/help.go

    	MultipleTargets bool `json:"multipleTargets"`
    }
    
    // HelpKVS - implement order of keys help messages.
    type HelpKVS []HelpKV
    
    // Lookup - lookup a key from help kvs.
    func (hkvs HelpKVS) Lookup(key string) (HelpKV, bool) {
    	for _, hkv := range hkvs {
    		if hkv.Key == key {
    			return hkv, true
    		}
    	}
    	return HelpKV{}, false
    }
    
    // DefaultComment used across all sub-systems.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 23 14:45:27 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  7. cmd/namespace-lock_test.go

    // following test. Adding new code before this test or changing its
    // position will cause the line number to change and the test to FAIL
    // Tests getSource().
    func TestGetSource(t *testing.T) {
    	currentSource := func() string { return getSource(2) }
    	gotSource := currentSource()
    	// Hard coded line number, 35, in the "expectedSource" value
    	expectedSource := "[namespace-lock_test.go:35:TestGetSource()]"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  8. cni/pkg/repair/repair.go

    package repair
    
    import (
    	"context"
    
    	"istio.io/istio/cni/pkg/config"
    	"istio.io/istio/cni/pkg/scopes"
    	"istio.io/istio/pkg/kube"
    )
    
    var repairLog = scopes.CNIAgent
    
    func StartRepair(ctx context.Context, cfg config.RepairConfig) {
    	if !cfg.Enabled {
    		repairLog.Info("CNI repair controller is disabled")
    		return
    	}
    	repairLog.Info("starting CNI sidecar repair controller")
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  9. src/archive/tar/reader.go

    	default:
    		return n, err
    	}
    }
    
    func (fr *regFileReader) WriteTo(w io.Writer) (int64, error) {
    	return io.Copy(w, struct{ io.Reader }{fr})
    }
    
    // logicalRemaining implements fileState.logicalRemaining.
    func (fr regFileReader) logicalRemaining() int64 {
    	return fr.nb
    }
    
    // physicalRemaining implements fileState.physicalRemaining.
    func (fr regFileReader) physicalRemaining() int64 {
    	return fr.nb
    }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-decom_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"testing"
    )
    
    func prepareErasurePools() (ObjectLayer, []string, error) {
    	nDisks := 32
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		return nil, nil, err
    	}
    
    	pools := mustGetPoolEndpoints(0, fsDirs[:16]...)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 01 14:38:46 UTC 2024
    - 4.8K bytes
    - Viewed (0)
Back to top