common

Documentation

Index

• Constants
• func AppendPrettyHexDump(dump *strings.Builder, b []byte)
• func CloneBytes(b []byte) []byte
• func CountBorrowed() int64
• func PrettyHexDump(b []byte) string
• func RandAlphabetic(n int) (s string)
• func RandAlphanumeric(n int) (s string)
• func RandFloat64() (v float64)
• func RandIntn(n int) (v int)
• func ReturnByteBuff(b *ByteBuff)
• func SafeCloseDoneChan(c chan<- struct{}) (ok bool)
• func ToMilliseconds(duration time.Duration) int64
• func TryRelease(input interface{})
• type ByteBuff
  • func BorrowByteBuff() *ByteBuff
  • func (b *ByteBuff) Bytes() []byte
  • func (b *ByteBuff) Len() (n int)
  • func (b *ByteBuff) Reset()
  • func (b *ByteBuff) Write(bs []byte) (int, error)
  • func (b *ByteBuff) WriteByte(c byte) error
  • func (b *ByteBuff) WriteString(s string) (err error)
  • func (b *ByteBuff) WriteTo(w io.Writer) (int64, error)
• type Cond
  • func NewCond(l sync.Locker) *Cond
  • func (c *Cond) Broadcast()
  • func (c *Cond) NotifyChan() <-chan struct{}
  • func (c *Cond) Wait(ctx context.Context) (isCtx bool)
• type Releasable

Constants

const (
	// DefaultKeepaliveInterval is default keepalive interval duration.
	DefaultKeepaliveInterval = 20 * time.Second
	// DefaultKeepaliveMaxLifetime is default keepalive max lifetime.
	DefaultKeepaliveMaxLifetime = 90 * time.Second
)

Functions

func AppendPrettyHexDump

func AppendPrettyHexDump(dump *strings.Builder, b []byte)

AppendPrettyHexDump appends bytes to string builder.

func CloneBytes

func CloneBytes(b []byte) []byte

func CountBorrowed

func CountBorrowed() int64

CountBorrowed returns borrowed ByteBuff amount.

func PrettyHexDump

func PrettyHexDump(b []byte) string

PrettyHexDump converts bytes to pretty hex dump string.

func RandAlphabetic

func RandAlphabetic(n int) (s string)

RandAlphabetic returns a string with random alphabets.

func RandAlphanumeric

func RandAlphanumeric(n int) (s string)

RandAlphanumeric returns a string with random alphabets and numbers.

func RandFloat64

func RandFloat64() (v float64)

RandFloat64 returns a random float64.

func RandIntn

func RandIntn(n int) (v int)

RandIntn returns a random int.

func ReturnByteBuff

func ReturnByteBuff(b *ByteBuff)

ReturnByteBuff returns a ByteBuff to pool.

func SafeCloseDoneChan

func SafeCloseDoneChan(c chan<- struct{}) (ok bool)

func ToMilliseconds

func ToMilliseconds(duration time.Duration) int64

func TryRelease

func TryRelease(input interface{})

Types

type ByteBuff

type ByteBuff bytes.Buffer

ByteBuff provides byte buffer, which can be used for minimizing.

func BorrowByteBuff

func BorrowByteBuff() *ByteBuff

BorrowByteBuff borrows a ByteBuff from pool.

func (*ByteBuff) Bytes

func (b *ByteBuff) Bytes() []byte

Bytes returns all bytes in ByteBuff.

func (*ByteBuff) Len

func (b *ByteBuff) Len() (n int)

Len returns size of ByteBuff.

func (*ByteBuff) Reset

func (b *ByteBuff) Reset()

Reset resets ByteBuff.

func (*ByteBuff) Write

func (b *ByteBuff) Write(bs []byte) (int, error)

Write writes bytes to current ByteBuff.

func (*ByteBuff) WriteByte

func (b *ByteBuff) WriteByte(c byte) error

WriteByte writes a byte to current ByteBuff.

func (*ByteBuff) WriteString

func (b *ByteBuff) WriteString(s string) (err error)

WriteString writes a string to current ByteBuff.

func (*ByteBuff) WriteTo

func (b *ByteBuff) WriteTo(w io.Writer) (int64, error)

WriteTo writes bytes to writer.

type Cond

type Cond struct {
	L sync.Locker
	// contains filtered or unexported fields
}

Cond is a customized Cond which support context. See https://gist.github.com/zviadm/c234426882bfc8acba88f3503edaaa36#file-cond2-go

func NewCond

func NewCond(l sync.Locker) *Cond

NewCond creates a new Cond.

func (*Cond) Broadcast

func (c *Cond) Broadcast()

Broadcast broadcast Cond.

func (*Cond) NotifyChan

func (c *Cond) NotifyChan() <-chan struct{}

NotifyChan returns readonly notify chan.

func (*Cond) Wait

func (c *Cond) Wait(ctx context.Context) (isCtx bool)

Wait waits Cond.

type Releasable

type Releasable interface {
	IncRef() int32
	RefCnt() int32
	Release()
}