- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 100 for pvcs (0.03 sec)
-
src/crypto/rsa/rsa.go
// Package rsa implements RSA encryption as specified in PKCS #1 and RFC 8017. // // RSA is a single, fundamental operation that is used in this package to // implement either public-key encryption or public-key signatures. // // The original specification for encryption and signatures with RSA is PKCS #1 // and the terms "RSA encryption" and "RSA signatures" by default refer to // PKCS #1 version 1.5. However, that specification has flaws and new designs
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:11:18 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/registry/core/persistentvolumeclaim/strategy_test.go
} switch { case oldPvcHasConditins || newPvcHasConditions: // new pvc should not be changed if the feature is enabled, or if the old pvc had Conditions if !reflect.DeepEqual(newPvc, newPvcInfo.pvc()) { t.Errorf("new pvc changed: %v", cmp.Diff(newPvc, newPvcInfo.pvc())) } default: // new pvc should not need to be changed if !reflect.DeepEqual(newPvc, newPvcInfo.pvc()) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.2K bytes - Viewed (0) -
src/cmd/trace/pprof.go
return rec } // Slow path: the stack may still be in the map. // Grab the stack's PCs as the source-of-truth. var pcs [pprofMaxStack]uint64 pcsForStack(stack, &pcs) // Check the source-of-truth. var rec *traceviewer.ProfileRecord if existing, ok := m.pcs[pcs]; ok { // In the map. rec = m.stacks[existing] delete(m.stacks, existing) } else { // Not in the map.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
// Locking Registries list while walking it to prevent inconsistent results for _, r := range c.GetRegistries() { svcs := r.Services() if r.Provider() != provider.Kubernetes { index += len(svcs) services = append(services, svcs...) } else { for _, s := range svcs { previous, ok := smap[s.Hostname] if !ok { // First time we see a service. The result will have a single service per hostname
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
src/crypto/rsa/pss_test.go
"crypto/sha256" "encoding/hex" "math/big" "os" "strconv" "strings" "testing" ) func TestEMSAPSS(t *testing.T) { // Test vector in file pss-int.txt from: ftp://ftp.rsasecurity.com/pub/pkcs/pkcs-1/pkcs-1v2-1-vec.zip msg := []byte{ 0x85, 0x9e, 0xef, 0x2f, 0xd7, 0x8a, 0xca, 0x00, 0x30, 0x8b, 0xdc, 0x47, 0x11, 0x93, 0xbf, 0x55, 0xbf, 0x9d, 0x78, 0xdb, 0x8f, 0x8a, 0x67, 0x2b, 0x48, 0x46, 0x34, 0xf3, 0xc9, 0xc2,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/assume_cache.go
Spec: v1.PersistentVolumeSpec{ StorageClassName: storageClassName, }, }) pvs := []*v1.PersistentVolume{} for _, obj := range objs { pv, ok := obj.(*v1.PersistentVolume) if !ok { c.logger.Error(&assumecache.WrongTypeError{TypeName: "v1.PersistentVolume", Object: obj}, "ListPVs") continue } pvs = append(pvs, pv) } return pvs } // PVCAssumeCache is a AssumeCache for PersistentVolumeClaim objects
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator_test.go
available = int64(5000000) inodesTotal = int64(2000) inodesFree = int64(1000) vol0 = "vol0" vol1 = "vol1" vol2 = "vol2" vol3 = "vol3" pvcClaimName0 = "pvc-fake0" pvcClaimName1 = "pvc-fake1" ) var ( ErrorWatchTimeout = errors.New("watch event timeout") // Create pod spec to test against podVolumes = []k8sv1.Volume{ { Name: vol0, VolumeSource: k8sv1.VolumeSource{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
utils/utils.go
} return filepath.ToSlash(s) + "/" } // FileWithLineNum return the file name and line number of the current file func FileWithLineNum() string { pcs := [13]uintptr{} // the third caller usually from gorm internal len := runtime.Callers(3, pcs[:]) frames := runtime.CallersFrames(pcs[:len]) for i := 0; i < len; i++ { // second return value is "more", not "ok" frame, _ := frames.Next()
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Apr 22 06:43:02 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/provision_test.go
expectedEvents: noevents, errors: noerrors, test: wrapTestWithProvisionCalls([]provisionCall{}, testSyncClaim), }, { // volume provision for PVC scheduled "11-23 - skip finding PV and provision for PVC annotated with AnnSelectedNode", newVolumeArray("volume11-23", "1Gi", "", "", v1.VolumeAvailable, v1.PersistentVolumeReclaimDelete, classCopper), []*v1.PersistentVolume{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 35.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
func (c *Controller) updateServiceNodePortAddresses(svcs ...*model.Service) bool { // node event, update all nodePort gateway services if len(svcs) == 0 { svcs = c.getNodePortGatewayServices() } // no nodePort gateway service found, no update if len(svcs) == 0 { return false } for _, svc := range svcs { c.RLock() nodeSelector := c.nodeSelectorsForServices[svc.Hostname]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0)