pools

Documentation

Index

• Constants
• Variables
• func AcquireStringsBuilder() *strings.Builder
• func AcquireTimer(timeout time.Duration) *time.Timer
• func AcquireWaitGroup() *sync.WaitGroup
• func Go(f func())
• func NewByteBuffer(min, max int) *byteBufferPool
• func NewByteSlice(min, max int) *byteSlicePool
• func ReleaseStringsBuilder(sb *strings.Builder)
• func ReleaseTimer(t *time.Timer)
• func ReleaseWaitGroup(wg *sync.WaitGroup)
• func ResetTimer(t *time.Timer, period time.Duration)
• type ByteBuffer
  • func (bb *ByteBuffer) AppendFrom(data []byte)
  • func (bb *ByteBuffer) AppendTo(data []byte) []byte
  • func (bb *ByteBuffer) Bytes() *[]byte
  • func (bb ByteBuffer) Cap() int
  • func (bb *ByteBuffer) CopyFrom(data []byte)
  • func (bb *ByteBuffer) CopyFromWithOffset(data []byte, offset int)
  • func (bb *ByteBuffer) CopyTo(data []byte) []byte
  • func (bb *ByteBuffer) Fill(data []byte, start, end int)
  • func (bb *ByteBuffer) Len() int
  • func (bb *ByteBuffer) Read(p []byte) (n int, err error)
  • func (bb *ByteBuffer) Reset()
  • func (bb *ByteBuffer) SetBytes(b *[]byte)
• type QueryPool
  • func NewQueryPool(genFunc queryBuilderFunc) *QueryPool
  • func (qp *QueryPool) GetQuery() *gocqlx.Queryx
  • func (qp *QueryPool) Put(q *gocqlx.Queryx)

Constants

const Imported = true

Variables

var Buffer = NewByteBuffer(4, 64<<10)

var Bytes = NewByteSlice(32, 64<<10)

var TinyBytes = NewByteSlice(4, 128)

Functions

func AcquireStringsBuilder

func AcquireStringsBuilder() *strings.Builder

func AcquireTimer

func AcquireTimer(timeout time.Duration) *time.Timer

func AcquireWaitGroup

func AcquireWaitGroup() *sync.WaitGroup

func Go

func Go(f func())

func NewByteBuffer

func NewByteBuffer(min, max int) *byteBufferPool

NewByteBuffer creates new byteBufferPool that reuses objects which size is in logarithmic range [min, max].

Note that it is a shortcut for Custom() constructor with Options provided by WithLogSizeMapping() and WithLogSizeRange(min, max) calls.

func NewByteSlice

func NewByteSlice(min, max int) *byteSlicePool

NewByteSlice creates new byteSlicePool that reuses objects which size is in logarithmic range [min, max].

Note that it is a shortcut for Custom() constructor with Options provided by WithLogSizeMapping() and WithLogSizeRange(min, max) calls.

func ReleaseStringsBuilder

func ReleaseStringsBuilder(sb *strings.Builder)

func ReleaseTimer

func ReleaseTimer(t *time.Timer)

func ReleaseWaitGroup

func ReleaseWaitGroup(wg *sync.WaitGroup)

func ResetTimer

func ResetTimer(t *time.Timer, period time.Duration)

Types

type ByteBuffer

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

func (*ByteBuffer) AppendFrom

func (bb *ByteBuffer) AppendFrom(data []byte)

func (*ByteBuffer) AppendTo

func (bb *ByteBuffer) AppendTo(data []byte) []byte

func (*ByteBuffer) Bytes

func (bb *ByteBuffer) Bytes() *[]byte

func (ByteBuffer) Cap

func (bb ByteBuffer) Cap() int

func (*ByteBuffer) CopyFrom

func (bb *ByteBuffer) CopyFrom(data []byte)

func (*ByteBuffer) CopyFromWithOffset

func (bb *ByteBuffer) CopyFromWithOffset(data []byte, offset int)

func (*ByteBuffer) CopyTo

func (bb *ByteBuffer) CopyTo(data []byte) []byte

func (*ByteBuffer) Fill

func (bb *ByteBuffer) Fill(data []byte, start, end int)

func (*ByteBuffer) Len

func (bb *ByteBuffer) Len() int

func (*ByteBuffer) Read

func (bb *ByteBuffer) Read(p []byte) (n int, err error)

func (*ByteBuffer) Reset

func (bb *ByteBuffer) Reset()

func (*ByteBuffer) SetBytes

func (bb *ByteBuffer) SetBytes(b *[]byte)

type QueryPool

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

func NewQueryPool

func NewQueryPool(genFunc queryBuilderFunc) *QueryPool

NewQueryPool creates a new query pool

func (*QueryPool) GetQuery

func (qp *QueryPool) GetQuery() *gocqlx.Queryx

func (*QueryPool) Put

func (qp *QueryPool) Put(q *gocqlx.Queryx)