- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 69 for newCounter (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)