lifecycle

Documentation

Index

• func Exists(pidfile string) error
• func GeneratePIDFile(pidfile string) error
• func Open(pidfile string) (*os.Process, error)
• 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) CancelContext()
  • 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 Exists

func Exists(pidfile string) error

Exists open a pid file.

func GeneratePIDFile

func GeneratePIDFile(pidfile string) error

GeneratePIDFile create a pid file for own process.

func Open

func Open(pidfile string) (*os.Process, error)

Open open a pid file and return this process.

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) CancelContext

func (l *LifeCycle) CancelContext()

CancelContext 预退出

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 .