- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 256 for fetches (0.24 sec)
-
cmd/kubeadm/app/cmd/upgrade/node.go
initCfg.NodeRegistration.IgnorePreflightErrors = sets.List(ignorePreflightErrorsSet) var patchesDir string if upgradeCfg.Node.Patches != nil { patchesDir = cmdutil.ValueFromFlagsOrConfig(cmd.Flags(), options.Patches, upgradeCfg.Node.Patches.Directory, nodeOptions.patchesDir).(string) } else { patchesDir = nodeOptions.patchesDir } return &nodeData{ cfg: upgradeCfg,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
if pvc.Spec.VolumeName == "" { return nil, errors.New("PVC has empty pvc.Spec.VolumeName") } return pvc, nil } // getPVSpec fetches the PV object with the given name from the API server // and returns a volume.Spec representing it. // An error is returned if the call to fetch the PV object fails. func (dswp *desiredStateOfWorldPopulator) getPVSpec( name string, pvcReadOnly bool,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
cmd/peer-rest-server.go
globalBucketHTTPStats.delete(bucketName) if localMetacacheMgr != nil { localMetacacheMgr.deleteBucketCache(bucketName) } return } // GetAllBucketStatsHandler - fetches bucket replication stats for all buckets from this peer. func (s *peerRESTServer) GetAllBucketStatsHandler(mss *grid.MSS) (*BucketStatsMap, *grid.RemoteErr) { replicationStats := globalReplicationStats.GetAll()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 52.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) -
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) -
cluster/gce/windows/k8s-node-setup.psm1
$kube_env_table[$key] = $val.Trim("'", " ", "`"") } return ${kube_env_table} } # Fetches the kube-env from the instance metadata. # # Returns: a PowerShell Hashtable object containing the key-value pairs from # kube-env. function Fetch-KubeEnv { # Testing / debugging: # First: # ${kube_env} = Get-InstanceMetadataAttribute 'kube-env' # or:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testGetBucketPolicyHandler, endpoints: []string{"PutBucketPolicy", "GetBucketPolicy"}}) } // testGetBucketPolicyHandler - Test for end point which fetches the access policy json of the given bucket. func testGetBucketPolicyHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler, credentials auth.Credentials, t *testing.T, ) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
cb.req.Push.AddMetric(model.DuplicatedClusters, c.Name, cb.proxyID, fmt.Sprintf("Duplicate cluster %s found while pushing CDS", c.Name)) } } return out } // getAllCachedSubsetClusters either fetches all cached clusters for a given key (there may be multiple due to subsets) // and returns them along with allFound=True, or returns allFound=False indicating a cache miss. In either case,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0)