MCPcopy
hub / github.com/IBM/sarama / TestOffsetRequestV1

Function TestOffsetRequestV1

offset_request_test.go:73–80  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

71}
72
73func TestOffsetRequestV1(t *testing.T) {
74 request := new(OffsetRequest)
75 request.Version = 1
76 testRequest(t, "no blocks", request, offsetRequestNoBlocksV1)
77
78 request.AddBlock("bar", 4, 1, 2) // Last argument is ignored for V1
79 testRequest(t, "one block", request, offsetRequestOneBlockV1)
80}
81
82func TestOffsetRequestV2(t *testing.T) {
83 request := new(OffsetRequest)

Callers

nothing calls this directly

Calls 2

testRequestFunction · 0.85
AddBlockMethod · 0.45

Tested by

no test coverage detected