signals

Documentation

Index

• Constants
• Variables
• type Handler
  • func SetupSignalHandler(logger log.Logger) (stopCh *Handler)
  • func SignalHandler() (stopCh *Handler)
  • func (s *Handler) Add(delta int)
  • func (s *Handler) AddFor(level uint8, delta int)
  • func (s *Handler) AddRequest(delta int)
  • func (s *Handler) Channel() <-chan struct{}
  • func (s *Handler) Done()
  • func (s *Handler) DoneFor(level uint8)
  • func (s *Handler) DoneRequest()
  • func (s *Handler) PreStop(level uint8, f stopFunc)
  • func (s *Handler) SafeStop(timeout time.Duration, exitFunc func(int))
  • func (s *Handler) Wait()
  • func (s *Handler) WaitFor(level uint8)
  • func (s *Handler) WaitRequest()

Constants

const (
	LevelRoot    uint8 = 0
	LevelTrace   uint8 = 5
	LevelDB      uint8 = 10
	LevelRequest uint8 = 20
	LevelMax     uint8 = 31
)

Variables

var (
	ErrorNoInit           = errors.New("stopChan is not init")
	ErrorLevelOutOfBounds = errors.New("level out of bounds")
)

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

func SetupSignalHandler

func SetupSignalHandler(logger log.Logger) (stopCh *Handler)

func SignalHandler

func SignalHandler() (stopCh *Handler)

func (*Handler) Add

func (s *Handler) Add(delta int)

func (*Handler) AddFor

func (s *Handler) AddFor(level uint8, delta int)

func (*Handler) AddRequest

func (s *Handler) AddRequest(delta int)

func (*Handler) Channel

func (s *Handler) Channel() <-chan struct{}

func (*Handler) Done

func (s *Handler) Done()

func (*Handler) DoneFor

func (s *Handler) DoneFor(level uint8)

func (*Handler) DoneRequest

func (s *Handler) DoneRequest()

func (*Handler) PreStop

func (s *Handler) PreStop(level uint8, f stopFunc)

func (*Handler) SafeStop

func (s *Handler) SafeStop(timeout time.Duration, exitFunc func(int))

func (*Handler) Wait

func (s *Handler) Wait()

func (*Handler) WaitFor

func (s *Handler) WaitFor(level uint8)

func (*Handler) WaitRequest

func (s *Handler) WaitRequest()