util

Documentation

Index

• Constants
• func AllocSlice[T allocItem](data []T, size int) ([]T, []T)
• func BooleanSlice2byte(b []bool) []byte
• func Bytes2BooleanSlice(b []byte) []bool
• func Bytes2Float32Slice(b []byte) []float32
• func Bytes2Float64Slice(b []byte) []float64
• func Bytes2Int16Slice(b []byte) []int16
• func Bytes2Int32Slice(b []byte) []int32
• func Bytes2Int64Slice(b []byte) []int64
• func Bytes2Int8Slice(b []byte) []int8
• func Bytes2Uint16Slice(b []byte) []uint16
• func Bytes2Uint32Slice(b []byte) []uint32
• func Bytes2Uint64Slice(b []byte) []uint64
• func Bytes2str(b []byte) string
• func CeilToPower2(num uint64) uint64
• func Float32Slice2byte(b []float32) []byte
• func Float64Slice2byte(b []float64) []byte
• func Float64ToUint64(v float64) uint64
• func HttpError(w http.ResponseWriter, errmsg string, code int)
• func Include(slice []uint64, s uint64) bool
• func IndexOf(slice []uint64, s uint64) int
• func Int16Slice2byte(b []int16) []byte
• func Int32Slice2byte(b []int32) []byte
• func Int64Slice2byte(b []int64) []byte
• func IntLimit(min, max int, v int) int
• func IsObjectNil(obj interface{}) bool
• func MaxUint32(x, y uint32) uint32
• func MemorySet(buf []byte)
• func Min(x, y int) int
• func MinUint32(x, y uint32) uint32
• func MustClose(obj io.Closer)
• func NumberOfTrailingZeros(num uint64) int
• func Search(begin, n int, f func(int) bool) int
• func SetLogger(lg *zap.Logger)
• func Str2bytes(s string) []byte
• func TimeCost(option string) func()
• func Uint16Slice2byte(b []uint16) []byte
• func Uint32Slice2byte(b []uint32) []byte
• func Uint64Slice2byte(b []uint64) []byte
• func Uint64ToFloat64(v uint64) float64
• type Corrector
  • func NewCorrector(intMin int64, floatMin float64) *Corrector
  • func (c *Corrector) Float64(v *float64, def float64)
  • func (c *Corrector) Int(v *int, def int)
  • func (c *Corrector) String(v *string, def string)
  • func (c *Corrector) TomlDuration(v *toml.Duration, def toml.Duration)
  • func (c *Corrector) TomlSize(v *toml.Size, def toml.Size)
  • func (c *Corrector) Uint64(v *uint64, def uint64)
• type Signal
  • func NewSignal() *Signal
  • func (s *Signal) C() chan struct{}
  • func (s *Signal) Close()
  • func (s *Signal) Opening() bool
  • func (s *Signal) ReOpen()
• type TimeRange
  • func (t TimeRange) Overlaps(min, max int64) bool
• type TimerPool
  • func NewTimePool() *TimerPool
  • func (p *TimerPool) GetTimer(timeout time.Duration) *time.Timer
  • func (p *TimerPool) PutTimer(timer *time.Timer)

Constants

const (
	TierBegin = 0
	Hot       = 1
	Warm      = 2
	Cold      = 3
	Moving    = 4
	TierEnd   = 5
)

const (
	BooleanSizeBytes = int(unsafe.Sizeof(false))
	Uint32SizeBytes  = int(unsafe.Sizeof(uint32(0)))
	Uint16SizeBytes  = int(unsafe.Sizeof(uint16(0)))
	Uint64SizeBytes  = int(unsafe.Sizeof(uint64(0)))
	Int16SizeBytes   = int(unsafe.Sizeof(int16(0)))
	Int32SizeBytes   = int(unsafe.Sizeof(int32(0)))
	Int64SizeBytes   = int(unsafe.Sizeof(int64(0)))
	Float32SizeBytes = int(unsafe.Sizeof(float32(0)))
	Float64SizeBytes = int(unsafe.Sizeof(float64(0)))
	Int8SizeBytes    = int(unsafe.Sizeof(int8(0)))
)

const MaxMeasurementLength = MaxMeasurementLengthWithVersion - MeasurementVersionLength

the measurement name length should consider MeasurementVersionLength

const MaxMeasurementLengthWithVersion = 255

const MeasurementVersionLength = 5

eg, version is:_0000

const RowsNumPerFragment int = 8192

Functions

func AllocSlice

func AllocSlice[T allocItem](data []T, size int) ([]T, []T)

