helper

type StatCallback ¶ added in v0.8.1

type StatCallback func(metric string, value float64)

type Stoppable ¶

type Stoppable struct {
	sync.RWMutex

	Go       func(callable func(exit chan bool))
	WithExit func(callable func(exit chan bool))
	// contains filtered or unexported fields
}

Stoppable is abstract class with Start/Stop methods

func (s *Stoppable) Start()

func (s *Stoppable) StartFunc(startProcedure func() error) error

func (s *Stoppable) Stop()

func (s *Stoppable) StopFunc(callable func())

type StoppableInterface ¶

type StoppableInterface interface {
}

type ThrottleTicker ¶ added in v0.17.0

type ThrottleTicker struct {
	Stoppable
	C chan bool
}

ThrottleTicker is a ticker that can be used for hard or soft rate-limiting.

• A soft rate limiter will send a message on C at the actual rate that is specified.

• A hard rate limiter may send arbitrarily many messages on C every second, but it will send the value 'true' with the first ratePerSec ones, and 'false' with all subsequent ones, until the next second. It is up to the user to decide what to do in each case.

func NewHardThrottleTicker(ratePerSec int) *ThrottleTicker

func NewThrottleTicker(ratePerSec int) *ThrottleTicker