utils

Documentation

Index

• func Contains(slice []string, item string) bool
• func GetExecutablePath() string
• func GetVersion() (string, error)
• func NewHTTPClient() *http.Client
• func UpdateSubs()
• type Task
• type ThreadPool
  • func NewThreadPool(numWorkers int, taskFunc func(interface{}) (interface{}, error)) *ThreadPool
  • func (tp *ThreadPool) AddTaskArgs(argsList []interface{})
  • func (tp *ThreadPool) GetResults() []Task
  • func (tp *ThreadPool) Start()
  • func (tp *ThreadPool) Wait()

Functions

func Contains

func Contains(slice []string, item string) bool

func GetExecutablePath

func GetExecutablePath() string

func GetVersion

func GetVersion() (string, error)

func NewHTTPClient

func NewHTTPClient() *http.Client

func UpdateSubs

func UpdateSubs()

Types

type Task

type Task struct {
	ID     int
	Args   interface{}
	Result interface{}
	Err    error
}

type ThreadPool

type ThreadPool struct {
	NumWorkers int
	Tasks      chan Task
	Results    chan Task
	Wg         sync.WaitGroup
	TaskFunc   func(interface{}) (interface{}, error)
	// contains filtered or unexported fields
}

func NewThreadPool

func NewThreadPool(numWorkers int, taskFunc func(interface{}) (interface{}, error)) *ThreadPool

func (*ThreadPool) AddTaskArgs

func (tp *ThreadPool) AddTaskArgs(argsList []interface{})

func (*ThreadPool) GetResults

func (tp *ThreadPool) GetResults() []Task

func (*ThreadPool) Start

func (tp *ThreadPool) Start()

func (*ThreadPool) Wait

func (tp *ThreadPool) Wait()