watcher

Documentation

Index

• func Run(ps *pubsub.PubSub, loggerArg *logrus.Logger, logArg *base.LogObject, ...) int
• type GoroutineLeakDetectionParams
  • func (gldp *GoroutineLeakDetectionParams) Get() (int, time.Duration, time.Duration, time.Duration, time.Duration)
  • func (gldp *GoroutineLeakDetectionParams) MakeStoppable()
  • func (gldp *GoroutineLeakDetectionParams) Set(threshold int, ...)
  • func (gldp *GoroutineLeakDetectionParams) Stop()

Functions

func Run

func Run(ps *pubsub.PubSub, loggerArg *logrus.Logger, logArg *base.LogObject, arguments []string, baseDir string) int

Run :

Types

type GoroutineLeakDetectionParams

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

GoroutineLeakDetectionParams holds the global goroutine leak detection parameters

func (*GoroutineLeakDetectionParams) Get

func (gldp *GoroutineLeakDetectionParams) Get() (int, time.Duration, time.Duration, time.Duration, time.Duration)

Get atomically gets the global goroutine leak detection parameters

func (*GoroutineLeakDetectionParams) MakeStoppable

func (gldp *GoroutineLeakDetectionParams) MakeStoppable()

MakeStoppable creates a cancellable context and a stop function

func (*GoroutineLeakDetectionParams) Set

func (gldp *GoroutineLeakDetectionParams) Set(threshold int, checkInterval, checkStatsFor, keepStatsFor, cooldownPeriod time.Duration)

Set atomically sets the global goroutine leak detection parameters

func (*GoroutineLeakDetectionParams) Stop

func (gldp *GoroutineLeakDetectionParams) Stop()

Stop cancels the context to stop the monitoring goroutine