Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 1,387 for funcs (0.03 sec)

  1. docs/debugging/inspect/export.go

    // afterVersion returns the payload after the version, if any.
    func (x xlMetaInlineData) afterVersion() []byte {
    	if len(x) == 0 {
    		return x
    	}
    	return x[1:]
    }
    
    // versionOK returns whether the version is ok.
    func (x xlMetaInlineData) versionOK() bool {
    	if len(x) == 0 {
    		return true
    	}
    	return x[0] > 0 && x[0] <= xlMetaInlineDataVer
    }
    
    func (x xlMetaInlineData) json() ([]byte, error) {
    	if len(x) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    // in movement, such as decommissioning or rebalance.
    func (fi *FileInfo) SetDataMov() {
    	if fi.Metadata == nil {
    		fi.Metadata = make(map[string]string)
    	}
    	fi.Metadata[xMinIODataMov] = "true"
    }
    
    // DataMov returns true if object is being in movement
    func (fi FileInfo) DataMov() bool {
    	_, ok := fi.Metadata[xMinIODataMov]
    	return ok
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  3. cmd/erasure-metadata_test.go

    	}
    }
    
    func TestSkipTierFreeVersion(t *testing.T) {
    	fi := newFileInfo("object", 8, 8)
    	fi.SetSkipTierFreeVersion()
    	if ok := fi.SkipTierFreeVersion(); !ok {
    		t.Fatal("Expected SkipTierFreeVersion to be set on FileInfo but wasn't")
    	}
    }
    
    func TestListObjectParities(t *testing.T) {
    	mkMetaArr := func(N, parity, agree int) []FileInfo {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  4. istioctl/pkg/waypoint/waypoint.go

    	waypointName    = constants.DefaultNamespaceWaypoint
    	enrollNamespace bool
    	overwrite       bool
    )
    
    const waitTimeout = 90 * time.Second
    
    func Cmd(ctx cli.Context) *cobra.Command {
    	makeGateway := func(forApply bool) (*gateway.Gateway, error) {
    		ns := ctx.NamespaceOrDefault(ctx.Namespace())
    		if ctx.Namespace() == "" && !forApply {
    			ns = ""
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  5. cmd/metrics-resource.go

    }
    
    // Describe sends the super-set of all possible descriptors of metrics
    func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) {
    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    		for metric := range in {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  6. cmd/endpoint-ellipses.go

    // single set size.
    var setSizes = []uint64{2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16}
    
    // getDivisibleSize - returns a greatest common divisor of
    // all the ellipses sizes.
    func getDivisibleSize(totalSizes []uint64) (result uint64) {
    	gcd := func(x, y uint64) uint64 {
    		for y != 0 {
    			x, y = y, x%y
    		}
    		return x
    	}
    	result = totalSizes[0]
    	for i := 1; i < len(totalSizes); i++ {
    		result = gcd(result, totalSizes[i])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/arch/arm64.go

    	// which needs to patched like a jump.
    	"ADR":  true,
    	"ADRP": true,
    }
    
    func jumpArm64(word string) bool {
    	return arm64Jump[word]
    }
    
    var arm64SpecialOperand map[string]arm64.SpecialOperand
    
    // GetARM64SpecialOperand returns the internal representation of a special operand.
    func GetARM64SpecialOperand(name string) arm64.SpecialOperand {
    	if arm64SpecialOperand == nil {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Sep 29 09:04:58 UTC 2022
    - 10.4K bytes
    - Viewed (0)
  8. cmd/dynamic-timeouts_test.go

    		t.Errorf("Failure to decrease timeout appropriately")
    	}
    }
    
    func TestDynamicTimeoutConcurrent(t *testing.T) {
    	// Race test.
    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for i := 0; i < 100; i++ {
    				for j := 0; j < 100; j++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  9. istioctl/cmd/root.go

    				commandStack = append(commandStack, command)
    			}
    		}
    		curCmd.SetFlagErrorFunc(func(_ *cobra.Command, e error) error {
    			return util.CommandParseError{Err: e}
    		})
    	}
    
    	return rootCmd
    }
    
    func hideInheritedFlags(orig *cobra.Command, hidden ...string) {
    	orig.SetHelpFunc(func(cmd *cobra.Command, args []string) {
    		for _, hidden := range hidden {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Aug 05 02:08:47 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  10. istioctl/pkg/metrics/metrics.go

    	}
    }
    
    func convertLatencyToDuration(val float64) time.Duration {
    	return time.Duration(val) * time.Millisecond
    }
    
    func printHeader(writer io.Writer) {
    	w := tabwriter.NewWriter(writer, 13, 1, 2, ' ', tabwriter.AlignRight)
    	_, _ = fmt.Fprintf(w, "%40s\tTOTAL RPS\tERROR RPS\tP50 LATENCY\tP90 LATENCY\tP99 LATENCY\t\n", "WORKLOAD")
    	_ = w.Flush()
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top