func BooleanSlice2byte

func BooleanSlice2byte(b []bool) []byte

func Bytes2BooleanSlice

func Bytes2BooleanSlice(b []byte) []bool

func Bytes2Float32Slice

func Bytes2Float32Slice(b []byte) []float32

func Bytes2Float64Slice

func Bytes2Float64Slice(b []byte) []float64

func Bytes2Int16Slice

func Bytes2Int16Slice(b []byte) []int16

func Bytes2Int32Slice

func Bytes2Int32Slice(b []byte) []int32

func Bytes2Int64Slice

func Bytes2Int64Slice(b []byte) []int64

func Bytes2Int8Slice

func Bytes2Int8Slice(b []byte) []int8

func Bytes2Uint16Slice

func Bytes2Uint16Slice(b []byte) []uint16

func Bytes2Uint32Slice

func Bytes2Uint32Slice(b []byte) []uint32

func Bytes2Uint64Slice

func Bytes2Uint64Slice(b []byte) []uint64

func Bytes2str

func Bytes2str(b []byte) string

func CeilToPower2

func CeilToPower2(num uint64) uint64

func Float32Slice2byte

func Float32Slice2byte(b []float32) []byte

func Float64Slice2byte

func Float64Slice2byte(b []float64) []byte

func Float64ToUint64

func Float64ToUint64(v float64) uint64

func HttpError

func HttpError(w http.ResponseWriter, errmsg string, code int)

httpError writes an error to the client in a standard format.

func Include

func Include(slice []uint64, s uint64) bool

Include returns true or false if given array is in slice.

func IndexOf

func IndexOf(slice []uint64, s uint64) int

IndexOf returns index position in slice from given array If value is -1, the string does not found.

func Int16Slice2byte

func Int16Slice2byte(b []int16) []byte

func Int32Slice2byte

func Int32Slice2byte(b []int32) []byte

func Int64Slice2byte

func Int64Slice2byte(b []int64) []byte

func IntLimit

func IntLimit(min, max int, v int) int

func IsObjectNil

func IsObjectNil(obj interface{}) bool

func MaxUint32

func MaxUint32(x, y uint32) uint32

func MemorySet

func MemorySet(buf []byte)

func Min

func Min(x, y int) int

func MinUint32

func MinUint32(x, y uint32) uint32

func MustClose

func MustClose(obj io.Closer)

func NumberOfTrailingZeros

func NumberOfTrailingZeros(num uint64) int

func Search

func Search(begin, n int, f func(int) bool) int

func SetLogger

func SetLogger(lg *zap.Logger)

func Str2bytes

func Str2bytes(s string) []byte

func TimeCost

func TimeCost(option string) func()

func Uint16Slice2byte

func Uint16Slice2byte(b []uint16) []byte

func Uint32Slice2byte

func Uint32Slice2byte(b []uint32) []byte

func Uint64Slice2byte

func Uint64Slice2byte(b []uint64) []byte

func Uint64ToFloat64

func Uint64ToFloat64(v uint64) float64

Types

type Corrector

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

func NewCorrector

func NewCorrector(intMin int64, floatMin float64) *Corrector

func (*Corrector) Float64

func (c *Corrector) Float64(v *float64, def float64)

func (*Corrector) Int

func (c *Corrector) Int(v *int, def int)

func (*Corrector) String

func (c *Corrector) String(v *string, def string)

func (*Corrector) TomlDuration

func (c *Corrector) TomlDuration(v *toml.Duration, def toml.Duration)

func (*Corrector) TomlSize

func (c *Corrector) TomlSize(v *toml.Size, def toml.Size)

func (*Corrector) Uint64

func (c *Corrector) Uint64(v *uint64, def uint64)

type Signal

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

func NewSignal

func NewSignal() *Signal

func (*Signal) C

func (s *Signal) C() chan struct{}

func (*Signal) Close

func (s *Signal) Close()

func (*Signal) Opening

func (s *Signal) Opening() bool

func (*Signal) ReOpen

func (s *Signal) ReOpen()

type TimeRange

type TimeRange struct {
	Min, Max int64
}

func (TimeRange) Overlaps

func (t TimeRange) Overlaps(min, max int64) bool

type TimerPool

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

func NewTimePool

func NewTimePool() *TimerPool

func (*TimerPool) GetTimer

func (p *TimerPool) GetTimer(timeout time.Duration) *time.Timer

func (*TimerPool) PutTimer

func (p *TimerPool) PutTimer(timer *time.Timer)