priority

May 30, 2024

Changes in this version

+ var ErrDividerBad = errors.New("divider produces an incorrect distribution")

+ var ErrEmptyInput = errors.New("input channels was not specified")

+ var ErrHandlersQuantityZero = errors.New("handlers quantity is zero")

Jun 14, 2023

Changes in this version

type Discipline

+ func (dsc *Discipline[Type]) GracefulStop()

type Simple

+ func (smpl *Simple[Type]) GracefulStop()

Jun 8, 2023

Changes in this version

+ var ErrEmptyHandle = errors.New("handle function was not specified")

+ var ErrQuantityExceeded = errors.New("value of handlers quantity has been exceeded")

type Discipline

+ func (dsc *Discipline[Type]) Err() <-chan error

type Simple

+ func (smpl *Simple[Type]) Err() <-chan error

Jun 6, 2023

Changes in this version

+ func IsNonFatalConfig(priorities []uint, divider Divider, quantity uint) bool

+ func IsSuitableConfig(priorities []uint, divider Divider, quantity uint, limit float64) bool

+ func PickUpMaxNonFatalQuantity(priorities []uint, divider Divider, maxQuantity uint) uint

+ func PickUpMaxSuitableQuantity(priorities []uint, divider Divider, maxQuantity uint, limit float64) uint

+ func PickUpMinNonFatalQuantity(priorities []uint, divider Divider, maxQuantity uint) uint

+ func PickUpMinSuitableQuantity(priorities []uint, divider Divider, maxQuantity uint, limit float64) uint

+ type Handle func(ctx context.Context, item Type)

+ type Simple struct

+ func NewSimple(opts SimpleOpts[Type]) (*Simple[Type], error)

+ func (smpl *Simple[Type]) Stop()

+ type SimpleOpts struct

+ Ctx context.Context

+ Divider Divider

+ Handle Handle[Type]

+ HandlersQuantity uint

+ Inputs map[uint]<-chan Type

May 31, 2023

Changes in this version

type Opts

+ Ctx context.Context

May 25, 2023

Changes in this version

+ func FairDivider(priorities []uint, dividend uint, distribution map[uint]uint) map[uint]uint

+ func RateDivider(priorities []uint, dividend uint, distribution map[uint]uint) map[uint]uint

+ type Divider func(priorities []uint, dividend uint, distribution map[uint]uint) map[uint]uint

+ type Prioritized struct

+ Item Type

+ Priority uint

May 20, 2023

Changes in this version

+ var ErrEmptyDivider = errors.New("priorities divider was not specified")

+ var ErrEmptyFeedback = errors.New("feedback channel was not specified")

+ var ErrEmptyOutput = errors.New("output channel was not specified")

+ type Discipline struct

+ func New(opts Opts[Type]) (*Discipline[Type], error)

+ func (dsc *Discipline[Type]) AddInput(channel chan Type, priority uint)

+ func (dsc *Discipline[Type]) RemoveInput(priority uint)

+ func (dsc *Discipline[Type]) Stop()

+ type Opts struct

+ Divider divider.Divider

+ Feedback <-chan uint

+ HandlersQuantity uint

+ Inputs map[uint]<-chan Type

+ Output chan<- types.Prioritized[Type]