dqf2

type ChDown[T any] chan *Message[T]

type Chopper_Mode struct {
	Period              time.Duration
	ThresholdPerc       float32 // threshold perc of full capacity, action happens if above it
	ChopNPerc           float32 // how much to chop per one action, perc of full capacity
	NChopsToUpgrade     int     // e.g. after 5 successive chops, upgrade to faster mode
	NNoChopsToDowngrade int     // e.g. after 5 successive no-chops, downgrade to slower mode
}

type Chopper_Options struct {
	Modes         []Chopper_Mode // 0 is slowest, -1 is fastest
	IfChoppedFunc func(n_chopped int)
	UpgradeFunc   func(from_mode, to_mode int)
	DowngradeFunc func(from_mode, to_mode int)
}

type Message[T any] struct {
	Tag int // this is used, among other things, by the chopper to mark failed deliveries

	Func func(m *Message[T], s T)
	// contains filtered or unexported fields
}