lifecycle

Documentation

Index

• func OwnerID() string
• func Retry(interval time.Duration, retryTimes int, fn func() (needRetry bool, err error)) (err error)
• type LifeCycle
  • func New() *LifeCycle
  • func Std() *LifeCycle
  • func (l *LifeCycle) AddCloseFunc(f func() error)
  • func (l *LifeCycle) AddCloser(clr io.Closer)
  • func (l *LifeCycle) C() <-chan struct{}
  • func (l *LifeCycle) Context() context.Context
  • func (l *LifeCycle) Exit()
  • func (l *LifeCycle) SetSignals(sigs ...os.Signal)
  • func (l *LifeCycle) SetTimeout(d time.Duration)
  • func (l *LifeCycle) WaitExit()

Functions

func OwnerID

func OwnerID() string

OwnerID 获取当前服务的ownerID

func Retry

func Retry(interval time.Duration, retryTimes int, fn func() (needRetry bool, err error)) (err error)

Retry 重試

Types

type LifeCycle

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

LifeCycle 应用程序生命周期

func New

func New() *LifeCycle

New .

func Std

func Std() *LifeCycle

Std ..

func (*LifeCycle) AddCloseFunc

func (l *LifeCycle) AddCloseFunc(f func() error)

AddCloseFunc 添加退出任务

func (*LifeCycle) AddCloser

func (l *LifeCycle) AddCloser(clr io.Closer)

AddCloser 添加退出任务

func (*LifeCycle) C

func (l *LifeCycle) C() <-chan struct{}

C .

func (*LifeCycle) Context

func (l *LifeCycle) Context() context.Context

Context 上下文

func (*LifeCycle) Exit

func (l *LifeCycle) Exit()

Exit 强制退出

func (*LifeCycle) SetSignals

func (l *LifeCycle) SetSignals(sigs ...os.Signal)

SetSignals 设置监听的信号量

func (*LifeCycle) SetTimeout

func (l *LifeCycle) SetTimeout(d time.Duration)

SetTimeout 退出超时时间

func (*LifeCycle) WaitExit

func (l *LifeCycle) WaitExit()

WaitExit .