pool

Documentation

Index

• Variables
• func CopyPublish(dest *packets.Publish, src *packets.Publish)
• type Byte
  • func NewByte() *Byte
  • func (p *Byte) Get() []byte
  • func (p *Byte) Put(b []byte)
• type ByteBuffer
  • func NewByteBufferPool() *ByteBuffer
  • func (p *ByteBuffer) Get() *bytes.Buffer
  • func (p *ByteBuffer) Put(b *bytes.Buffer)
• type Publish
  • func NewPublish() *Publish
  • func (p *Publish) Get() *packets.Publish
  • func (p *Publish) Put(b *packets.Publish)

Variables

var (
	BytePool       = NewByte()
	ByteBufferPool = NewByteBufferPool()
)

var (
	PublishPool = NewPublish()
)

Functions

func CopyPublish

func CopyPublish(dest *packets.Publish, src *packets.Publish)

Types

type Byte

type Byte struct {
	sync.Pool
}

func NewByte

func NewByte() *Byte

func (*Byte) Get

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

func (*Byte) Put

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

type ByteBuffer

type ByteBuffer struct {
	sync.Pool
}

func NewByteBufferPool

func NewByteBufferPool() *ByteBuffer

func (*ByteBuffer) Get

func (p *ByteBuffer) Get() *bytes.Buffer

func (*ByteBuffer) Put

func (p *ByteBuffer) Put(b *bytes.Buffer)

type Publish

type Publish struct {
	sync.Pool
}

func NewPublish

func NewPublish() *Publish

func (*Publish) Get

func (p *Publish) Get() *packets.Publish

func (*Publish) Put

func (p *Publish) Put(b *packets.Publish)