| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/rafthttp/ |
| H A D | stream.go | 277 peerID types.ID
278 typ streamType
280 tr *Transport
281 picker *urlPicker
282 status *peerStatus
288 errorc chan<- error
290 mu sync.Mutex
291 paused bool
292 closer io.Closer
294 ctx context.Context
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/rafthttp/ |
| H A D | stream.go | 277 peerID types.ID
278 typ streamType
280 tr *Transport
281 picker *urlPicker
282 status *peerStatus
288 errorc chan<- error
290 mu sync.Mutex
291 paused bool
292 closer io.Closer
294 ctx context.Context
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/rafthttp/ |
| H A D | stream.go | 277 peerID types.ID
278 typ streamType
280 tr *Transport
281 picker *urlPicker
282 status *peerStatus
288 errorc chan<- error
290 mu sync.Mutex
291 paused bool
292 closer io.Closer
294 ctx context.Context
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/rafthttp/ |
| H A D | stream.go | 277 peerID types.ID
278 typ streamType
280 tr *Transport
281 picker *urlPicker
282 status *peerStatus
288 errorc chan<- error
290 mu sync.Mutex
291 paused bool
292 closer io.Closer
294 ctx context.Context
[all …]
|
| /dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/coreos/etcd/rafthttp/ |
| H A D | stream.go | 277 peerID types.ID
278 typ streamType
280 tr *Transport
281 picker *urlPicker
282 status *peerStatus
288 errorc chan<- error
290 mu sync.Mutex
291 paused bool
292 closer io.Closer
294 ctx context.Context
[all …]
|
| /dports/devel/etcd31/etcd-3.1.20/rafthttp/ |
| H A D | stream.go | 269 peerID types.ID
270 typ streamType
272 tr *Transport
273 picker *urlPicker
274 status *peerStatus
278 errorc chan<- error
280 mu sync.Mutex
281 paused bool
282 cancel func()
283 closer io.Closer
[all …]
|
| /dports/devel/etcd32/etcd-3.2.32/rafthttp/ |
| H A D | stream.go | 272 peerID types.ID
273 typ streamType
275 tr *Transport
276 picker *urlPicker
277 status *peerStatus
281 errorc chan<- error
283 mu sync.Mutex
284 paused bool
285 cancel func()
286 closer io.Closer
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
| H A D | stream.go | 356 lg *zap.Logger
358 peerID types.ID
359 typ streamType
361 tr *Transport
362 picker *urlPicker
363 status *peerStatus
369 errorc chan<- error
371 mu sync.Mutex
372 paused bool
373 closer io.Closer
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
| H A D | stream.go | 367 lg *zap.Logger
369 peerID types.ID
370 typ streamType
372 tr *Transport
373 picker *urlPicker
374 status *peerStatus
380 errorc chan<- error
382 mu sync.Mutex
383 paused bool
384 closer io.Closer
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/ |
| H A D | stream.go | 356 lg *zap.Logger
358 peerID types.ID
359 typ streamType
361 tr *Transport
362 picker *urlPicker
363 status *peerStatus
369 errorc chan<- error
371 mu sync.Mutex
372 paused bool
373 closer io.Closer
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/ |
| H A D | stream.go | 356 lg *zap.Logger
358 peerID types.ID
359 typ streamType
361 tr *Transport
362 picker *urlPicker
363 status *peerStatus
369 errorc chan<- error
371 mu sync.Mutex
372 paused bool
373 closer io.Closer
[all …]
|
| /dports/www/minio-client/etcd-3.5.0/server/etcdserver/api/rafthttp/ |
| H A D | stream.go | 356 lg *zap.Logger
358 peerID types.ID
359 typ streamType
361 tr *Transport
362 picker *urlPicker
363 status *peerStatus
369 errorc chan<- error
371 mu sync.Mutex
372 paused bool
373 closer io.Closer
[all …]
|
| /dports/devel/etcd/etcd-2.3.8/rafthttp/ |
| H A D | stream.go | 244 tr *Transport
245 picker *urlPicker
246 t streamType
247 local, remote types.ID
248 cid types.ID
254 mu sync.Mutex
255 paused bool
256 cancel func()
257 closer io.Closer
258 stopc chan struct{}
[all …]
|
| /dports/devel/etcd34/etcd-3.4.18/etcdserver/api/rafthttp/ |
| H A D | stream.go | 367 lg *zap.Logger
369 peerID types.ID
370 typ streamType
372 tr *Transport
373 picker *urlPicker
374 status *peerStatus
380 errorc chan<- error
382 mu sync.Mutex
383 paused bool
384 closer io.Closer
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
| H A D | stream.go | 367 lg *zap.Logger
369 peerID types.ID
370 typ streamType
372 tr *Transport
373 picker *urlPicker
374 status *peerStatus
380 errorc chan<- error
382 mu sync.Mutex
383 paused bool
384 closer io.Closer
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/gopherjs/gopherjs/compiler/natives/src/net/http/ |
| H A D | fetch.go | 16 type streamReader struct { struct
17 pending []byte
18 stream *js.Object
21 func (r *streamReader) Read(p []byte) (n int, err error) {
52 func (r *streamReader) Close() error {
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/gopherjs/gopherjs/compiler/natives/src/net/http/ |
| H A D | fetch.go | 16 type streamReader struct { struct
17 pending []byte
18 stream *js.Object
21 func (r *streamReader) Read(p []byte) (n int, err error) {
52 func (r *streamReader) Close() error {
|
| /dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/gopherjs/gopherjs/compiler/natives/src/net/http/ |
| H A D | fetch.go | 16 type streamReader struct { struct
17 pending []byte
18 stream *js.Object
21 func (r *streamReader) Read(p []byte) (n int, err error) {
52 func (r *streamReader) Close() error {
|
| /dports/www/writefreely/writefreely-0.13.1/vendor/github.com/gopherjs/gopherjs/compiler/natives/src/net/http/ |
| H A D | fetch.go | 16 type streamReader struct { struct
17 pending []byte
18 stream *js.Object
21 func (r *streamReader) Read(p []byte) (n int, err error) {
52 func (r *streamReader) Close() error {
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/gopherjs/gopherjs/compiler/natives/src/net/http/ |
| H A D | fetch.go | 16 type streamReader struct { struct
17 pending []byte
18 stream *js.Object
21 func (r *streamReader) Read(p []byte) (n int, err error) {
52 func (r *streamReader) Close() error {
|
| /dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/github.com/gopherjs/gopherjs/compiler/natives/src/net/http/ |
| H A D | fetch.go | 16 type streamReader struct { struct
17 pending []byte
18 stream *js.Object
21 func (r *streamReader) Read(p []byte) (n int, err error) {
52 func (r *streamReader) Close() error {
|
| /dports/audio/visp-go/visp-2585747/vendor/github.com/gopherjs/gopherjs/compiler/natives/src/os/ |
| H A D | os.go | 16 if process := js.Global.Get("process"); process != js.Undefined {
17 argv := process.Get("argv")
18 Args = make([]string, argv.Length()-1)
28 func runtime_beforeExit() {}
|
| /dports/lang/gcc9-devel/gcc-9-20211007/libgo/go/net/http/ |
| H A D | roundtrip_js.go | 178 type streamReader struct { struct
179 pending []byte
180 stream js.Value
181 err error // sticky read error
184 func (r *streamReader) Read(p []byte) (n int, err error) {
231 func (r *streamReader) Close() error {
|
| /dports/lang/gcc9/gcc-9.4.0/libgo/go/net/http/ |
| H A D | roundtrip_js.go | 178 type streamReader struct { struct
179 pending []byte
180 stream js.Value
181 err error // sticky read error
184 func (r *streamReader) Read(p []byte) (n int, err error) {
231 func (r *streamReader) Close() error {
|
| /dports/lang/gcc9-aux/gcc-9.1.0/libgo/go/net/http/ |
| H A D | roundtrip_js.go | 178 type streamReader struct { struct
179 pending []byte
180 stream js.Value
181 err error // sticky read error
184 func (r *streamReader) Read(p []byte) (n int, err error) {
231 func (r *streamReader) Close() error {
|