- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 492 for fetches (0.13 sec)
-
cmd/kubeadm/app/phases/upgrade/compute.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 03:03:29 UTC 2024 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler.go
// Equal priority uses name to break ties return iName < jName } // i sorts before j if it has a higher priority return iPriority > jPriority }) return groups } // Fetches from cache if it exists. If cache is empty, create it. func (rdm *resourceDiscoveryManager) fetchFromCache() *cachedGroupList { rdm.lock.RLock() defer rdm.lock.RUnlock() cacheLoad := rdm.cache.Load()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 16.1K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
}) } } return res, nil } // Enabled returns if configURL is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(ConfigURL) != "" } // GetSettings - fetches OIDC settings for site-replication related validation. // NOTE that region must be populated by caller as this package does not know. func (r *Config) GetSettings() madmin.OpenIDSettings { res := madmin.OpenIDSettings{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/security/security.go
// identity. WorkloadKeyCertResourceName = "default" // GCE is Credential fetcher type of Google plugin GCE = "GoogleComputeEngine" // JWT is a Credential fetcher type that reads from a JWT token file JWT = "JWT" // Mock is Credential fetcher type of mock plugin Mock = "Mock" // testing only // GoogleCAProvider uses the Google CA for workload certificate signing
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 19.1K bytes - Viewed (0) -
cmd/erasure-metadata.go
} // GetInternalReplicationState is a wrapper method to fetch internal replication state from the map m func GetInternalReplicationState(m map[string][]byte) ReplicationState { m1 := make(map[string]string, len(m)) for k, v := range m { m1[k] = string(v) } return getInternalReplicationState(m1) } // getInternalReplicationState fetches internal replication state from the map m
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
// max_bytes the cache is a pass-through. tf_gcs_filesystem::RamFileBlockCache cache1(1, 0, 0, fetcher); tf_gcs_filesystem::RamFileBlockCache cache2(0, 1, 0, fetcher); tf_gcs_filesystem::RamFileBlockCache cache3(0, 0, 0, fetcher); tf_gcs_filesystem::RamFileBlockCache cache4(1000, 1000, 0, fetcher); std::vector<char> out; TF_EXPECT_OK(ReadCache(&cache1, want_filename, want_offset, want_n, &out));
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Oct 15 03:16:57 UTC 2021 - 23.2K bytes - Viewed (0) -
pkg/ledger/smt.go
} } else if len(batch[iBatch]) != 0 && batch[iBatch][hashLength] == 1 { isShortcut = true } return batch, iBatch, batch[2*iBatch+1], batch[2*iBatch+2], isShortcut, nil } // loadBatch fetches a batch of nodes in cache or db func (s *smt) loadBatch(root []byte) ([][]byte, error) { var node hash copy(node[:], root)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 14K bytes - Viewed (0) -
tensorflow/cc/saved_model/loader.cc
// leaving behind non-GC'ed state. // // Detailed motivation behind this approach, from ashankar@: // // Each call to Session::Run() that identifies a new subgraph (based on feeds // and fetches) creates some datastructures that live as long as the session // (the partitioned graph, associated executors etc.). // // A pathological case of this would be if say the initialization op
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 02 04:36:00 UTC 2024 - 23K bytes - Viewed (0) -
tensorflow/c/eager/c_api.h
TFE_TensorHandle** inputs, int num_inputs, TF_Status* status); // Fetches the current number of inputs attached to `op`. // // Does not use the operation's definition to determine how many inputs should // be attached. It is intended for use with TFE_OpGetFlatInput to inspect an
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 22.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
return true, errors.New(strings.Join(errs, "; ")) } return len(vm.actualStateOfWorld.GetMountedVolumesForPod(podName)) == 0, nil } } // getUnmountedVolumes fetches the current list of mounted volumes from // the actual state of the world, and uses it to process the list of // expectedVolumes. It returns a list of unmounted volumes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0)