| /dports/sysutils/cbsd-mq-api/cbsd-mq-api-0.3/src/github.com/beanstalkd/go-beanstalk/ |
| H A D | conn_test.go | 9 c := NewConn(mock("", ""))
22 c := NewConn(mock("", ""))
35 c := NewConn(mock("", ""))
48 c := NewConn(mock("", ""))
58 c := NewConn(mock("delete 1\r\n", "NOT_FOUND\r\n"))
70 c := NewConn(mock(
88 c := NewConn(mock(
109 c := NewConn(mock("bury 1 3\r\n", "BURIED\r\n"))
133 c := NewConn(mock("delete 1\r\n", "DELETED\r\n"))
175 c := NewConn(mock(
[all …]
|
| H A D | tube_test.go | 9 c := NewConn(mock("put 0 0 0 3\r\nfoo\r\n", "INSERTED 1\r\n"))
24 c := NewConn(mock("peek-ready\r\n", "FOUND 1 1\r\nx\r\n"))
42 c := NewConn(mock("peek-delayed\r\n", "FOUND 1 1\r\nx\r\n"))
60 c := NewConn(mock("peek-buried\r\n", "FOUND 1 1\r\nx\r\n"))
78 c := NewConn(mock("kick 2\r\n", "KICKED 1\r\n"))
93 c := NewConn(mock("stats-tube default\r\n", "OK 10\r\n---\na: ok\n\r\n"))
108 c := NewConn(mock("pause-tube default 5\r\n", "PAUSED\r\n"))
|
| /dports/sysutils/cbsd-mq-router/cbsd-mq-router-0.2/src/github.com/beanstalkd/go-beanstalk/ |
| H A D | conn_test.go | 9 c := NewConn(mock("", ""))
22 c := NewConn(mock("", ""))
35 c := NewConn(mock("", ""))
48 c := NewConn(mock("", ""))
58 c := NewConn(mock("delete 1\r\n", "NOT_FOUND\r\n"))
70 c := NewConn(mock(
88 c := NewConn(mock(
109 c := NewConn(mock("bury 1 3\r\n", "BURIED\r\n"))
133 c := NewConn(mock("delete 1\r\n", "DELETED\r\n"))
175 c := NewConn(mock(
[all …]
|
| H A D | tube_test.go | 9 c := NewConn(mock("put 0 0 0 3\r\nfoo\r\n", "INSERTED 1\r\n"))
24 c := NewConn(mock("peek-ready\r\n", "FOUND 1 1\r\nx\r\n"))
42 c := NewConn(mock("peek-delayed\r\n", "FOUND 1 1\r\nx\r\n"))
60 c := NewConn(mock("peek-buried\r\n", "FOUND 1 1\r\nx\r\n"))
78 c := NewConn(mock("kick 2\r\n", "KICKED 1\r\n"))
93 c := NewConn(mock("stats-tube default\r\n", "OK 10\r\n---\na: ok\n\r\n"))
108 c := NewConn(mock("pause-tube default 5\r\n", "PAUSED\r\n"))
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/mattbaird/elastigo/elastigo-2fe47fd29e4b/lib/ |
| H A D | connection_test.go | 21 c := NewConn()
27 c = NewConn()
33 c = NewConn()
39 c = NewConn()
45 c = NewConn()
51 c = NewConn()
57 c = NewConn()
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/rafaeljusto/redigomock/ |
| H A D | redigomock_test.go | 59 connection := NewConn()
81 connection := NewConn()
120 connection := NewConn()
142 connection := NewConn()
169 connection := NewConn()
181 connection := NewConn()
191 connection := NewConn()
249 c := NewConn()
257 c := NewConn()
343 conn := NewConn()
[all …]
|
| H A D | command_test.go | 17 connection := NewConn()
54 connection := NewConn()
158 connection := NewConn()
181 connection := NewConn()
205 connection := NewConn()
246 connection := NewConn()
291 connection := NewConn()
311 connection := NewConn()
334 connection := NewConn()
358 connection := NewConn()
[all …]
|
| /dports/net-im/coyim/coyim-0.3.11/session/ |
| H A D | session_test.go | 116 conn := xmpp.NewConn(
143 conn := xmpp.NewConn(
179 conn := xmpp.NewConn(
203 conn := xmpp.NewConn(
227 conn := xmpp.NewConn(
268 conn := xmpp.NewConn(
308 conn := xmpp.NewConn(
351 conn := xmpp.NewConn(
384 conn := xmpp.NewConn(
424 conn := xmpp.NewConn(
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-transport-upgrader/ |
| H A D | upgrader_test.go | 34 func (m *negotiatingMuxer) NewConn(c net.Conn, isServer bool) (mux.MuxedConn, error) { func
45 return mplex.DefaultTransport.NewConn(c, isServer)
59 func (m *blockingMuxer) NewConn(c net.Conn, isServer bool) (mux.MuxedConn, error) { func
61 return (&negotiatingMuxer{}).NewConn(c, isServer)
73 func (m *errorMuxer) NewConn(c net.Conn, isServer bool) (mux.MuxedConn, error) { func
|
| /dports/devel/gh/cli-2.4.0/vendor/github.com/sourcegraph/jsonrpc2/ |
| H A D | call_opt_test.go | 24 …connA := jsonrpc2.NewConn(ctx, jsonrpc2.NewBufferedStream(a, jsonrpc2.VSCodeObjectCodec{}), handle…
25 …connB := jsonrpc2.NewConn(ctx, jsonrpc2.NewBufferedStream(b, jsonrpc2.VSCodeObjectCodec{}), noopHa…
83 …connA := jsonrpc2.NewConn(ctx, jsonrpc2.NewBufferedStream(a, jsonrpc2.VSCodeObjectCodec{}), handle…
84 …connB := jsonrpc2.NewConn(ctx, jsonrpc2.NewBufferedStream(b, jsonrpc2.VSCodeObjectCodec{}), noopHa…
|
| H A D | jsonrpc2_test.go | 166 jc := jsonrpc2.NewConn(r.Context(), websocketjsonrpc2.NewObjectStream(c), &ha)
186 cc := jsonrpc2.NewConn(ctx, stream, &hb)
267 …connA := jsonrpc2.NewConn(ctx, jsonrpc2.NewBufferedStream(a, jsonrpc2.VSCodeObjectCodec{}), handle…
268 …connB := jsonrpc2.NewConn(ctx, jsonrpc2.NewBufferedStream(b, jsonrpc2.VSCodeObjectCodec{}), noopHa…
313 …c := jsonrpc2.NewConn(context.Background(), jsonrpc2.NewBufferedStream(&readWriteCloser{eof, eof},…
322 …c := jsonrpc2.NewConn(context.Background(), jsonrpc2.NewBufferedStream(&readWriteCloser{eof, eof},…
335 …c := jsonrpc2.NewConn(context.Background(), jsonrpc2.NewBufferedStream(&readWriteCloser{eof, eof},…
351 …c := jsonrpc2.NewConn(context.Background(), jsonrpc2.NewBufferedStream(&readWriteCloser{eof, eof},…
376 jsonrpc2.NewConn(ctx, jsonrpc2.NewBufferedStream(conn, jsonrpc2.VarintObjectCodec{}), h, opts...)
|
| /dports/www/gitea/gitea-1.16.5/modules/log/ |
| H A D | conn_test.go | 43 logger := NewConn()
98 logger := NewConn()
114 logger := NewConn()
128 logger := NewConn()
169 logger := NewConn()
206 logger = NewConn()
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net/gscloud/gscloud-0.11.0/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/github.com/envoyproxy/protoc-gen-validate/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net-mgmt/blackbox_exporter/blackbox_exporter-0.17.0/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net-mgmt/adguard-exporter/adguard-exporter-1.14/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/golang.org/x/net/net-ab3426394381/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net/rclone/rclone-1.57.0/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/devel/gh/cli-2.4.0/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/net/evans/evans-0.9.1/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|
| /dports/devel/app-builder/app-builder-3.4.2/vendor/golang.org/x/net/ipv4/ |
| H A D | endpoint.go | 33 func NewConn(c net.Conn) *Conn { func
34 cc, _ := socket.NewConn(c)
103 cc, _ := socket.NewConn(c.(net.Conn))
169 cc, err := socket.NewConn(c.(net.Conn))
|