- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for newCounter (0.19 sec)
-
src/cmd/internal/telemetry/telemetry_bootstrap.go
func Start() {} func StartWithUpload() {} func Inc(name string) {} func NewCounter(name string) dummyCounter { return dummyCounter{} } func NewStackCounter(name string, depth int) dummyCounter { return dummyCounter{} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 20:16:39 UTC 2024 - 1.1K bytes - Viewed (0) -
src/cmd/internal/telemetry/telemetry.go
TelemetryDir: os.Getenv("TEST_TELEMETRY_DIR"), }) } // Inc increments the counter with the given name. func Inc(name string) { counter.Inc(name) } // NewCounter returns a counter with the given name. func NewCounter(name string) *counter.Counter { return counter.New(name) } // NewStackCounter returns a new stack counter with the given name and depth.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:47:30 UTC 2024 - 3.6K bytes - Viewed (0) -
src/cmd/go/internal/help/help.go
import ( "bufio" "fmt" "io" "os" "strings" "text/template" "unicode" "unicode/utf8" "cmd/go/internal/base" "cmd/internal/telemetry" ) var counterErrorsHelpUnknownTopic = telemetry.NewCounter("go/errors:help-unknown-topic") // Help implements the 'help' command. func Help(w io.Writer, args []string) { // 'go help documentation' generates doc.go. if len(args) == 1 && args[0] == "documentation" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 4.7K 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) -
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) -
pkg/volume/plugins_test.go
func (plugin *testPlugins) SupportsMountOption() bool { return false } func (plugin *testPlugins) SupportsSELinuxContextMount(spec *Spec) (bool, error) { return false, nil } func (plugin *testPlugins) NewMounter(spec *Spec, podRef *v1.Pod, opts VolumeOptions) (Mounter, error) { return nil, nil } func (plugin *testPlugins) 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 - 4.3K bytes - Viewed (0) -
internal/grid/debug.go
AuthRequest: func(r *http.Request) error { return nil }, AddAuth: func(aud string) string { return aud }, BlockConnect: ready, }) if err != nil { return nil, err } m := mux.NewRouter() m.Handle(RoutePath, manager.Handler()) res.Managers = append(res.Managers, manager) res.Servers = append(res.Servers, startHTTPServer(listeners[i], m)) res.Listeners = append(res.Listeners, listeners[i])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/volume/nfs/nfs.go
func (plugin *nfsPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode { return []v1.PersistentVolumeAccessMode{ v1.ReadWriteOnce, v1.ReadOnlyMany, v1.ReadWriteMany, } } func (plugin *nfsPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, _ volume.VolumeOptions) (volume.Mounter, error) { return plugin.newMounterInternal(spec, pod, plugin.host.GetMounter(plugin.GetPluginName())) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/volume/secret/secret.go
func (plugin *secretPlugin) SupportsMountOption() bool { return false } func (plugin *secretPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { return false, nil } func (plugin *secretPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) { return &secretVolumeMounter{ secretVolume: &secretVolume{ spec.Name(), pod.UID, plugin,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.1K bytes - Viewed (0)