cqos

module

v2.0.6 Latest Latest Go to latest Published: Dec 26, 2023 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
breaker Internal package used to break goroutine and wait it completion	Internal package used to break goroutine and wait it completion
consts Internal package with common constants	Internal package with common constants
durations Internal package used to work with slice of durations	Internal package used to work with slice of durations
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
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
internal/starter Internal package with implementation of the Starter that used to wait for the start of all goroutines after they have declared readiness n times	Internal package with implementation of the Starter that used to wait for the start of all goroutines after they have declared readiness n times
internal/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
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