}

// Wrapper to restClient.CallWithMethod to handle network errors, in case of network error the connection is disconnected
// and a healthcheck routine gets invoked that would reconnect.
func (client *storageRESTClient) callGet(ctx context.Context, rpcMethod string, values url.Values, body io.Reader, length int64) (io.ReadCloser, error) {
	if values == nil {
		values = make(url.Values)

     * This would cause the mojo to use a wrongly configured default logger when being run by Maven. The proper logger
     * gets injected by the Plexus container after the mojo has been constructed. Therefore, simply call this
     * method directly whenever you need the logger, it is fast enough and needs no caching.
     *

                    }
                } catch (final IOException e) {
                    throw new CrawlerSystemException(e);
                }
            }
        }

        /**
         * Gets the captured output as a single string.
         * @return The captured output with newlines.
         */
        public String getOutput() {
            final StringBuilder buf = new StringBuilder(100);

            for (final String role : roles) {
                if (StringUtil.isNotEmpty(role)) {
                    roleSet.add(role);
                }
            }
        }
    }

    /**
     * Gets the current time in milliseconds.
     * @return The current time in milliseconds.
     */
    protected long getCurrentTime() {
        return ComponentUtil.getSystemHelper().getCurrentTimeAsLong();
    }

            this.url = url;
            this.depth = depth;
        }

        /**
         * Gets the URL of this crawl request.
         *
         * @return the URL to be crawled
         */
        public String getUrl() {
            return url;
        }

        /**
         * Gets the depth of this crawl request in the crawling hierarchy.
         *
         * @return the crawling depth

            return searchWithMainSearcher(availableSearchers[0], query, params, userBean);
        }
        return searchWithMultipleSearchers(availableSearchers, query, params, userBean);
    }

    /**
     * Gets the array of available searchers based on configuration.
     * Filters the searchers list to include only those specified in the available searcher name set.
     * If no specific searchers are configured, returns all searchers.

            kryo.register(clazz);
        } catch (final Exception e) {
            logger.warn("Failed to register class for Kryo serialization: {}", clazz.getName(), e);
        }
    }

    /**
     * Gets the configured serializer type from the Fess configuration.
     *
     * @return the serializer type (either "kryo" or "javabin")
     */
    protected String getSerializerType() {

     *
     * @param runtime the job runtime to set
     */
    public void setJobRuntime(final LaJobRuntime runtime) {
        jobRuntimeLocal.set(runtime);
    }

    /**
     * Gets the job runtime for the current thread.
     *
     * @return the job runtime for the current thread
     */
    public LaJobRuntime getJobRuntime() {
        return jobRuntimeLocal.get();
    }

            } catch (final Exception e) {
                logger.error("Could not destroy a process correctly.", e);
            }
        }
        return -1;
    }

    /**
     * Gets the set of session IDs for all currently running processes.
     *
     * @return set of session IDs for running processes
     */
    public Set<String> getRunningSessionIdSet() {

   * It is set by a client who only wants to make a request if it can be fully satisfied by the
   * cache. Cached responses that would require validation (ie. conditional gets) are not permitted
   * if this header is set.
   */
  @get:JvmName("onlyIfCached") val onlyIfCached: Boolean,
  @get:JvmName("noTransform") val noTransform: Boolean,
  @get:JvmName("immutable") val immutable: Boolean,