bufferpool

package

v1.5.3-rc4 Latest Latest Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 3 Imported by: 1

Details

View Source

const (
	MaxLocalCacheLen             = 8
	MaxChunkMetaBufLocalCacheLen = 1024
	MaxLocalCacheSize            = 32 * 1024 * 1024 // 32M
)

View Source

var RaftMsgPool = NewByteBufferPool(0, cpu.GetCpuNum(), cpu.GetCpuNum())

func Get() []byte

func GetPoints() []byte

func GetRaftMsg() []byte

func GetSmartQuery() []byte

func Put(b []byte)

func PutPoints(b []byte)

func PutRaftMsg(b []byte)

func PutSmartQuery(b []byte)

func Resize(b []byte, n int) []byte

type Pool struct {
	// contains filtered or unexported fields
}

func NewByteBufferPool(defaultSize uint64, localCacheNum int, maxCacheLen int) *Pool

func (p *Pool) Get() []byte

func (p *Pool) Put(b []byte)