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 D | mock_test.go | 225 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 D | conn.go | 410 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 D | protocol.go | 19 FrameTypeResponse int32 = 0 const
|
H A D | producer.go | 319 w.popTransaction(FrameTypeResponse, data)
|
H A D | producer_test.go | 330 m.delegate.OnResponse(nil, framedResponse(FrameTypeResponse, []byte("OK")))
|
/dports/net/nsq/nsq-1.2.1/bench/bench_channels/ |
H A D | bench_channels.go | 72 } else if frameType == nsq.FrameTypeResponse {
|
/dports/net/nsq/nsq-1.2.1/bench/bench_reader/ |
H A D | bench_reader.go | 110 } else if frameType == nsq.FrameTypeResponse {
|
/dports/net/nsq/nsq-1.2.1/nsqd/ |
H A D | protocol_v2_test.go | 97 readValidate(t, conn, nsq.FrameTypeResponse, expectSuccess)
|