func NewTimeout()

in plugins/plugins.go [107:127]


func NewTimeout(timeoutFunc func(duration time.Duration)) (*Timeout, error) {
	if timeout := os.Getenv(sendFailureTimeoutEnvVar); timeout != "" {
		duration, err := time.ParseDuration(timeout)
		if err != nil {
			return nil, err
		}
		return &Timeout{
			timeoutFunc: timeoutFunc,
			duration:    duration,
			ticking:     false,
			enabled:     true,
		}, nil
	}

	// timeout not enabled
	return &Timeout{
		timeoutFunc: timeoutFunc,
		ticking:     false,
		enabled:     false,
	}, nil
}