signal

Documentation

Index

• func WaitTermSignalForGracefulRestart(sigs ...*TermSignal)
• type TermSignal
  • func NewTermSignal() *TermSignal
  • func (s *TermSignal) CancelCallbacksRegistry(callbacks ...func())
  • func (s *TermSignal) Close(wg *sync.WaitGroup)
  • func (s *TermSignal) GetStopChannel() *chan struct{}
  • func (s *TermSignal) GetStopCtx() *context.Context

Functions

func WaitTermSignalForGracefulRestart

func WaitTermSignalForGracefulRestart(sigs ...*TermSignal)

Types

type TermSignal

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

func NewTermSignal

func NewTermSignal() *TermSignal

func (*TermSignal) CancelCallbacksRegistry

func (s *TermSignal) CancelCallbacksRegistry(callbacks ...func())

func (*TermSignal) Close

func (s *TermSignal) Close(wg *sync.WaitGroup)

func (*TermSignal) GetStopChannel

func (s *TermSignal) GetStopChannel() *chan struct{}

GetStopChannel 不用手动关闭这个 channel， 关闭函数最后会关闭 channel

func (*TermSignal) GetStopCtx

func (s *TermSignal) GetStopCtx() *context.Context