- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for GetExec (0.34 sec)
-
pkg/kubelet/server/server.go
To(s.getExec). Operation("getExec")) ws.Route(ws.POST("/{podNamespace}/{podID}/{containerName}"). To(s.getExec). Operation("getExec")) ws.Route(ws.GET("/{podNamespace}/{podID}/{uid}/{containerName}"). To(s.getExec). Operation("getExec")) ws.Route(ws.POST("/{podNamespace}/{podID}/{uid}/{containerName}"). To(s.getExec). Operation("getExec")) s.restfulCont.Add(ws)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
pkg/volume/iscsi/attacher.go
} if mountArgs.SELinuxLabel != "" { options = volumeutil.AddSELinuxMountOption(options, mountArgs.SELinuxLabel) } if notMnt { diskMounter := &mount.SafeFormatAndMount{Interface: mounter, Exec: attacher.host.GetExec(iscsiPluginName)} mountOptions := volumeutil.MountOptionFromSpec(spec, options...) err = diskMounter.FormatAndMount(devicePath, deviceMountPath, fsType, mountOptions) if err != nil { os.Remove(deviceMountPath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 04 08:51:31 UTC 2022 - 6.8K bytes - Viewed (0) -
pkg/kubelet/container/testing/runtime_mock.go
} // GetExec indicates an expected call of GetExec. func (mr *MockStreamingRuntimeMockRecorder) GetExec(ctx, id, cmd, stdin, stdout, stderr, tty any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetExec", reflect.TypeOf((*MockStreamingRuntime)(nil).GetExec), ctx, id, cmd, stdin, stdout, stderr, tty) } // GetPortForward mocks base method.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 27K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher-defaults.go
options := make([]string, 0) if readOnly { options = append(options, "ro") } else { options = append(options, "rw") } diskMounter := &mount.SafeFormatAndMount{Interface: mounter, Exec: a.plugin.host.GetExec(a.plugin.GetPluginName())} return diskMounter.FormatAndMount(devicePath, deviceMountPath, volSourceFSType, options)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 2.4K bytes - Viewed (0) -
pkg/volume/fc/attacher.go
} if mountArgs.SELinuxLabel != "" { options = volumeutil.AddSELinuxMountOption(options, mountArgs.SELinuxLabel) } if notMnt { diskMounter := &mount.SafeFormatAndMount{Interface: mounter, Exec: attacher.host.GetExec(fcPluginName)} mountOptions := volumeutil.MountOptionFromSpec(spec, options...) err = diskMounter.FormatAndMount(devicePath, deviceMountPath, volumeSource.FSType, mountOptions) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 31 12:02:51 UTC 2022 - 7.5K bytes - Viewed (0) -
platforms/jvm/language-java/src/integTest/groovy/org/gradle/java/compile/jpms/execution/JavaModuleExecutionIntegrationTest.groovy
given: buildFile << """ interface Services { @javax.inject.Inject ExecOperations getExec() } task run { dependsOn jar def execOperations = project.objects.newInstance(Services).exec doLast {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
secret, err := createSecretMap(spec, plugin, pod.Namespace) if err != nil { return nil, err } return plugin.newMounterInternal(spec, pod.UID, &ISCSIUtil{}, plugin.host.GetMounter(plugin.GetPluginName()), plugin.host.GetExec(plugin.GetPluginName()), secret) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/volume/fc/fc.go
// Inject real implementations here, test through the internal function. return plugin.newMounterInternal(spec, pod.UID, &fcUtil{}, plugin.host.GetMounter(plugin.GetPluginName()), plugin.host.GetExec(plugin.GetPluginName())) } func (plugin *fcPlugin) newMounterInternal(spec *volume.Spec, podUID types.UID, manager diskManager, mounter mount.Interface, exec utilexec.Interface) (volume.Mounter, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/volume_host.go
return func(types.UID) { //nolint:logcheck klog.ErrorS(nil, "DeleteServiceAccountToken unsupported in PersistentVolumeController") } } func (adc *PersistentVolumeController) GetExec(pluginName string) utilexec.Interface { return utilexec.New() } func (ctrl *PersistentVolumeController) GetNodeLabels() (map[string]string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_runtime.go
ContainerFilesystems: f.ContainerFsStats, } return resp, f.Err } func (f *FakeStreamingRuntime) GetExec(_ context.Context, id kubecontainer.ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error) { f.Lock() defer f.Unlock() f.CalledFunctions = append(f.CalledFunctions, "GetExec") return &url.URL{Host: FakeHost}, f.Err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 00:23:50 UTC 2024 - 13.9K bytes - Viewed (0)