graceful

Documentation

Index

• type Graceful
  • func NewGraceful() *Graceful
  • func (s *Graceful) Stop()
  • func (s *Graceful) Wait()
  • func (s *Graceful) Wait2(e time.Duration) (err error)

Types

type Graceful

type Graceful struct {
	Ctx context.Context

	Wg sync.WaitGroup
	// contains filtered or unexported fields
}

优雅停止

func NewGraceful

func NewGraceful() *Graceful

NewGraceful 主要用于优雅重启msg_group

func (*Graceful) Stop

func (s *Graceful) Stop()

Stop 停止服务 不阻塞,停止后将不会在消费任何消息

func (*Graceful) Wait

func (s *Graceful) Wait()

Wait 阻塞等待所有消费者退出

func (*Graceful) Wait2

func (s *Graceful) Wait2(e time.Duration) (err error)