concurrency

package

v0.0.0-...-0a3be77 Latest Latest Go to latest Published: Jul 2, 2024 License: MIT Imports: 6 Imported by: 0

Documentation ¶

const (
	Retry = 150
)

View Source

var ConCurrencyGlobal = NewConcurrency()

This section is empty.

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

func NewConcurrency() *Concurrency

func (c *Concurrency) DecColdNum(metric, taskId string)

func (c *Concurrency) DoneTask(metric, taskId string)

func (c *Concurrency) WaitToValid(metric string) bool

WaitToValid Avoid excessive cold start concurrency

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

func NewMetric() *Metric

func (m *Metric) SetColdFlag(flag bool)

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