| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams map[uint32]httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
92 streams: make(map[uint32]httpstream.Stream),
113 c.streams = make(map[uint32]httpstream.Stream, 0)
123 func (c *connection) RemoveStreams(streams ...httpstream.Stream) {
136 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams map[uint32]httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
92 streams: make(map[uint32]httpstream.Stream),
113 c.streams = make(map[uint32]httpstream.Stream, 0)
123 func (c *connection) RemoveStreams(streams ...httpstream.Stream) {
133 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/k8s.io/apimachinery/apimachinery-0.21.1/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams map[uint32]httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
92 streams: make(map[uint32]httpstream.Stream),
113 c.streams = make(map[uint32]httpstream.Stream, 0)
123 func (c *connection) RemoveStreams(streams ...httpstream.Stream) {
133 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams map[uint32]httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
92 streams: make(map[uint32]httpstream.Stream),
113 c.streams = make(map[uint32]httpstream.Stream, 0)
123 func (c *connection) RemoveStreams(streams ...httpstream.Stream) {
136 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/net/gscloud/gscloud-0.11.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
50 func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, …
57 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
108 c.streams = make([]httpstream.Stream, 0)
119 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
50 func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, …
57 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
108 c.streams = make([]httpstream.Stream, 0)
119 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
50 func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, …
57 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
108 c.streams = make([]httpstream.Stream, 0)
119 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
50 func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, …
57 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
108 c.streams = make([]httpstream.Stream, 0)
119 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/net/inlets/inlets-3.0.2/vendor/k8s.io/apimachinery/apimachinery-0.20.1/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
50 func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, …
57 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
108 c.streams = make([]httpstream.Stream, 0)
119 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
50 func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, …
57 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
108 c.streams = make([]httpstream.Stream, 0)
119 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
41 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
50 func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, …
57 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
63 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
74 …nWithPings(conn net.Conn, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration) …
87 …ection, newStreamHandler httpstream.NewStreamHandler, pingPeriod time.Duration, pingFn func() (tim…
108 c.streams = make([]httpstream.Stream, 0)
119 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/sysutils/helmfile/helmfile-0.138.7/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /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 D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/misc/concourse/concourse-6.7.2/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/sysutils/go-wtf/wtf-0.21.0/vendor/k8s.io/apimachinery/apimachinery-6fa4771c83b3/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /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 D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/containerd/containerd/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/apimachinery/pkg/util/httpstream/spdy/ |
| H A D | connection.go | 34 streams []httpstream.Stream
36 newStreamHandler httpstream.NewStreamHandler
40 func NewClientConnection(conn net.Conn) (httpstream.Connection, error) {
47 return newConnection(spdyConn, httpstream.NoOpNewStreamHandler), nil
53 func NewServerConnection(conn net.Conn, newStreamHandler httpstream.NewStreamHandler) (httpstream.C…
66 …Connection(conn *spdystream.Connection, newStreamHandler httpstream.NewStreamHandler) httpstream.C…
84 c.streams = make([]httpstream.Stream, 0)
95 func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
110 func (c *connection) registerStream(s httpstream.Stream) {
|