- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 71 for could (0.12 sec)
-
operator/cmd/mesh/manifest_shared_test.go
} check, ok := obj.DeepCopyObject().(client.Object) if !ok { return errors.New("could not check for object in fake client") } if err := clnt.Get(ctx, client.ObjectKeyFromObject(obj), check); kerrors.IsNotFound(err) { if err := clnt.Create(ctx, check); err != nil { return fmt.Errorf("could not inject object creation for fake: %w", err) } } else if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
istioctl/pkg/multixds/gather.go
return nil, err } defer fw.Close() xdsOpts.Xds = fw.Address() response, err := GetXdsResponse(dr, istioNamespace, tokenServiceAccount, xdsOpts, dialOpts) if err != nil { return nil, fmt.Errorf("could not get XDS from discovery pod %q: %v", pod.Name, err) } responses = append(responses, response) if !all && len(responses) > 0 { break } } return responses, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
Pretty: true, Strict: true, }) whObject, _, err := deserializer.Decode([]byte(validatingWebhookYAML), nil, &admitv1.ValidatingWebhookConfiguration{}) if err != nil { return "", fmt.Errorf("could not decode generated webhook: %w", err) } decodedWh := whObject.(*admitv1.ValidatingWebhookConfiguration) for i := range decodedWh.Webhooks { decodedWh.Webhooks[i].ClientConfig.CABundle = []byte(config.CABundle) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 13.2K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
tokenReq, err := kubeClient.Kube().CoreV1().ServiceAccounts(wg.Namespace).CreateToken(context.Background(), serviceAccount, token, metav1.CreateOptions{}) // errors if the token could not be created with the given service account in the given namespace if err != nil { return fmt.Errorf("could not create a token under service account %s in namespace %s: %v", serviceAccount, wg.Namespace, err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
s.iptablesConfigurator.DeleteHostRules() log.Debug("destroying host ipset") s.hostsideProbeIPSet.Flush() if err := s.hostsideProbeIPSet.DestroySet(); err != nil { log.Warnf("could not destroy host ipset on shutdown") } log.Debug("stopping ztunnel server") s.ztunnelServer.Close() } func (s *NetServer) rescanPod(pod *corev1.Pod) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
chainable_api.go
func (db *DB) Offset(offset int) (tx *DB) { tx = db.getInstance() tx.Statement.AddClause(clause.Limit{Offset: offset}) return } // Scopes pass current database connection to arguments `func(DB) DB`, which could be used to add conditions dynamically // // func AmountGreaterThan1000(db *gorm.DB) *gorm.DB { // return db.Where("amount > ?", 1000) // } // // func OrderStatus(status []string) func (db *gorm.DB) *gorm.DB {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Apr 17 03:38:55 GMT 2024 - 14.3K bytes - Viewed (1) -
cmd/object-api-errors.go
return "Invalid upload id " + e.UploadID } // InvalidPart One or more of the specified parts could not be found type InvalidPart struct { PartNumber int ExpETag string GotETag string } func (e InvalidPart) Error() string { return fmt.Sprintf("Specified part could not be found. PartNumber %d, Expected %s, got %s", e.PartNumber, e.ExpETag, e.GotETag) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
cmd/peer-s3-client.go
} } } // loop through buckets and see if some with lost quorum // these could be stale buckets lying around, queue a heal // of such a bucket. This is needed here as we identify such // buckets here while listing buckets. As part of regular // globalBucketMetadataSys.Init() call would get a valid // buckets only and not the quourum lost ones like this, so // explicit call
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// used for the upload-id-marker request parameter in a subsequent request. NextUploadIDMarker string // Maximum number of multipart uploads that could have been included in the // response. MaxUploads int // Indicates whether the returned list of multipart uploads is truncated. A // value of true indicates that the list was truncated. The list can be truncated
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
if err := rs.ReconstructData(split); err == nil { fmt.Println("Could reconstruct completely") for i, data := range split[:k] { start := i * len(data) copy(mapped[start:], data) } lastValid = size - 1 missing = 0 } else { fmt.Println("Could NOT reconstruct:", err) } } } if lastValid == 0 { return errors.New("no valid data found")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1)