Home
last modified time | relevance | path

Searched refs:FrameTypeResponse (Results 1 – 8 of 8) sorted by relevance

/dports/net/nsq/nsq-1.2.1/vendor/github.com/nsqio/go-nsq/
H A Dmock_test.go225 instruction{0, FrameTypeResponse, []byte("OK")},
227 instruction{0, FrameTypeResponse, []byte("OK")},
300 instruction{0, FrameTypeResponse, []byte("OK")},
302 instruction{0, FrameTypeResponse, []byte("OK")},
368 instruction{0, FrameTypeResponse, []byte("OK")},
370 instruction{0, FrameTypeResponse, []byte("OK")},
433 instruction{0, FrameTypeResponse, []byte("OK")},
435 instruction{0, FrameTypeResponse, []byte("OK")},
480 instruction{0, FrameTypeResponse, []byte("OK")},
482 instruction{0, FrameTypeResponse, []byte("OK")},
H A Dconn.go410 if frameType != FrameTypeResponse || !bytes.Equal(data, []byte("OK")) {
428 if frameType != FrameTypeResponse || !bytes.Equal(data, []byte("OK")) {
445 if frameType != FrameTypeResponse || !bytes.Equal(data, []byte("OK")) {
502 if frameType == FrameTypeResponse && bytes.Equal(data, []byte("_heartbeat_")) {
515 case FrameTypeResponse:
H A Dprotocol.go19 FrameTypeResponse int32 = 0 const
H A Dproducer.go319 w.popTransaction(FrameTypeResponse, data)
H A Dproducer_test.go330 m.delegate.OnResponse(nil, framedResponse(FrameTypeResponse, []byte("OK")))
/dports/net/nsq/nsq-1.2.1/bench/bench_channels/
H A Dbench_channels.go72 } else if frameType == nsq.FrameTypeResponse {
/dports/net/nsq/nsq-1.2.1/bench/bench_reader/
H A Dbench_reader.go110 } else if frameType == nsq.FrameTypeResponse {
/dports/net/nsq/nsq-1.2.1/nsqd/
H A Dprotocol_v2_test.go97 readValidate(t, conn, nsq.FrameTypeResponse, expectSuccess)