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

Struct pageRef

protocol/buffer.go:483–490  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

481)
482
483type pageRef struct {
484 buffer [2]*page
485 pages contiguousPages
486 offset int64
487 cursor int64
488 length uint32
489 once uint32
490}
491
492func (ref *pageRef) unref() {
493 if atomic.CompareAndSwapUint32(&ref.once, 0, 1) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected