- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for PortForward (0.85 sec)
-
pkg/kube/portforwarder.go
fw, err := portforward.NewOnAddresses(dialer, []string{f.localAddress}, []string{fmt.Sprintf("%d:%d", f.localPort, f.podPort)}, f.stopCh, readyCh, io.Discard, os.Stderr) if err != nil { return nil, fmt.Errorf("failed establishing port-forward: %v", err) } // Run the same check as k8s.io/kubectl/pkg/cmd/portforward/portforward.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/portforward/constants.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package portforward const ( PortForwardV1Name = "portforward.k8s.io" WebsocketsSPDYTunnelingPrefix = "SPDY/3.1+" KubernetesSuffix = ".k8s.io"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 855 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
"k8s.io/apimachinery/pkg/util/httpstream" "k8s.io/apimachinery/pkg/util/httpstream/spdy" constants "k8s.io/apimachinery/pkg/util/portforward" "k8s.io/apimachinery/pkg/util/proxy" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/registry/rest" restconfig "k8s.io/client-go/rest" "k8s.io/client-go/tools/portforward" ) func TestTunnelingHandler_UpgradeStreamingAndTunneling(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
if err != nil { return err } return portForward(name, namespace, "SkyWalking", "http://%s", bindAddress, skywalkingPort, client, cmd.OutOrStdout(), browser) }, } return cmd } // portForward first tries to forward localhost:remotePort to podName:remotePort, falls back to dynamic local port func portForward(podName, namespace, flavor, urlFormat, localAddress string, remotePort int,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 01:29:35 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
pkg/registry/core/pod/rest/subresources.go
} // NewConnectOptions returns the versioned object that represents the // portforward parameters func (r *PortForwardREST) NewConnectOptions() (runtime.Object, bool, string) { return &api.PodPortForwardOptions{}, false, "" } // ConnectMethods returns the methods supported by portforward func (r *PortForwardREST) ConnectMethods() []string { return upgradeableMethods }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kubelet/server/auth_test.go
"/metrics/probes": "metrics", "/metrics/resource": "metrics", "/pods/": "proxy", "/portForward/{podNamespace}/{podID}": "proxy", "/portForward/{podNamespace}/{podID}/{uid}": "proxy", "/run/{podNamespace}/{podID}/{containerName}": "proxy", "/run/{podNamespace}/{podID}/{uid}/{containerName}": "proxy",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 18:09:38 UTC 2024 - 5K bytes - Viewed (0) -
manifests/charts/istio-operator/templates/clusterrole.yaml
- leases verbs: - get - create - update - apiGroups: - "" resources: - configmaps - endpoints - events - namespaces - pods - pods/proxy - pods/portforward - persistentvolumeclaims - secrets - services - serviceaccounts - resourcequotas verbs: - '*'
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/doc.go
// STDERR, TTY resize, and error streams) to the input streams of a // SPDY connection. // // The stream tunnel proxy tunnels SPDY frames through a WebSocket // connection, and it is used for the PortForward subprotocol (e.g. // kubectl port-forward). This proxy implements tunneling by transparently // encoding and decoding SPDY framed data into and out of the payload of a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 17:56:46 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/kubelet/server/server.go
ws.Route(ws.POST("/{podNamespace}/{podID}/{uid}/{containerName}"). To(s.getAttach). Operation("getAttach")) s.restfulCont.Add(ws) s.addMetricsBucketMatcher("portForward") ws = new(restful.WebService) ws. Path("/portForward") ws.Route(ws.GET("/{podNamespace}/{podID}"). To(s.getPortForward). Operation("getPortForward")) ws.Route(ws.POST("/{podNamespace}/{podID}"). To(s.getPortForward).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0)