- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for attacher (0.26 sec)
-
pkg/volume/csi/csi_attacher_test.go
if attached.attached && !ok { t.Error("failed to retrieve attached status for:", attached.spec) } if attached.attached != stat { t.Errorf("expecting volume attachment %t, got %t", attached.attached, stat) } } }) } } func TestAttacherVolumesAreAttachedWithInline(t *testing.T) { type attachedSpec struct { volName string spec *volume.Spec attached bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/apis/storage/validation/validation_test.go
Spec: storage.VolumeAttachmentSpec{ Attacher: "myattacher", Source: storage.VolumeAttachmentSource{ PersistentVolumeName: &volumeName, }, NodeName: "mynode", }, }, { ObjectMeta: metav1.ObjectMeta{Name: "foo-with-inlinespec"}, Spec: storage.VolumeAttachmentSpec{ Attacher: "myattacher", Source: storage.VolumeAttachmentSource{ InlineVolumeSpec: &inlineSpec,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 69.7K bytes - Viewed (0) -
pkg/volume/testing/testing.go
// have a zero WaitForAttachCallCount. Otherwise it returns an error. func VerifyZeroWaitForAttachCallCount(fakeVolumePlugin *FakeVolumePlugin) error { for _, attacher := range fakeVolumePlugin.GetAttachers() { actualCallCount := attacher.GetWaitForAttachCallCount() if actualCallCount != 0 { return fmt.Errorf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
func() (bool, error) { for i, attacher := range fakePlugin.GetAttachers() { actualCallCount := attacher.GetAttachCallCount() if actualCallCount == expectedAttachCallCount { return true, nil } t.Logf( "Warning: Wrong attacher[%v].GetAttachCallCount(). Expected: <%v> Actual: <%v>. Will try next attacher.", i, expectedAttachCallCount, actualCallCount)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
staging/src/k8s.io/api/storage/v1alpha1/generated.pb.go
if err != nil { return 0, err } i -= size i = encodeVarintGenerated(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 i -= len(m.Attacher) copy(dAtA[i:], m.Attacher) i = encodeVarintGenerated(dAtA, i, uint64(len(m.Attacher))) i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *VolumeAttachmentStatus) Marshal() (dAtA []byte, err error) { size := m.Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 76.5K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
csiMounter.csiClient = setupClient(t, true) attachID := getAttachmentName(csiMounter.volumeID, string(csiMounter.driverName), string(plug.host.GetNodeName())) attachment := &storage.VolumeAttachment{ ObjectMeta: meta.ObjectMeta{ Name: attachID, }, Spec: storage.VolumeAttachmentSpec{ NodeName: "test-node", Attacher: CSIPluginName, Source: storage.VolumeAttachmentSource{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go
} } // Calls AddVolumeNode() once with attached set to false. // Verifies a single volume/node entry exists. // Then calls AddVolumeNode() to attach the volume to a different node with attached set to true // Verifies volume is attached to the node according to asw. func Test_AddVolumeNode_Positive_NewVolumeTwoNodesWithFalseAttached(t *testing.T) { // Arrange
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/resource_op_lifting.cc
// Helper class to hoist resource ops out of regions attached to an op. class RegionResourceHoister { public: explicit RegionResourceHoister(Operation* op) : op_(op) {} // Analyzes attached regions to record resources read and written. LogicalResult Analyze(); // Returns all resources accessed by the regions attached the op. auto& GetResources() { return resources_; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 55.1K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/instantiation/generator/AbstractClassGenerator.java
* <li>An {@link ExtensionAware} implementation is added, unless {@link NonExtensible} is attached to the class.</li> * <li>An {@link IConventionAware} implementation is added, unless {@link NoConventionMapping} is attached to the class.</li> * </ul> */ abstract class AbstractClassGenerator implements ClassGenerator { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 06 21:54:37 UTC 2024 - 63K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/testFixtures/groovy/org/gradle/api/internal/provider/PropertySpec.groovy
when: setToNull(property) then: assertHasProducer(property, task) } def "producer task of upstream provider is ignored when producer task attached to property"() { def task = Mock(Task) def upstream = Mock(Task) def property = propertyWithNoValue() property.set(supplierWithProducer(upstream)) expect:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 11:41:55 UTC 2024 - 87.8K bytes - Viewed (0)