Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetExec (0.31 sec)

  1. 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)
  2. pkg/kubelet/kuberuntime/kuberuntime_container.go

    		return remote.ErrContainerStatusNil
    	}
    	return m.ReadLogs(ctx, status.GetLogPath(), containerID.ID, logOptions, stdout, stderr)
    }
    
    // GetExec gets the endpoint the runtime will serve the exec request from.
    func (m *kubeGenericRuntimeManager) GetExec(ctx context.Context, id kubecontainer.ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error) {
    	req := &runtimeapi.ExecRequest{
    		ContainerId: id.ID,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  3. pkg/kubelet/container/runtime.go

    // streaming calls (exec/attach/port-forward) themselves. In this case, Kubelet should redirect to
    // the runtime server.
    type StreamingRuntime interface {
    	GetExec(ctx context.Context, id ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error)
    	GetAttach(ctx context.Context, id ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods.go

    	}
    	// TODO(tallclair): Pass a proper timeout value.
    	return kl.runner.RunInContainer(ctx, container.ID, cmd, 0)
    }
    
    // GetExec gets the URL the exec will be served from, or nil if the Kubelet will serve it.
    func (kl *Kubelet) GetExec(ctx context.Context, podFullName string, podUID types.UID, containerName string, cmd []string, streamOpts remotecommandserver.Options) (*url.URL, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  5. pkg/volume/plugins.go

    	DeleteServiceAccountTokenFunc() func(podUID types.UID)
    
    	// Returns an interface that should be used to execute any utilities in volume plugins
    	GetExec(pluginName string) exec.Interface
    
    	// Returns the labels on the node
    	GetNodeLabels() (map[string]string, error)
    
    	// Returns the name of the node
    	GetNodeName() types.NodeName
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods_test.go

    			fakeRuntime := &containertest.FakeStreamingRuntime{FakeRuntime: testKubelet.fakeRuntime}
    			kubelet.containerRuntime = fakeRuntime
    			kubelet.streamingRuntime = fakeRuntime
    
    			redirect, err := kubelet.GetExec(ctx, tc.podFullName, podUID, tc.container, tc.command, remotecommand.Options{})
    			if tc.expectError {
    				assert.Error(t, err, description)
    			} else {
    				assert.NoError(t, err, description)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top