utils

Documentation

Index

• func AssertPanics(t *testing.T, name string, f func())
• func NormalizeDuration(d time.Duration) string
• func UnsafeToBytes(s string) []byte
• func UnsafeToString(b []byte) string
• type Copool
  • func NewCopool(cap uint) *Copool
  • func (cp *Copool) CtxGo(ctx *context.Context, f func())
  • func (cp *Copool) Go(f func())
  • func (cp *Copool) SetPanicHandler(f func(*context.Context, interface{})) *Copool
• type ObjectPool
  • func NewObjectPool[T any](creator func() T) *ObjectPool[T]
  • func (p *ObjectPool[T]) Get() T
  • func (p *ObjectPool[T]) Put(x T)
• type PprofUtils
  • func NewPprofUtils(profile ProfileType, output string) *PprofUtils
  • func (p *PprofUtils) StartProfile()
  • func (p *PprofUtils) StopProfile()
• type ProfileType
• type Queue
  • func NewQueue[V any](threadSafe bool) *Queue[V]
  • func (q *Queue[V]) Get(i int) V
  • func (q *Queue[V]) Len() int
  • func (q *Queue[V]) Pop() V
  • func (q *Queue[V]) Put(elem V)
  • func (q *Queue[V]) Top() V
  • func (q *Queue[V]) TryPop() (V, bool)

Functions

func AssertPanics

func AssertPanics(t *testing.T, name string, f func())

func NormalizeDuration

func NormalizeDuration(d time.Duration) string

NormalizeDuration normalize duration

func UnsafeToBytes

func UnsafeToBytes(s string) []byte

func UnsafeToString

func UnsafeToString(b []byte) string

Types

type Copool

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

func NewCopool

func NewCopool(cap uint) *Copool

NewCopool return a goroutine pool with specified cap

func (*Copool) CtxGo

func (cp *Copool) CtxGo(ctx *context.Context, f func())

CtxGo executes f and accepts the context.

func (*Copool) Go

func (cp *Copool) Go(f func())

Go executes f.

func (*Copool) SetPanicHandler

func (cp *Copool) SetPanicHandler(f func(*context.Context, interface{})) *Copool

SetPanicHandler sets the panic handler.

type ObjectPool

type ObjectPool[T any] struct {
	// contains filtered or unexported fields
}

ObjectPool with Type

func NewObjectPool

func NewObjectPool[T any](creator func() T) *ObjectPool[T]

func (*ObjectPool[T]) Get

func (p *ObjectPool[T]) Get() T

func (*ObjectPool[T]) Put

func (p *ObjectPool[T]) Put(x T)

type PprofUtils

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

func NewPprofUtils

func NewPprofUtils(profile ProfileType, output string) *PprofUtils

func (*PprofUtils) StartProfile

func (p *PprofUtils) StartProfile()

func (*PprofUtils) StopProfile

func (p *PprofUtils) StopProfile()

type ProfileType

type ProfileType int

const (
	CPU ProfileType = iota
	HEAP
)

type Queue

type Queue[V any] struct {
	// contains filtered or unexported fields
}

Queue represents a single instance of the queue data structure.

func NewQueue

func NewQueue[V any](threadSafe bool) *Queue[V]

New constructs and returns a new Queue.

func (*Queue[V]) Get

func (q *Queue[V]) Get(i int) V

Get returns the element at index i in the queue. If the index is invalid, the call will panic. This method accepts both positive and negative index values. Index 0 refers to the first element, and index -1 refers to the last.

func (*Queue[V]) Len

func (q *Queue[V]) Len() int

Length returns the number of elements currently stored in the queue.

func (*Queue[V]) Pop

func (q *Queue[V]) Pop() V

Remove removes and returns the element from the front of the queue. If the queue is empty, the call will panic.

func (*Queue[V]) Put

func (q *Queue[V]) Put(elem V)

Add puts an element on the end of the queue.

func (*Queue[V]) Top

func (q *Queue[V]) Top() V

Top returns the element at the head of the queue. This call panics if the queue is empty.

func (*Queue[V]) TryPop

func (q *Queue[V]) TryPop() (V, bool)

Remove removes and returns the element from the front of the queue. If the queue is empty, the call will panic.