limiter

package

v0.1.2 Latest Latest Go to latest Published: Jan 20, 2016 License: MPL-2.0 Imports: 8 Imported by: 0

Details

Limiters helps to describe different schedulers

This section is empty.

This section is empty.

func Drain(ctx context.Context, l Limiter) (int, error)

Drain counts all ticks from limiter

type Limiter interface {
	Start(context.Context) error
	Control() <-chan struct{}
}

Limiter interface describes limiter control structure

func NewBatch(batchSize int, master Limiter) (l Limiter)

NewBatch returns batch limiter that makes batch with size batchSize on every master tick master shouldn't be started

func NewCompositeFromConfig(c *config.Limiter) (l Limiter, err error)

func NewLinear(startRps, endRps, period float64) (l Limiter)

func NewLinearFromConfig(c *config.Limiter) (l Limiter, err error)

NewLinearFromConfig returns linear limiter

func NewPeriodic(period time.Duration) (l Limiter)

func NewPeriodicFromConfig(c *config.Limiter) (l Limiter, err error)

NewPeriodicFromConfig returns periodic limiter

func NewSize(size int, master Limiter) (l Limiter)

NewSize returns size limiter that cuts master limiter by size master shouldn't be started

func NewUnlimitedFromConfig(c *config.Limiter) (l Limiter, err error)