flow

module

v0.0.4 Latest Latest Go to latest Published: Feb 19, 2025 License: MIT

Details

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

Repository

github.com/akramarenkov/flow

Links

Open Source Insights

README ¶

Flow

Purpose

Library that provides data flow control between Go channels

Implemented disciplines

join - accumulates data items from an input channel into a slice and write that slice to an output channel when the maximum slice size or timeout for its accumulation is reached. See README
limit - limits the speed of passing data items from the input channel to the output channel. See README
priority - distributes data items between handlers in quantity corresponding to the priority of the data items. See README

Directories ¶

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

Path	Synopsis
internal
consts Internal package with constants common to this module.	Internal package with constants common to this module.
env Internal package with environment constants common to this module.	Internal package with environment constants common to this module.
qot Internal package describing the quantity over time structure.	Internal package describing the quantity over time structure.
join Discipline used to accumulate data items from an input channel into a slice and write that slice to an output channel when the maximum slice size or timeout for its accumulation is reached.	Discipline used to accumulate data items from an input channel into a slice and write that slice to an output channel when the maximum slice size or timeout for its accumulation is reached.
internal/defaults Internal default constants for all join packages.	Internal default constants for all join packages.
unite Discipline used to accumulate items of slices from an input channel into a one slice and write that slice to an output channel when the maximum slice size or timeout for its accumulation is reached.	Discipline used to accumulate items of slices from an input channel into a one slice and write that slice to an output channel when the maximum slice size or timeout for its accumulation is reached.
limit Discipline used to limit the speed of passing data items from the input channel to the output channel.	Discipline used to limit the speed of passing data items 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 used to distribute data items between handlers in quantity corresponding to the priority of the data items.	Discipline used to distribute data items between handlers in quantity corresponding to the priority of the data items.
divider Here are implemented several dividers that determine in what quantity data items distributed among data handlers.	Here are implemented several dividers that determine in what quantity data items distributed among data handlers.
divider/inspect The package is used to check the dividers for compliance with the requirements for them.	The package is used to check the dividers for compliance with the requirements for them.
internal/distrib Internal package used to calculate distribution parameters.	Internal package used to calculate distribution parameters.
internal/measuring Internal package used to measuring and benchmarking of the discipline.	Internal package used to measuring and benchmarking of the discipline.
internal/research Internal package with research functions that are used for testing.	Internal package with research functions that are used for testing.
internal/unmanaged Internal package with the implementation of a discipline that does not distribute data items between handlers in quantity corresponding to the priority of the data items.	Internal package with the implementation of a discipline that does not distribute data items between handlers in quantity corresponding to the priority of the data items.
simple Simplified version of the priority discipline that runs handlers on its own.	Simplified version of the priority discipline that runs handlers on its own.
types Data types of the priority discipline.	Data types of the priority discipline.