- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,843 for lake (0.06 sec)
-
pkg/volume/csi/csi_client_test.go
return fake.NewNodeClientWithVolumeStats(volumeStatsCapable) }) } func TestClientNodeSupportsVolumeMountGroup(t *testing.T) { testClientNodeSupportsCapabilities(t, func(client *csiDriverClient) (bool, error) { return client.NodeSupportsVolumeMountGroup(context.Background()) }, func(volumeMountGroupCapable bool) *fake.NodeClient {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 17 06:30:53 UTC 2023 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/fake_example.go
_, err := c.Fake.Invokes(action, &v1.ExampleList{}) return err } // Patch applies the patch and returns the patched example. func (c *FakeExamples) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.Example, err error) { emptyResult := &v1.Example{} obj, err := c.Fake.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 5.5K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
Namespace: "test", }, Spec: v1alpha3.ServiceEntry{}, } fake := kube.NewFakeClient() clienttest.NewWriter[*clientnetworkingv1alpha3.ServiceEntry](t, fake).Create(obj) for _, s := range collections.Pilot.All() { clienttest.MakeCRD(t, fake, s.GroupVersionResource()) } stop := test.NewStop(t) c := New(fake, Option{}) events := atomic.NewInt64(0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/filewatcher/fakefilewatcher.go
func NewFakeWatcher(changedFunc func(path string, added bool)) (NewFileWatcherFunc, *FakeWatcher) { w := &FakeWatcher{ events: make(map[string]chan fsnotify.Event), errors: make(map[string]chan error), changedFunc: changedFunc, } return func() FileWatcher { return w }, w } // Add is a fake implementation of the FileWatcher interface. func (w *FakeWatcher) Add(path string) error { w.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 14:06:41 UTC 2023 - 3.6K bytes - Viewed (0) -
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/kubelet/pluginmanager/metrics/metrics_test.go
if !ok { t.Errorf("getPluginCount failed. Expected <desired_state_of_world>, got nothing") } fakePluginCount := dswCount["fake/path/plugin.sock"] if fakePluginCount != 1 { t.Errorf("getPluginCount failed. Expected <1> fake/path/plugin.sock in DesiredStateOfWorld, got <%d>", fakePluginCount) } aswCount, ok := count["actual_state_of_world"] if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 12 12:48:20 UTC 2019 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/fake/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package fake provides a fake audit.Backend interface implementation for testing.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 10 17:16:18 UTC 2018 - 719 bytes - Viewed (0)