utils

package

v0.0.0-...-f62d9cd Latest Latest Go to latest Published: Aug 12, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/fanghongbo/ops-transfer

Documentation ¶

Index ¶

func CalculateMemLimit(maxMemRate float64) int
func GetCPULimitNum(maxCPURate float64) int
func GetMetricPrimaryKey(endpoint, metric string, tags map[string]string) string
func Md5(raw string) string
func ReformatMetricUniqueString(endpoint, metric string, tags map[string]string, dsType string, step int) string
func ReformatTag(str string) map[string]string
func SortedTags(tags map[string]string) string
func UnixTsFormat(ts int64) string
type List
- func NewSafeList() *List
- func (u *List) BackAll() []interface{}
- func (u *List) Front() interface{}
- func (u *List) FrontAll() []interface{}
- func (u *List) Len() int
- func (u *List) PopBack() interface{}
- func (u *List) PopBackAll() []interface{}
- func (u *List) PopBackBy(max int) []interface{}
- func (u *List) PushFront(v interface{}) *list.Element
- func (u *List) PushFrontBatch(vs []interface{})
- func (u *List) Remove(e *list.Element) interface{}
- func (u *List) RemoveAll()
type ListLimited
- func NewSafeListLimited(maxSize int) *ListLimited
- func (u *ListLimited) Front() interface{}
- func (u *ListLimited) FrontAll() []interface{}
- func (u *ListLimited) Len() int
- func (u *ListLimited) PopBack() interface{}
- func (u *ListLimited) PopBackBy(max int) []interface{}
- func (u *ListLimited) PushFront(v interface{}) bool
- func (u *ListLimited) PushFrontBatch(vs []interface{}) bool
- func (u *ListLimited) PushFrontViolently(v interface{}) bool
- func (u *ListLimited) RemoveAll()
type SafeSet
- func NewSafeSet() *SafeSet
- func (u *SafeSet) Add(key string)
- func (u *SafeSet) Clear()
- func (u *SafeSet) Contains(key string) bool
- func (u *SafeSet) Remove(key string)
- func (u *SafeSet) Size() int
- func (u *SafeSet) ToSlice() []string
type Semaphore
- func NewSemaphore(concurrencyNum int) *Semaphore
- func (u *Semaphore) Acquire()
- func (u *Semaphore) AvailablePermits() int
- func (u *Semaphore) Release()
- func (u *Semaphore) TryAcquire() bool
type StringSet
- func NewStringSet() *StringSet
- func (u *StringSet) Add(elt string) *StringSet
- func (u *StringSet) Clear()
- func (u *StringSet) Delete(elt string)
- func (u *StringSet) Exists(elt string) bool
- func (u *StringSet) ToSlice() []string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CalculateMemLimit ¶

func CalculateMemLimit(maxMemRate float64) int

func GetCPULimitNum ¶

func GetCPULimitNum(maxCPURate float64) int

func GetMetricPrimaryKey ¶

func GetMetricPrimaryKey(endpoint, metric string, tags map[string]string) string

func Md5 ¶

func Md5(raw string) string

func ReformatMetricUniqueString ¶

func ReformatMetricUniqueString(endpoint, metric string, tags map[string]string, dsType string, step int) string

func ReformatTag ¶

func ReformatTag(str string) map[string]string

func SortedTags ¶

func SortedTags(tags map[string]string) string

func UnixTsFormat ¶

func UnixTsFormat(ts int64) string

Types ¶

type List ¶

type List struct {
	sync.RWMutex
	L *list.List
}

func NewSafeList ¶

func NewSafeList() *List

func (*List) BackAll ¶

func (u *List) BackAll() []interface{}

func (*List) Front ¶

func (u *List) Front() interface{}

func (*List) FrontAll ¶

func (u *List) FrontAll() []interface{}

func (*List) Len ¶

func (u *List) Len() int

func (*List) PopBack ¶

func (u *List) PopBack() interface{}

func (*List) PopBackAll ¶

func (u *List) PopBackAll() []interface{}

func (*List) PopBackBy ¶

func (u *List) PopBackBy(max int) []interface{}

func (*List) PushFront ¶

func (u *List) PushFront(v interface{}) *list.Element

func (*List) PushFrontBatch ¶

func (u *List) PushFrontBatch(vs []interface{})

func (*List) Remove ¶

func (u *List) Remove(e *list.Element) interface{}

func (*List) RemoveAll ¶

func (u *List) RemoveAll()

type ListLimited ¶

type ListLimited struct {
	SL *List
	// contains filtered or unexported fields
}

SafeList with Limited Size

func NewSafeListLimited ¶

func NewSafeListLimited(maxSize int) *ListLimited

func (*ListLimited) Front ¶

func (u *ListLimited) Front() interface{}

func (*ListLimited) FrontAll ¶

func (u *ListLimited) FrontAll() []interface{}

func (*ListLimited) Len ¶

func (u *ListLimited) Len() int

func (*ListLimited) PopBack ¶

func (u *ListLimited) PopBack() interface{}

func (*ListLimited) PopBackBy ¶

func (u *ListLimited) PopBackBy(max int) []interface{}

func (*ListLimited) PushFront ¶

func (u *ListLimited) PushFront(v interface{}) bool

func (*ListLimited) PushFrontBatch ¶

func (u *ListLimited) PushFrontBatch(vs []interface{}) bool

func (*ListLimited) PushFrontViolently ¶

func (u *ListLimited) PushFrontViolently(v interface{}) bool

func (*ListLimited) RemoveAll ¶

func (u *ListLimited) RemoveAll()

type SafeSet ¶

type SafeSet struct {
	sync.RWMutex
	M map[string]bool
}

func NewSafeSet ¶

func NewSafeSet() *SafeSet

func (*SafeSet) Add ¶

func (u *SafeSet) Add(key string)

func (*SafeSet) Clear ¶

func (u *SafeSet) Clear()

func (*SafeSet) Contains ¶

func (u *SafeSet) Contains(key string) bool

func (*SafeSet) Remove ¶

func (u *SafeSet) Remove(key string)

func (*SafeSet) Size ¶

func (u *SafeSet) Size() int

func (*SafeSet) ToSlice ¶

func (u *SafeSet) ToSlice() []string

type Semaphore ¶

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

func NewSemaphore ¶

func NewSemaphore(concurrencyNum int) *Semaphore

func (*Semaphore) Acquire ¶

func (u *Semaphore) Acquire()

func (*Semaphore) AvailablePermits ¶

func (u *Semaphore) AvailablePermits() int

func (*Semaphore) Release ¶

func (u *Semaphore) Release()

func (*Semaphore) TryAcquire ¶

func (u *Semaphore) TryAcquire() bool

type StringSet ¶

type StringSet struct {
	M map[string]struct{}
}

func NewStringSet ¶

func NewStringSet() *StringSet

func (*StringSet) Add ¶

func (u *StringSet) Add(elt string) *StringSet

func (*StringSet) Clear ¶

func (u *StringSet) Clear()

func (*StringSet) Delete ¶

func (u *StringSet) Delete(elt string)

func (*StringSet) Exists ¶

func (u *StringSet) Exists(elt string) bool

func (*StringSet) ToSlice ¶

func (u *StringSet) ToSlice() []string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL