- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for Wong (0.16 sec)
-
cmd/handler-api.go
// Only replace if needed. // Existing requests will use the previous limit, // but new requests will use the new limit. // There will be a short overlap window, // but this shouldn't last long. t.requestsPool = make(chan struct{}, apiRequestsMaxPerNode) } t.requestsDeadline = cfg.RequestsDeadline listQuorum := cfg.ListQuorum if listQuorum == "" { listQuorum = "strict" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 10K bytes - Viewed (0) -
operator/cmd/mesh/install.go
ic := &cobra.Command{ Use: "install", Short: "Applies an Istio manifest, installing or reconfiguring Istio on a cluster.", Long: "The install command generates an Istio install manifest and applies it to a cluster.", Aliases: []string{"apply"}, // nolint: lll Example: ` # Apply a default Istio installation istioctl install
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
cmd/admin-handlers.go
hr := healResp{respBytes, apiErr, errMsg} respCh <- hr }() } // Due to the force-starting functionality, the Launch // call above can take a long time - to keep the // connection alive, we start sending whitespace keepConnLive(w, r, respCh) } // getAggregatedBackgroundHealState returns the heal state of disks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
istioctl/pkg/waypoint/waypoint.go
gw.Labels = map[string]string{label.IoIstioRev.Name: revision} } return &gw, nil } waypointGenerateCmd := &cobra.Command{ Use: "generate", Short: "Generate a waypoint configuration", Long: "Generate a waypoint configuration as YAML", Example: ` # Generate a waypoint as yaml istioctl x waypoint generate --namespace default`, RunE: func(cmd *cobra.Command, args []string) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
// corresponding error value. NB When there is more than one error value that // occurs maximum number of times, the error value returned depends on how // golang's map orders keys. This doesn't affect correctness as long as quorum // value is greater than or equal to simple majority, since none of the equally // maximal values would occur quorum or more number of times. func reduceErrs(errs []error, ignoredErrs []error) (maxCount int, maxErr error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
src/bytes/buffer_test.go
readBytes, _ := buf.Read(tmp) yBytes := Repeat(y, growLen) allocs := testing.AllocsPerRun(100, func() { buf.Grow(growLen) buf.Write(yBytes) }) // Check no allocation occurs in write, as long as we're single-threaded. if allocs != 0 { t.Errorf("allocation occurred during write") } // Check that buffer has correct data. if !Equal(buf.Bytes()[0:startLen-readBytes], xBytes[readBytes:]) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Apr 26 13:31:36 GMT 2024 - 18.6K bytes - Viewed (0) -
cmd/bucket-handlers.go
if r.ContentLength <= 0 { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMissingContentLength), r.URL) return } // The max. XML contains 100000 object names (each at most 1024 bytes long) + XML overhead const maxBodySize = 2 * 100000 * 1024 if r.ContentLength > maxBodySize { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEntityTooLarge), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0)