- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 187 for ok (0.13 sec)
-
cmd/erasure-server-pool-rebalance.go
func (z *erasureServerPools) updateRebalanceStats(ctx context.Context) error { var ok bool for i := range z.serverPools { if z.findIndex(i) == -1 { // Also ensure to initialize rebalanceStats to indicate // its a new pool that can receive rebalanced data. z.rebalMeta.PoolStats = append(z.rebalMeta.PoolStats, &rebalanceStats{}) ok = true } } if ok { lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
src/archive/tar/writer.go
default: return n, nil } } func (sw *sparseFileWriter) ReadFrom(r io.Reader) (n int64, err error) { rs, ok := r.(io.ReadSeeker) if ok { if _, err := rs.Seek(0, io.SeekCurrent); err != nil { ok = false // Not all io.Seeker can really seek } } if !ok { return io.Copy(struct{ io.Writer }{sw}, r) } var readLastByte bool pos0 := sw.pos
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
return } func tokenDataFromSecret(tokenSecret *v1.Secret) (ca, token []byte, err error) { var ok bool ca, ok = tokenSecret.Data[v1.ServiceAccountRootCAKey] if !ok { err = errMissingRootCAKey return } token, ok = tokenSecret.Data[v1.ServiceAccountTokenKey] if !ok { err = errMissingTokenKey return } return }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
// if an apply patch occurs for an object that doesn't yet exist, create it. if patch.Type() != types.ApplyPatchType { return clnt.Patch(ctx, obj, patch, opts...) } 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) {
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) -
cmd/encryption-v1_test.go
} if kdf, ok := test.metadata[crypto.MetaAlgorithm]; !ok { t.Errorf("Test %d: ServerSideEncryptionKDF must be part of metadata: %v", i, kdf) } if iv, ok := test.metadata[crypto.MetaIV]; !ok { t.Errorf("Test %d: crypto.SSEIV must be part of metadata: %v", i, iv) } if mac, ok := test.metadata[crypto.MetaSealedKeySSEC]; !ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 24 04:17:08 GMT 2022 - 19.9K bytes - Viewed (0) -
cmd/iam-etcd-store.go
for { outerLoop: watchCh := ies.client.Watch(ctx, keyPath, etcd.WithPrefix(), etcd.WithKeysOnly()) for { select { case <-ctx.Done(): return case watchResp, ok := <-watchCh: if !ok { time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } if err := watchResp.Err(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
responses, err = queryEachShard(all, dr, istioNamespace, kubeClient, centralOpts) } if err != nil { if _, ok := err.(ControlPlaneNotFoundError); ok { // Attempt to get the XDS address from the webhook and try again addr, err := getXdsAddressFromWebhooks(kubeClient) if err == nil { centralOpts.Xds = addr.host
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) -
internal/event/target/kafka.go
} func (target *KafkaTarget) addToBatch(key store.Key) error { if target.batch.IsFull() { if err := target.commitBatch(); err != nil { return err } } if _, ok := target.batch.GetByKey(key.Name); !ok { eventData, err := target.store.Get(key.Name) if err != nil { if os.IsNotExist(err) { return nil } return err } msg, err := target.toProducerMessage(eventData)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/grid/grid_test.go
const testPayload = "Hello Grid World!" // Single requests should have remote errors. _, err := remoteConn.Request(context.Background(), handlerTest, []byte(testPayload)) if v, ok := err.(*RemoteErr); !ok || v.Error() != "Invalid Handler for type" { t.Fatalf("Unexpected error: %v, %T", err, err) } // Streams should not be able to set up until registered. // Thus, the error is a local error.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/metrics-resource.go
} func collectDriveMetrics(m madmin.RealtimeMetrics) { latestDriveStatsMu.Lock() for d, dm := range m.ByDisk { labels := map[string]string{"drive": d} latestStats, ok := latestDriveStats[d] if !ok { latestDriveStats[d] = dm.IOStats continue } updateDriveIOStats(dm.IOStats, latestStats, labels) latestDriveStats[d] = dm.IOStats } lastDriveStatsRefresh = time.Now().UTC()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0)