mirror of
https://gitee.com/johng/gf
synced 2026-06-07 02:12:11 +08:00
49 lines
1.5 KiB
Go
49 lines
1.5 KiB
Go
package sarama
|
|
|
|
import "testing"
|
|
|
|
var (
|
|
fetchRequestNoBlocks = []byte{
|
|
0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00}
|
|
|
|
fetchRequestWithProperties = []byte{
|
|
0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x20, 0x00, 0x00, 0x00, 0xEF,
|
|
0x00, 0x00, 0x00, 0x00}
|
|
|
|
fetchRequestOneBlock = []byte{
|
|
0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x01,
|
|
0x00, 0x05, 't', 'o', 'p', 'i', 'c',
|
|
0x00, 0x00, 0x00, 0x01,
|
|
0x00, 0x00, 0x00, 0x12, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x34, 0x00, 0x00, 0x00, 0x56}
|
|
|
|
fetchRequestOneBlockV4 = []byte{
|
|
0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0xFF,
|
|
0x01,
|
|
0x00, 0x00, 0x00, 0x01,
|
|
0x00, 0x05, 't', 'o', 'p', 'i', 'c',
|
|
0x00, 0x00, 0x00, 0x01,
|
|
0x00, 0x00, 0x00, 0x12, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x34, 0x00, 0x00, 0x00, 0x56}
|
|
)
|
|
|
|
func TestFetchRequest(t *testing.T) {
|
|
request := new(FetchRequest)
|
|
testRequest(t, "no blocks", request, fetchRequestNoBlocks)
|
|
|
|
request.MaxWaitTime = 0x20
|
|
request.MinBytes = 0xEF
|
|
testRequest(t, "with properties", request, fetchRequestWithProperties)
|
|
|
|
request.MaxWaitTime = 0
|
|
request.MinBytes = 0
|
|
request.AddBlock("topic", 0x12, 0x34, 0x56)
|
|
testRequest(t, "one block", request, fetchRequestOneBlock)
|
|
|
|
request.Version = 4
|
|
request.MaxBytes = 0xFF
|
|
request.Isolation = ReadCommitted
|
|
testRequest(t, "one block v4", request, fetchRequestOneBlockV4)
|
|
}
|