- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 62 for Chow (0.13 sec)
-
cni/pkg/plugin/plugin_dryrun_test.go
golden: filepath.Join(env.IstioSrc, "cni/pkg/plugin/testdata/custom-uid-tproxy.txt.golden"), }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { // TODO(bianpengyuan): How do we test ipv6 rules? getNs = generateMockGetNsFunc(testSandboxDirectory) tmpDir := t.TempDir() outputFilePath := filepath.Join(tmpDir, "output.txt") if _, err := os.Create(outputFilePath); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/metacache-set.go
if askDisks > 0 && len(disks) > askDisks { rand.Shuffle(len(disks), func(i, j int) { disks[i], disks[j] = disks[j], disks[i] }) fallbackDisks = disks[askDisks:] disks = disks[:askDisks] } // How to resolve results. resolver := metadataResolutionParams{ dirQuorum: listingQuorum, objQuorum: listingQuorum, bucket: o.Bucket, } // Maximum versions requested for "latest" object
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
misc/go_android_exec/main.go
} } } deviceBin := fmt.Sprintf("%s/%s", deviceGotmp, binName) if err := adb("push", os.Args[1], deviceBin); err != nil { return 0, err } // Forward SIGQUIT from the go command to show backtraces from // the binary instead of from this wrapper. quit := make(chan os.Signal, 1) signal.Notify(quit, syscall.SIGQUIT) go func() { for range quit {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
src/bytes/buffer.go
// Cap returns the capacity of the buffer's underlying byte slice, that is, the // total space allocated for the buffer's data. func (b *Buffer) Cap() int { return cap(b.buf) } // Available returns how many bytes are unused in the buffer. func (b *Buffer) Available() int { return cap(b.buf) - len(b.buf) } // Truncate discards all but the first n unread bytes from the buffer // but continues to use the same allocated storage.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 15.7K bytes - Viewed (0) -
src/bufio/bufio.go
} if err != nil { if n > 0 && n < b.n { copy(b.buf[0:b.n-n], b.buf[n:b.n]) } b.n -= n b.err = err return err } b.n = 0 return nil } // Available returns how many bytes are unused in the buffer. func (b *Writer) Available() int { return len(b.buf) - b.n } // AvailableBuffer returns an empty buffer with b.Available() capacity. // This buffer is intended to be appended to and
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
src/archive/tar/reader.go
func NewReader(r io.Reader) *Reader { return &Reader{r: r, curr: ®FileReader{r, 0}} } // Next advances to the next entry in the tar archive. // The Header.Size determines how many bytes can be read for the next file. // Any remaining data in the current file is automatically discarded. // At the end of the archive, Next returns the error io.EOF. //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
# Retrieve full bootstrap without using Kubernetes API ssh <user@hostname> 'curl localhost:15000/config_dump' > envoy-config.json istioctl proxy-config bootstrap --file envoy-config.json # Show a human-readable Istio and Envoy version summary istioctl proxy-config bootstrap <pod-name[.namespace]> -o short `, Aliases: []string{"b"}, Args: func(cmd *cobra.Command, args []string) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
cmd/erasure-healing.go
if len(disks) == 0 { return errors.New("listAndHeal: No non-healing drives found") } expectedDisks := len(disks)/2 + 1 fallbackDisks := disks[expectedDisks:] disks = disks[:expectedDisks] // How to resolve partial results. resolver := metadataResolutionParams{ dirQuorum: 1, objQuorum: 1, bucket: bucket, strict: false, // Allow less strict matching. } path := baseDirFromPrefix(prefix)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/data-scanner.go
// // We therefore perform a heal check. // If that doesn't bring it back we remove the folder and assume it was deleted. // This means that the next run will not look for it. // How to resolve results. resolver := metadataResolutionParams{ dirQuorum: f.disksQuorum, objQuorum: f.disksQuorum, bucket: "", strict: false, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
// It lists the ones applied to the pod, and the current active mTLS mode. // When the client doesn't have access to root namespace, it will only show workload namespace Peerauthentications. func describePeerAuthentication( writer io.Writer, kubeClient kube.CLIClient, configClient istioclient.Interface, workloadNamespace string, podsLabels klabels.Set,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0)