utils

Documentation

Index

• func CheckDNS(domain string) error
• func CheckNetwork(host, port string, timeout time.Duration) error
• func GatherCallFrames() string
• func GetEncodedToken(username string, password string) string
• func ResolvePort(port string, schema string) (string, error)
• type WorkerScheduler
  • func NewWorkerScheduler(workerNum int, maxWorkEverySeconds int, ctx context.Context) (*WorkerScheduler, error)
  • func (s *WorkerScheduler) Release()
  • func (s *WorkerScheduler) Submit(task func() error) error
  • func (s *WorkerScheduler) WaitUntilFinish()

Functions

func CheckDNS

func CheckDNS(domain string) error

func CheckNetwork

func CheckNetwork(host, port string, timeout time.Duration) error

func GatherCallFrames

func GatherCallFrames() string

func GetEncodedToken

func GetEncodedToken(username string, password string) string

func ResolvePort

func ResolvePort(port string, schema string) (string, error)

Types

type WorkerScheduler

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

func NewWorkerScheduler

func NewWorkerScheduler(workerNum int, maxWorkEverySeconds int, ctx context.Context) (*WorkerScheduler, error)

NewWorkerScheduler 创建一个并行执行的调度器，控制最大运行数和每秒最大运行数量 NewWorkerScheduler Create a parallel scheduler to control the maximum number of runs and the maximum number of runs per second 注意: task执行是无序的 Warning: task execution is out of order

func (*WorkerScheduler) Release

func (s *WorkerScheduler) Release()

func (*WorkerScheduler) Submit

func (s *WorkerScheduler) Submit(task func() error) error

func (*WorkerScheduler) WaitUntilFinish

func (s *WorkerScheduler) WaitUntilFinish()