MCPcopy
hub / github.com/segmentio/kafka-go / testConnFirstOffset

Function testConnFirstOffset

conn_test.go:370–376  ·  view source on GitHub ↗
(t *testing.T, conn *Conn)

Source from the content-addressed store, hash-verified

368}
369
370func testConnFirstOffset(t *testing.T, conn *Conn) {
371 offset, whence := conn.Offset()
372
373 if offset != 0 && whence != 0 {
374 t.Error("bad first offset:", offset, whence)
375 }
376}
377
378func testConnWrite(t *testing.T, conn *Conn) {
379 b := []byte("Hello World!")

Callers

nothing calls this directly

Calls 2

OffsetMethod · 0.45
ErrorMethod · 0.45

Tested by

no test coverage detected