cqos

module

v2.0.9 Latest Latest Go to latest Published: Jun 4, 2024 License: MIT

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/akramarenkov/cqos

README ¶

CQOS

Purpose

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

Implemented disciplines

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
limit - limits the speed of passing data elements from the input channel to the output channel. See README

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

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.
launcher Internal package with implementation of the Launcher that used to wait for the launch of all goroutines after they have declared readiness n times.	Internal package with implementation of the Launcher that used to wait for the launch of all goroutines after they have declared readiness n times.
qot Internal package with quantity over time struct used in research.	Internal package with quantity over time struct used in research.
stressor Internal package with implementation of the Stressor that was used to load the system and runtime.	Internal package with implementation of the Stressor that was used to load the system and runtime.
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.
internal/spinner Internal package used to iterate over integer values that returns the begin value when trying to go beyond the end value.	Internal package used to iterate over integer values that returns the begin value when trying to go beyond the end value.
limit Discipline that used to limits the speed of passing data elements from the input channel to the output channel.	Discipline that used to limits the speed of passing data elements from the input channel to the output channel.
internal/research Internal package with research functions that are used for testing.	Internal package with research functions that are used for testing.
priority Discipline that used to distributes data among handlers according to priority.	Discipline that used to distributes data among handlers according to priority.
divider Several dividers are implemented here that distributes quantity of something by priorities.	Several dividers are implemented here that distributes quantity of something by priorities.
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/measurer Internal package with implementation of the measurer which is used for testing.	Internal package with implementation of the measurer which is used for testing.
internal/research Internal package with research functions that are used for testing.	Internal package with research functions that are used for testing.
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.
internal/unmanaged Internal package with the implementation of a discipline that does not manage data according to their priority.	Internal package with the implementation of a discipline that does not manage data according to their priority.
simple Simplified version of the prioritization discipline that runs handlers on its own	Simplified version of the prioritization discipline that runs handlers on its own
types Data types of prioritization discipline.	Data types of prioritization discipline.
utils Several auxiliary functions for pickup and checking the quantity of handlers are implemented here.	Several auxiliary functions for pickup and checking the quantity of handlers are implemented here.