Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 69 for newCounter (0.2 sec)

  1. src/cmd/go/internal/work/buildid.go

    	if err != nil {
    		return ""
    	}
    	return buildid.HashToString(sum)
    }
    
    var (
    	counterCacheHit  = telemetry.NewCounter("go/buildcache/hit")
    	counterCacheMiss = telemetry.NewCounter("go/buildcache/miss")
    
    	onceIncStdlibRecompiled sync.Once
    	stdlibRecompiled        = telemetry.NewCounter("go/buildcache/stdlib-recompiled")
    )
    
    // useCache tries to satisfy the action a, which has action ID actionHash,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:31:25 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  2. pkg/scheduler/metrics/metrics.go

    			// we think #victims>64 is pretty rare, therefore [64, +Inf) is considered a single bucket.
    			Buckets:        metrics.ExponentialBuckets(1, 2, 7),
    			StabilityLevel: metrics.STABLE,
    		})
    	PreemptionAttempts = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Subsystem:      SchedulerSubsystem,
    			Name:           "preemption_attempts_total",
    			Help:           "Total preemption attempts in the cluster till now",
    			StabilityLevel: metrics.STABLE,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 08:22:53 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. src/cmd/go/internal/toolchain/switch.go

    	fmt.Fprintf(os.Stderr, "go: %v requires go >= %v; switching to %v\n", s.TooNew.What, s.TooNew.GoVersion, tv)
    	counterSwitchExec.Inc()
    	Exec(tv)
    	panic("unreachable")
    }
    
    var counterSwitchExec = telemetry.NewCounter("go/toolchain/switch-exec")
    
    // SwitchOrFatal attempts a toolchain switch based on the information in err
    // and otherwise falls back to base.Fatal(err).
    func SwitchOrFatal(ctx context.Context, err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 18:15:22 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. src/cmd/go/main.go

    		help.HelpPackages,
    		modfetch.HelpPrivate,
    		test.HelpTestflag,
    		test.HelpTestfunc,
    		modget.HelpVCS,
    	}
    }
    
    var _ = go11tag
    
    var counterErrorsGOPATHEntryRelative = telemetry.NewCounter("go/errors:gopath-entry-relative")
    
    func main() {
    	log.SetFlags(0)
    	telemetry.Start() // Open the telemetry counter file so counters can be written to it.
    	handleChdirFlag()
    	toolchain.Select()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:09:11 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. src/cmd/go/internal/toolchain/select.go

    	var out []string
    	for _, e := range env {
    		if strings.HasPrefix(e, countEnv+"=") {
    			continue
    		}
    		out = append(out, e)
    	}
    	return out
    }
    
    var counterErrorsInvalidToolchainInFile = telemetry.NewCounter("go/errors:invalid-toolchain-in-file")
    
    // Select invokes a different Go toolchain if directed by
    // the GOTOOLCHAIN environment variable or the user's configuration
    // or go.mod file.
    // It must be called early in startup.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 17:25:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  6. src/cmd/go/internal/modfetch/cache.go

    		f.Truncate(0)
    		return err
    	}
    
    	return nil
    }
    
    var (
    	statCacheOnce sync.Once
    	statCacheErr  error
    
    	counterErrorsGOMODCACHEEntryRelative = telemetry.NewCounter("go/errors:gomodcache-entry-relative")
    )
    
    // checkCacheDir checks if the directory specified by GOMODCACHE exists. An
    // error is returned if it does not.
    func checkCacheDir(ctx context.Context) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 18:15:22 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    	if err != nil {
    		t.Fatalf("MarkVolumeAsAttached failed. Expected: <no error> Actual: <%v>", err)
    	}
    	podName := util.GetUniquePodName(pod)
    
    	mounter, err := plugin.NewMounter(volumeSpec, pod, volume.VolumeOptions{})
    	if err != nil {
    		t.Fatalf("NewMounter failed. Expected: <no error> Actual: <%v>", err)
    	}
    
    	mapper, err := plugin.NewBlockVolumeMapper(volumeSpec, pod, volume.VolumeOptions{})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  8. src/go/types/pointer.go

    // license that can be found in the LICENSE file.
    
    package types
    
    // A Pointer represents a pointer type.
    type Pointer struct {
    	base Type // element type
    }
    
    // NewPointer returns a new pointer type for the given element (base) type.
    func NewPointer(elem Type) *Pointer { return &Pointer{base: elem} }
    
    // Elem returns the element type for the given pointer p.
    func (p *Pointer) Elem() Type { return p.base }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 03 18:48:38 UTC 2024
    - 761 bytes
    - Viewed (0)
  9. pkg/volume/noop_expandable_plugin.go

    	return true
    }
    
    func (n *noopExpandableVolumePluginInstance) RequiresRemount(spec *Spec) bool {
    	return false
    }
    
    func (n *noopExpandableVolumePluginInstance) NewMounter(spec *Spec, podRef *v1.Pod, opts VolumeOptions) (Mounter, error) {
    	return nil, nil
    }
    
    func (n *noopExpandableVolumePluginInstance) NewUnmounter(name string, podUID types.UID) (Unmounter, error) {
    	return nil, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  10. pkg/volume/flexvolume/plugin.go

    	return []api.PersistentVolumeAccessMode{
    		api.ReadWriteOnce,
    		api.ReadOnlyMany,
    	}
    }
    
    // NewMounter is part of the volume.VolumePlugin interface.
    func (plugin *flexVolumePlugin) NewMounter(spec *volume.Spec, pod *api.Pod, _ volume.VolumeOptions) (volume.Mounter, error) {
    	return plugin.newMounterInternal(spec, pod, plugin.host.GetMounter(plugin.GetPluginName()), plugin.runner)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top