misc

Documentation

Index

• Constants
• func FindAllGroups(a string, url string) (paramsMap map[string]string)
• func InsertSortFindIndex(s []float64, v float64) int
• type ConcurrencyLimiter
  • func NewConcurrencyLimiter(limit int) *ConcurrencyLimiter
  • func (c *ConcurrencyLimiter) Execute(job func())
  • func (c *ConcurrencyLimiter) ExecuteIndex(index int, job func(numb int))
  • func (c *ConcurrencyLimiter) Loop(n int, job func(o int))
  • func (c *ConcurrencyLimiter) Wait()
• type Timeout
  • func (t *Timeout) Release()
  • func (t *Timeout) Run(seconds int, callback func())

Constants

const (
	// DefaultLimit is the default concurrency limit
	DefaultLimit = 100
)

Functions

func FindAllGroups

func FindAllGroups(a string, url string) (paramsMap map[string]string)

FindAllGroups FindAllGroups example: Pack(?P<DeviceID>\d{1,})(_S(?P<SlaveID>\d{1,})_C(?P<CellID>\d{1,}))?

func InsertSortFindIndex

func InsertSortFindIndex(s []float64, v float64) int

Inserts a float into a slice, sorts the slice and returns the index of first appearance of given float after sorting

Types

type ConcurrencyLimiter

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

ConcurrencyLimiter object

func NewConcurrencyLimiter

func NewConcurrencyLimiter(limit int) *ConcurrencyLimiter

NewConcurrencyLimiter allocates a new ConcurrencyLimiter

func (*ConcurrencyLimiter) Execute

func (c *ConcurrencyLimiter) Execute(job func())

Execute adds a function to the execution queue. if num of go routines allocated by this instance is < limit launch a new go routine to execute job else wait until a go routine becomes available

func (*ConcurrencyLimiter) ExecuteIndex

func (c *ConcurrencyLimiter) ExecuteIndex(index int, job func(numb int))

ExecuteIndex ExecuteIndex

func (*ConcurrencyLimiter) Loop

func (c *ConcurrencyLimiter) Loop(n int, job func(o int))

func (*ConcurrencyLimiter) Wait

func (c *ConcurrencyLimiter) Wait()

Wait will block all the previously Executed jobs completed running.

IMPORTANT: calling the Wait function while keep calling Execute leads to

un-desired race conditions

type Timeout

type Timeout struct {
	Released bool
	Occured  bool
}

func (*Timeout) Release

func (t *Timeout) Release()

func (*Timeout) Run

func (t *Timeout) Run(seconds int, callback func())