- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 422 for getY (0.21 sec)
-
istioctl/pkg/checkinject/checkinject.go
if err != nil { return err } pod, err := kubeClient.Kube().CoreV1().Pods(podNs).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return err } ns, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.TODO(), podNs, metav1.GetOptions{}) if err != nil { return err } podLabels = pod.GetLabels()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
secretKey string // Sent body body []byte // Expected response expectedRespStatus int lifecycleResponse []byte errorResponse APIErrorResponse shouldPass bool }{ // GET empty credentials { method: http.MethodGet, bucketName: bucketName, accessKey: "", secretKey: "", expectedRespStatus: http.StatusForbidden, lifecycleResponse: []byte(""),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 13 20:52:33 GMT 2023 - 11.2K bytes - Viewed (0) -
cmd/leak-detect_test.go
if t.Failed() { return } // Loop, waiting for goroutines to shut down. // Wait up to 5 seconds, but finish as quickly as possible. deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines. leaked := initialSnapShot.CompareCurrentSnapshot() // current stack snapshot matches the initial one, no leaks, return. if len(leaked) == 0 { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/object-api-utils.go
if w == 0 { return true } return false } // mustGetUUID - get a random UUID. func mustGetUUID() string { u, err := uuid.NewRandom() if err != nil { logger.CriticalIf(GlobalContext, err) } return u.String() } // mustGetUUIDBytes - get a random UUID as 16 bytes unencoded. func mustGetUUIDBytes() []byte { u, err := uuid.NewRandom() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/batch-expire.go
} func (oiCache objInfoCache) Get(toDel ObjectToDelete) (*ObjectInfo, bool) { oi, ok := oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)] return oi, ok } func batchObjsForDelete(ctx context.Context, r *BatchJobExpire, ri *batchJobInfo, job BatchJobRequest, api ObjectLayer, wk *workers.Workers, expireCh <-chan []expireObjInfo) { vc, _ := globalBucketVersioningSys.Get(r.Bucket) retryAttempts := r.Retry.Attempts
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cni/pkg/nodeagent/podcgroupns_other.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 781 bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
# (This is the usual way to get the debug information with an out-of-cluster control plane.) istioctl x internal-debug syncz --xds-address istio.cloudprovider.example.com:15012 # Retrieve syncz debug information via Kubernetes config, using token security # (This is the usual way to get the debug information with an in-cluster control plane.) istioctl x internal-debug syncz
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
switch p, m := req.URL.Path, req.Method; { case p == "/namespaces/istio-system/deployments/foo" && m == "GET": body := cmdtesting.ObjBody(codec, attachDeploy("istio-system")) return &http.Response{StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: body}, nil case p == "/namespaces/test/deployments/foo" && m == "GET": body := cmdtesting.ObjBody(codec, attachDeploy("test"))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
cmd/admin-router.go
func adminMiddleware(f http.HandlerFunc, flags ...hFlag) http.HandlerFunc { // Collect all flags with bitwise-OR and assign operator var handlerFlags hFlag for _, flag := range flags { handlerFlags |= flag } // Get name of the handler using reflection. handlerName := getHandlerName(f, "adminAPIHandlers") var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) { // Update request context with `logger.ReqInfo`.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/warm-backend-azure.go
if err != nil { return "", azureToObjectError(err, az.Bucket, object) } return remoteVersionID(res.Version()), nil } func (az *warmBackendAzure) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) { if opts.startOffset < 0 { return nil, InvalidRange{} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1)