- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 453 for ctx_ (0.05 sec)
-
internal/kms/stub.go
// StubKMS is a KMS implementation for tests type StubKMS struct { KeyNames []string } // Version returns the type of the KMS. func (s StubKMS) Version(ctx context.Context) (string, error) { return "stub", nil } // APIs returns supported APIs func (s StubKMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) { return []madmin.KMSAPI{ {Method: http.MethodGet, Path: "stub/path"}, }, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint_test.go
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Apr 04 15:53:09 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/metrics-v3-cluster-config.go
) // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config // such as standard and RRS parity. func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { clusterDriveMetrics, err := c.clusterDriveMetrics.Get() if err != nil { metricsLogIf(ctx, err) } else { m.Set(configStandardParity, float64(clusterDriveMetrics.storageInfo.Backend.StandardSCParity))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 1.5K bytes - Viewed (0) -
istioctl/pkg/admin/admin.go
// limitations under the License. package admin import ( "fmt" "github.com/spf13/cobra" "istio.io/istio/istioctl/pkg/cli" ) func Cmd(ctx cli.Context) *cobra.Command { adminCmd := &cobra.Command{ Use: "admin", Short: "Manage control plane (istiod) configuration", Long: "A group of commands used to manage istiod configuration",
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.4K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
errorWriter io.Writer } type Patch struct { addr *obj.Addr label string } func NewParser(ctxt *obj.Link, ar *arch.Arch, lexer lex.TokenReader) *Parser { pkgPrefix := obj.UnlinkablePkg if ctxt != nil { pkgPrefix = objabi.PathToPrefix(ctxt.Pkgpath) } return &Parser{ ctxt: ctxt, arch: ar, lex: lexer, labels: make(map[string]*obj.Prog),
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Sep 04 18:16:59 UTC 2024 - 36.9K bytes - Viewed (0) -
cmd/peer-rest-server.go
return np, grid.NewRemoteErr(err) } subSys := vars.Get(peerRESTSubSys) // Apply dynamic values. ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defer cancel() if subSys == "" { err = applyDynamicConfig(ctx, objAPI, srvCfg) } else { err = applyDynamicConfigForSubSys(ctx, objAPI, srvCfg, subSys) } if err != nil { return np, grid.NewRemoteErr(err) } default:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
cmd/admin-heal-ops.go
) var ( errHealIdleTimeout = errors.New("healing results were not consumed for too long") errHealStopSignalled = errors.New("heal stop signaled") errFnHealFromAPIErr = func(ctx context.Context, err error) error { apiErr := toAdminAPIErr(ctx, err) return fmt.Errorf("Heal internal error: %s: %s", apiErr.Code, apiErr.Description) } ) // healSequenceStatus - accumulated status of the heal sequence
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/api-response.go
// Similar check to http.checkWriteHeaderCode if err.HTTPStatusCode < 100 || err.HTTPStatusCode > 999 { bugLogIf(ctx, fmt.Errorf("invalid WriteHeader code %v from %v", err.HTTPStatusCode, err.Code)) err.HTTPStatusCode = http.StatusInternalServerError } // Generate error response. errorResponse := getAPIErrorResponse(ctx, err, reqURL.Path, w.Header().Get(xhttp.AmzRequestID), w.Header().Get(xhttp.AmzRequestHostID))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 19:27:06 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/metacache-stream.go
// The context allows the operation to be canceled. func (r *metacacheReader) readAll(ctx context.Context, dst chan<- metaCacheEntry) error { r.checkInit() if r.err != nil { return r.err } defer xioutil.SafeClose(dst) if r.current.name != "" { select { case <-ctx.Done(): r.err = ctx.Err() return ctx.Err() case dst <- r.current: } r.current.name = "" r.current.metadata = nil
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/test-utils_test.go
} func prepareErasureSets32(ctx context.Context) (ObjectLayer, []string, error) { return prepareErasure(ctx, 32) } func prepareErasure(ctx context.Context, nDisks int) (ObjectLayer, []string, error) { fsDirs, err := getRandomDisks(nDisks) if err != nil { return nil, nil, err } obj, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...)) if err != nil { removeRoots(fsDirs)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0)