Search Options

Results per page
Sort
Preferred Languages
Advance

Results 891 - 900 of 1,423 for Func (0.03 sec)

  1. 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)
  2. 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)
  3. cmd/shared-lock.go

    				break keepLock
    			case ld.lockContext <- lkctx:
    				// Send the lock context to anyone asking for it
    			}
    		}
    	}
    }
    
    func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) {
    	ctx, cancel := context.WithCancel(context.Background())
    	go func() {
    		select {
    		case <-ctx1.Done():
    		case <-ctx2.Done():
    		// The lock acquirer decides to cancel, exit this goroutine
    		case <-ctx.Done():
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K 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. internal/event/target/postgresql_test.go

    // TestPostgreSQLRegistration checks if postgres driver
    // is registered and fails otherwise.
    func TestPostgreSQLRegistration(t *testing.T) {
    	var found bool
    	for _, drv := range sql.Drivers() {
    		if drv == "postgres" {
    			found = true
    			break
    		}
    	}
    	if !found {
    		t.Fatal("postgres driver not registered")
    	}
    }
    
    func TestPsqlTableNameValidation(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 17:51:07 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. internal/amztime/parse_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    // Package amztime implements AWS specific time parsing and deviations
    package amztime
    
    import (
    	"errors"
    	"testing"
    	"time"
    )
    
    func TestParse(t *testing.T) {
    	type testCase struct {
    		expectedErr  error
    		expectedTime time.Time
    		timeStr      string
    	}
    	testCases := []testCase{
    		{
    			ErrMalformedDate,
    			time.Time{},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 07 14:24:54 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  7. istioctl/pkg/util/common.go

    // CommandParseError distinguishes an error parsing istioctl CLI arguments from an error processing
    type CommandParseError struct {
    	Err error
    }
    
    func (c CommandParseError) Error() string {
    	return c.Err.Error()
    }
    
    // Confirm waits for a user to confirm with the supplied message.
    func Confirm(msg string, writer io.Writer) bool {
    	for {
    		_, _ = fmt.Fprintf(writer, "%s ", msg)
    		var response string
    		_, err := fmt.Scanln(&response)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.6K 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. 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)
  10. internal/handlers/proxy_test.go

    package handlers
    
    import (
    	"net/http"
    	"testing"
    )
    
    type headerTest struct {
    	key      string // header key
    	val      string // header val
    	expected string // expected result
    }
    
    func TestGetScheme(t *testing.T) {
    	headers := []headerTest{
    		{xForwardedProto, "https", "https"},
    		{xForwardedProto, "http", "http"},
    		{xForwardedProto, "HTTP", "http"},
    		{xForwardedScheme, "https", "https"},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 22 00:56:55 UTC 2023
    - 3.2K bytes
    - Viewed (0)
Back to top