- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,622 for lake (0.05 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/fake/fake_customresourcedefinition.go
See the License for the specific language governing permissions and limitations under the License. */ // Code generated by client-gen. DO NOT EDIT. package fake import ( "context" json "encoding/json" "fmt" v1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1" apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/client/applyconfiguration/apiextensions/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_test.go
VolumeSource: v1.VolumeSource{ RBD: &v1.RBDVolumeSource{ RBDImage: "fake-device", }, }, }, }, }) stopCh := runVolumeManager(kubelet) defer close(stopCh) kubelet.podManager.SetPods([]*v1.Pod{pod}) // Fake node status update go simulateVolumeInUseUpdate( v1.UniqueVolumeName("fake/fake-device"), stopCh, kubelet.volumeManager)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 20.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
return wait.ExponentialBackoff(backoff, fn) } func createTestClient(attachedVolumes ...v1.AttachedVolume) *fake.Clientset { fakeClient := &fake.Clientset{} if len(attachedVolumes) == 0 { attachedVolumes = append(attachedVolumes, v1.AttachedVolume{ Name: "fake-plugin/fake-device1", DevicePath: "fake/path", }) } fakeClient.AddReactor("get", "nodes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/proxy/conntrack/cleanup_test.go
} for _, tc := range testCases { t.Run(tc.description, func(t *testing.T) { fake := NewFake() CleanStaleEntries(fake, svcPortMap, tc.serviceUpdates, tc.endpointsUpdates) if !fake.ClearedIPs.Equal(tc.result.ClearedIPs) { t.Errorf("Expected ClearedIPs=%v, got %v", tc.result.ClearedIPs, fake.ClearedIPs) } if !fake.ClearedPorts.Equal(tc.result.ClearedPorts) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 7.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
server := &fakeServer{} server.Start(fakeCtx) server.On("DelPodFromMesh", fakeCtx, pod, ).Return(errors.New("fake error")) fakeClientSet := fake.NewSimpleClientset() m := meshDataplane{ kubeClient: fakeClientSet, netServer: server, } // pod is not in fake client, so if this will try to remove annotation, it will fail. err := m.DelPodFromMesh(fakeCtx, pod) assert.Error(t, err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 7.8K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/deprecation/LoggingDeprecatedFeatureHandlerTest.groovy
} def 'fake call with #deprecationTracePropertyName=true logs full stack trace.'() { given: System.setProperty(deprecationTracePropertyName, 'true') useStackTrace(fakeStackTrace) when: handler.featureUsed(new DeprecatedFeatureUsage(deprecatedFeatureUsage('fake'))) def events = outputEventListener.events then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 16:09:54 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
ObjectMeta: metav1.ObjectMeta{Name: testHostname}, Status: v1.NodeStatus{ VolumesAttached: []v1.AttachedVolume{ { Name: "fake/fake-device", DevicePath: "fake/path", }, }}, } pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "abc", Namespace: "nsA", UID: "1234", }, Spec: v1.PodSpec{ Containers: []v1.Container{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/testing/openapi.go
openapi "k8s.io/kube-openapi/pkg/util/proto" ) // Fake opens and returns a openapi swagger from a file Path. It will // parse only once and then return the same copy everytime. type Fake struct { Path string once sync.Once document *openapi_v2.Document err error } // OpenAPISchema returns the openapi document and a potential error. func (f *Fake) OpenAPISchema() (*openapi_v2.Document, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 14:34:26 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/metrics/metrics_test.go
} fakePluginCount := dswCount["fake-plugin"] if fakePluginCount != 1 { t.Errorf("getVolumeCount failed. Expected <1> fake-plugin volume in DesiredStateOfWorld, got <%d>", fakePluginCount) } aswCount, ok := count["actual_state_of_world"] if !ok { t.Errorf("getVolumeCount failed. Expected <actual_state_of_world>, got nothing") } fakePluginCount = aswCount["fake-plugin"] if fakePluginCount != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4K bytes - Viewed (0) -
pkg/controller/deployment/rolling_test.go
if !test.scaleExpected { if scaled || len(fake.Actions()) > 0 { t.Errorf("unexpected scaling: %v", fake.Actions()) } continue } if test.scaleExpected && !scaled { t.Errorf("expected scaling to occur") continue } if len(fake.Actions()) != 1 { t.Errorf("expected 1 action during scale, got: %v", fake.Actions()) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 11K bytes - Viewed (0)