Method Size

agent/immortalstreams/backedpipe/ring_buffer.go:26–35

Size returns the current number of bytes in the buffer.

()

// Size returns the current number of bytes in the buffer.
func (rb *ringBuffer) Size() int {
	if rb.end == -1 {
		return 0 // Buffer is empty
	}
	if rb.start <= rb.end {
		return rb.end - rb.start + 1
	}
	// Buffer wraps around
	return len(rb.buffer) - rb.start + rb.end + 1
}

// Write writes data to the ring buffer. If the buffer would overflow,
// it evicts the oldest data to make room for new data.