zquit

package

v1.2.1 Latest Latest Go to latest Published: Dec 25, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Pool struct {
	PostWaitDur time.Duration
	// contains filtered or unexported fields
}

func DefaultPool() *Pool

func NewPool(postWaitDur time.Duration) *Pool

func (p *Pool) Add(z *ZQuit)

func (p *Pool) PrintStat(sec int)

func (p *Pool) Wait()

func (p *Pool) WaitInterrupt()

func (p *Pool) WaitInterruptPrePost(pre func(), post func())

type ZQuit struct {
	Name        string
	PostWaitDur time.Duration
	// contains filtered or unexported fields
}

func Default(name ...string) *ZQuit

func New(name string, postWaitDur time.Duration) *ZQuit

func (q *ZQuit) Done()

func (q *ZQuit) GetStat() string

func (q *ZQuit) Inc()

func (q *ZQuit) IncDefer() func()

func (q *ZQuit) IsQuit() bool

func (q *ZQuit) Middleware(c *gin.Context)

func (q *ZQuit) PrintStat(sec int)

func (q *ZQuit) Shutdown()

func (q *ZQuit) Val() int

func (q *ZQuit) Wait()

func (q *ZQuit) WaitInterrupt()

func (q *ZQuit) WaitInterruptPrePost(pre func(), post func())