- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 152 for vaName (0.18 sec)
-
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
if err != nil { t.Fatalf("Run failed with error. Failed to create a new pv: <%v>", err) } pvInformer.GetIndexer().Add(newPv) } if tc.vaName != "" { newVa := controllervolumetesting.NewVolumeAttachment(tc.vaName, tc.pvName, tc.vaNodeName, tc.vaAttachStatus) _, err = adc.kubeClient.StorageV1().VolumeAttachments().Create(tCtx, newVa, metav1.CreateOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
}, NodeName: nodeName, }, } } // Returns a volumeAttachment object func NewVolumeAttachment(vaName, pvName, nodeName string, status bool) *storagev1.VolumeAttachment { return &storagev1.VolumeAttachment{ ObjectMeta: metav1.ObjectMeta{ UID: types.UID(vaName), Name: vaName, }, Spec: storagev1.VolumeAttachmentSpec{ Attacher: "test.storage.gke.io", NodeName: nodeName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
if pvName == nil { // Currently VA objects are created for CSI volumes only. nil pvName is unexpected, generate a warning logger.Info("Skipping the va as its pvName is nil", "node", klog.KRef("", string(nodeName)), "vaName", va.Name) continue } pv, err := adc.pvLister.Get(*pvName) if err != nil { logger.Error(err, "Unable to lookup pv object", "PV", klog.KRef("", *pvName)) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
src/cmd/link/internal/ld/pe.go
va := int(sect.virtualAddress) pefile.dataDirectory[pe.IMAGE_DIRECTORY_ENTRY_EXPORT].VirtualAddress = uint32(va) pefile.dataDirectory[pe.IMAGE_DIRECTORY_ENTRY_EXPORT].Size = sect.virtualSize vaName := va + binary.Size(&e) + nexport*4 vaAddr := va + binary.Size(&e) vaNa := va + binary.Size(&e) + nexport*8 e.Characteristics = 0 e.MajorVersion = 0 e.MinorVersion = 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 19:01:27 UTC 2023 - 48.8K bytes - Viewed (0) -
cni/pkg/ipset/ipset.go
func NewIPSet(name string, v6 bool, deps NetlinkIpsetDeps) (IPSet, error) { var err error set := IPSet{ V4Name: fmt.Sprintf(V4Name, name), Deps: deps, Prefix: name, } err = deps.ipsetIPHashCreate(set.V4Name, false) if v6 { set.V6Name = fmt.Sprintf(V6Name, name) v6err := deps.ipsetIPHashCreate(set.V6Name, true) err = errors.Join(err, v6err) } return set, err } func (m *IPSet) DestroySet() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
} func TestAddPodToHostNSIPSetsV6(t *testing.T) { pod := buildConvincingPod(true) var podUID string = string(pod.ObjectMeta.UID) fakeIPSetDeps := ipset.FakeNLDeps() set := ipset.IPSet{V4Name: "foo-v4", V6Name: "foo-v6", Prefix: "foo", Deps: fakeIPSetDeps} ipProto := uint8(unix.IPPROTO_TCP) fakeIPSetDeps.On("addIP", "foo-v6", netip.MustParseAddr("e9ac:1e77:90ca:399f:4d6d:ece3:2f9b:3162"), ipProto,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
pkg/api/persistentvolume/util_test.go
newSpec: specWithVACName(vacName), expectNewSpec: specWithVACName(vacName), oldSpec: specWithVACName(vacName), expectOldSpec: specWithVACName(vacName), }, "disabled vac old pv had volume attributes class name": { vacEnabled: false, newSpec: specWithVACName(vacName), expectNewSpec: specWithVACName(vacName), oldSpec: specWithVACName(vacName), expectOldSpec: specWithVACName(vacName),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/serviceaccount/claims_test.go
private: &privateClaims{Kubernetes: kubernetes{Svcacct: ref{Name: "saname", UID: "sauid"}, Namespace: "ns"}}, expectErr: "", }, { name: "expired", getter: fakeGetter{serviceAccount, nil, nil, nil}, private: &privateClaims{Kubernetes: kubernetes{Svcacct: ref{Name: "saname", UID: "sauid"}, Namespace: "ns"}}, expiry: *jwt.NewNumericDate(now().Add(-1_000 * time.Hour)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 17.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/certs/certlist_test.go
for _, cert := range test.certs { if cert.CAName != "" && certMap[cert.CAName] == nil { t.Errorf("Certificate %q references nonexistent CA %q", cert.Name, cert.CAName) } } }) } } func TestMakeCertTree(t *testing.T) { rootCert := &KubeadmCert{ Name: "root", } leaf0 := &KubeadmCert{ Name: "leaf0", CAName: "root", } leaf1 := &KubeadmCert{ Name: "leaf1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/api/persistentvolumeclaim/util_test.go
oldSpec: core.PersistentVolumeClaimSpec{}, }, "vac disabled with vac when vac exists in oldSpec": { spec: core.PersistentVolumeClaimSpec{VolumeAttributesClassName: vacName}, oldSpec: core.PersistentVolumeClaimSpec{VolumeAttributesClassName: vacName}, vacEnabled: false, wantVAC: vacName, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.9K bytes - Viewed (0)