The highest tagged major version is v2.

cqos

module

v1.5.3 Latest Latest Go to latest Published: Jun 4, 2024 License: MIT

Details

Library that allows you to control passage of data between Go channels

priority - distributes data among handlers according to priority. See README
join - accumulates elements from the input channel into a slice and writes it to the output channel when the size or timeout is reached. See README

Path	Synopsis
internal
consts Internal package with common constants.	Internal package with common constants.
general Internal package with functions and data types used in other packages.	Internal package with functions and data types used in other packages.
qot Internal package with quantity over time struct used in research.	Internal package with quantity over time struct used in research.
join Discipline that used to accumulates elements from the input channel into a slice and writes it to the output channel when the size or timeout is reached.	Discipline that used to accumulates elements from the input channel into a slice and writes it to the output channel when the size or timeout is reached.
priority Discipline that used to distributes data among handlers according to priority.	Discipline that used to distributes data among handlers according to priority.
internal/common Internal package with functions and data types used in other packages.	Internal package with functions and data types used in other packages.
internal/starter Internal package with implementation of the Starter which is used to run multiple goroutines at the same time.	Internal package with implementation of the Starter which is used to run multiple goroutines at the same time.