utils

Documentation

Index

• Variables
• func AbsInt64(n int64) int64
• func CPUPercent(p *process.Process) float64
• func ExtractRedisInfo(info string, key string) (string, string)
• func MemoryInfo(p *process.Process) *process.MemoryInfoStat
• func Merge(cs ...<-chan error) <-chan error
• func NewProcess() (*process.Process, error)
• func NewRedisClient(conf *viper.Viper) (*redis.Client, error)
• func Reverse(s string) string
• func SinceMS(t time.Time) float64
• func Text(obj interface{}) string
• type BulkLock
  • func NewBulkLock(size int) *BulkLock
  • func (lock *BulkLock) Lock(i uint64)
  • func (lock *BulkLock) RLock(i uint64)
  • func (lock *BulkLock) RUnlock(i uint64)
  • func (lock *BulkLock) Unlock(i uint64)
• type ParsedRedisInfo
  • func ParseRedisInfo(info string) ParsedRedisInfo
• type ParsedURL
  • func NewParsedURL(rawURL string) (parsedURL *ParsedURL, err error)
• type ScanProcessFunc
• type Scanner
  • func NewScanner(client *redis.Client, scanType string, key string, match string, count int64) *Scanner
  • func (scanner *Scanner) Scan(f ScanProcessFunc) (err error)

Variables

var DefaultSchemePort = map[string]string{
	"http":  "80",
	"https": "443",
	"ftp":   "21",
	"ssh":   "22",
}

DefaultSchemePort TODO

Functions

func AbsInt64

func AbsInt64(n int64) int64

AbsInt64 TODO

func CPUPercent

func CPUPercent(p *process.Process) float64

CPUPercent TODO

func ExtractRedisInfo

func ExtractRedisInfo(info string, key string) (string, string)

ExtractRedisInfo TODO

func MemoryInfo

func MemoryInfo(p *process.Process) *process.MemoryInfoStat

MemoryInfo TODO

func Merge

func Merge(cs ...<-chan error) <-chan error

Merge TODO

func NewProcess

func NewProcess() (*process.Process, error)

NewProcess TODO

func NewRedisClient

func NewRedisClient(conf *viper.Viper) (*redis.Client, error)

NewRedisClient create redis client and connect

func Reverse

func Reverse(s string) string

Reverse TODO

func SinceMS

func SinceMS(t time.Time) float64

SinceMS TODO

func Text

func Text(obj interface{}) string

Text TODO

Types

type BulkLock

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

BulkLock TODO

func NewBulkLock

func NewBulkLock(size int) *BulkLock

NewBulkLock TODO

func (*BulkLock) Lock

func (lock *BulkLock) Lock(i uint64)

Lock TODO

func (*BulkLock) RLock

func (lock *BulkLock) RLock(i uint64)

RLock TODO

func (*BulkLock) RUnlock

func (lock *BulkLock) RUnlock(i uint64)

RUnlock TODO

func (*BulkLock) Unlock

func (lock *BulkLock) Unlock(i uint64)

Unlock TODO

type ParsedRedisInfo

type ParsedRedisInfo map[string]map[string]string

ParsedRedisInfo TODO

func ParseRedisInfo

func ParseRedisInfo(info string) ParsedRedisInfo

ParseRedisInfo TODO

type ParsedURL

type ParsedURL struct {
	Parsed *url.URL
	Host   string
	Port   string
}

ParsedURL TODO

func NewParsedURL

func NewParsedURL(rawURL string) (parsedURL *ParsedURL, err error)

NewParsedURL TODO

type ScanProcessFunc

type ScanProcessFunc func(keys []string) error

ScanProcessFunc TODO

type Scanner

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

Scanner TODO

func NewScanner

func NewScanner(client *redis.Client, scanType string, key string, match string, count int64) *Scanner

NewScanner TODO

func (*Scanner) Scan

func (scanner *Scanner) Scan(f ScanProcessFunc) (err error)

Scan TODO