checkpoints

Documentation

Index

• func ReportDeadlockFatal(name string, threshold time.Duration, log *zap.SugaredLogger)
• type Checkpoints
  • func New(callback func(name string), checkPeriod ...time.Duration) *Checkpoints
  • func (c *Checkpoints) Check(name string, nextExpectedAfter ...time.Duration)
  • func (c *Checkpoints) CheckAndClose(name string)
  • func (c *Checkpoints) Close()

Functions

func ReportDeadlockFatal

func ReportDeadlockFatal(name string, threshold time.Duration, log *zap.SugaredLogger)

Types

type Checkpoints

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

func New

func New(callback func(name string), checkPeriod ...time.Duration) *Checkpoints

func (*Checkpoints) Check

func (c *Checkpoints) Check(name string, nextExpectedAfter ...time.Duration)

Check is nextExpectedAfter == 0 cancels checkpoint

func (*Checkpoints) CheckAndClose

func (c *Checkpoints) CheckAndClose(name string)

func (*Checkpoints) Close

func (c *Checkpoints) Close()