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

Method newPageRef

protocol/buffer.go:600–608  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

598}
599
600func (a *pageRefAllocator) newPageRef() *pageRef {
601 if a.head == len(a.refs) {
602 a.refs = make([]pageRef, a.size)
603 a.head = 0
604 }
605 ref := &a.refs[a.head]
606 a.head++
607 return ref
608}
609
610func seek(cursor, limit, offset int64, whence int) (int64, error) {
611 switch whence {

Callers 1

readFromVersion2Method · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected