Home
last modified time | relevance | path

Searched refs:newStreamHandler (Results 1 – 25 of 134) sorted by relevance

123456

/dports/net/gscloud/gscloud-0.11.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
88 c := &connection{conn: conn, newStreamHandler: newStreamHandler, ping: pingFn}
152 err := c.newStreamHandler(stream, replySent)
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
88 c := &connection{conn: conn, newStreamHandler: newStreamHandler, ping: pingFn}
152 err := c.newStreamHandler(stream, replySent)
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
88 c := &connection{conn: conn, newStreamHandler: newStreamHandler, ping: pingFn}
152 err := c.newStreamHandler(stream, replySent)
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
88 c := &connection{conn: conn, newStreamHandler: newStreamHandler, ping: pingFn}
152 err := c.newStreamHandler(stream, replySent)
/dports/net/inlets/inlets-3.0.2/vendor/k8s.io/apimachinery/apimachinery-0.20.1/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
88 c := &connection{conn: conn, newStreamHandler: newStreamHandler, ping: pingFn}
152 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
88 c := &connection{conn: conn, newStreamHandler: newStreamHandler, ping: pingFn}
152 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
88 c := &connection{conn: conn, newStreamHandler: newStreamHandler, ping: pingFn}
152 err := c.newStreamHandler(stream, replySent)
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
90 newStreamHandler: newStreamHandler,
169 err := c.newStreamHandler(stream, replySent)
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
90 newStreamHandler: newStreamHandler,
166 err := c.newStreamHandler(stream, replySent)
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/k8s.io/apimachinery/apimachinery-0.21.1/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
90 newStreamHandler: newStreamHandler,
166 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
64 return NewServerConnectionWithPings(conn, newStreamHandler, 0)
74 func NewServerConnectionWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, ping…
81 return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil
87 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler, pingP…
90 newStreamHandler: newStreamHandler,
169 err := c.newStreamHandler(stream, replySent)
/dports/security/vault/vault-1.8.2/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/k8s.io/apimachinery/apimachinery-0.16.8/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/misc/concourse/concourse-6.7.2/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/go-wtf/wtf-0.21.0/vendor/k8s.io/apimachinery/apimachinery-6fa4771c83b3/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/devel/mutagen/mutagen-0.11.8/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/
H A Dconnection.go36 newStreamHandler httpstream.NewStreamHandler member
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
60 return newConnection(spdyConn, newStreamHandler), nil
66 func newConnection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) https…
67 c := &connection{conn: conn, newStreamHandler: newStreamHandler}
128 err := c.newStreamHandler(stream, replySent)

123456