eq_pump

Documentation

Index

• Variables
• type Pump
  • func New(l esl.Logger, bundle eq_bundle.Bundle) Pump

Variables

var (
	// Duration of sleep when the bundle is empty.
	PollInterval = 50 * time.Millisecond
)

Types

type Pump

type Pump interface {
	// Start the pump.
	Start() chan eq_bundle.Barrel

	// Wait & close the pump
	Close()

	// Stop the pump
	Shutdown()
}

func New

func New(l esl.Logger, bundle eq_bundle.Bundle) Pump