Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 115 for newCounter (2.4 sec)

  1. 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)
  2. 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)
  3. 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)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go

    		[]string{"verb", "group", "version", "resource", "subresource", "scope", "component"},
    	)
    	// TLSHandshakeErrors is a number of requests dropped with 'TLS handshake error from' error
    	TLSHandshakeErrors = compbasemetrics.NewCounter(
    		&compbasemetrics.CounterOpts{
    			Subsystem:      APIServerComponent,
    			Name:           "tls_handshake_errors_total",
    			Help:           "Number of requests dropped with 'TLS handshake error from' error",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 35K bytes
    - Viewed (0)
  5. pkg/kubelet/winstats/network_stats_test.go

    }
    
    func TestNetworkGetDataFailures(t *testing.T) {
    	netCounter := newFakedNetworkCounters(true)
    
    	_, err := netCounter.getData()
    	expectedMsg := "Expected getDataList error."
    	if err == nil || err.Error() != expectedMsg {
    		t.Fatalf("expected error message `%s` but got `%v`", expectedMsg, err)
    	}
    
    	_, err = netCounter.getData()
    	netCounter.packetsReceivedPerSecondCounter.(*fakePerfCounterImpl).raiseError = false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 13 12:08:15 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. src/cmd/compile/internal/types2/pointer.go

    // license that can be found in the LICENSE file.
    
    package types2
    
    // 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: Thu Jul 01 22:17:50 UTC 2021
    - 635 bytes
    - Viewed (0)
  9. pkg/kubelet/volumemanager/metrics/metrics_test.go

    	if err != nil {
    		t.Fatalf("AddPodToVolume failed. Expected: <no error> Actual: <%v>", err)
    	}
    
    	mounter, err := fakePlugin.NewMounter(volumeSpec, pod, volume.VolumeOptions{})
    	if err != nil {
    		t.Fatalf("NewMounter failed. Expected: <no error> Actual: <%v>", err)
    	}
    
    	mapper, err := fakePlugin.NewBlockVolumeMapper(volumeSpec, pod, volume.VolumeOptions{})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 4K bytes
    - Viewed (0)
  10. pkg/volume/local/local_test.go

    	}
    }
    
    func TestInvalidLocalPath(t *testing.T) {
    	tmpDir, plug := getPlugin(t)
    	defer os.RemoveAll(tmpDir)
    
    	pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}}
    	mounter, err := plug.NewMounter(getTestVolume(false, "/no/backsteps/allowed/..", false, nil), pod, volume.VolumeOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	err = mounter.SetUp(volume.MounterArgs{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 10:53:39 UTC 2023
    - 22.5K bytes
    - Viewed (0)
Back to top