}

func (m *batchJobMetrics) delete(jobID string) {
	m.Lock()
	defer m.Unlock()

	delete(m.metrics, jobID)
}

func (m *batchJobMetrics) save(jobID string, ri *batchJobInfo) {
	m.Lock()
	defer m.Unlock()

	m.metrics[jobID] = ri.clone()
}

type objTraceInfoer interface {
	TraceObjName() string
	TraceVersionID() string
}

    private final String layoutId;

    public UnknownRepositoryLayoutException(String repositoryId, String layoutId) {
        super("Cannot find ArtifactRepositoryLayout instance for: " + layoutId, repositoryId);
        this.layoutId = layoutId;
    }

    public UnknownRepositoryLayoutException(String repositoryId, String layoutId, ComponentLookupException e) {

public class TextExtractor extends AbstractExtractor {

    protected String encoding = Constants.UTF_8;

    @Override
    public ExtractData getText(final InputStream in, final Map<String, String> params) {
        if (in == null) {
            throw new CrawlerSystemException("The inputstream is null.");
        }
        try {
            return new ExtractData(new String(InputStreamUtil.getBytes(in), getEncoding()));

  static TestSuite suiteForString(
      ByteSourceFactory factory, String string, String name, String desc) {
    TestSuite suite = suiteForBytes(factory, string.getBytes(UTF_8), name, desc, true);
    CharSourceFactory charSourceFactory = SourceSinkFactories.asCharSourceFactory(factory);
    suite.addTest(
        CharSourceTester.suiteForString(
            charSourceFactory, string, name + ".asCharSource[Charset]", desc));
    return suite;
  }

                        try {
                            try {
                                if (String.class == type) {
                                    String value = (String) field.get(target);
                                    if (value != null) {
                                        String interpolated = modelInterpolator.interpolateInternal(

    protected String url;

    protected Integer accessTimeout; // sec

    protected CloseableHttpClient httpClient;

    protected Integer connectionTimeout;

    protected Integer soTimeout;

    protected Map<String, AuthSchemeProvider> authSchemeProviderMap;

    protected String userAgent = "Crawler";

          + Arrays.toString(trustManagers));
    }
    return (X509TrustManager) trustManagers[0];
  }

  private String[] javaNames(List<CipherSuite> cipherSuites) {
    String[] result = new String[cipherSuites.size()];
    for (int i = 0; i < result.length; i++) {
      result[i] = cipherSuites.get(i).javaName();
    }
    return result;
  }

  /**

                retVal = tokBuf.toString();
            }
        }

        return optional ? "?" + retVal : retVal;
    }

    public static String substVars(
            String value, String name, Map<String, String> props, Function<String, String> callback) {
        return DefaultInterpolator.substVars(value, name, null, props, callback, null, false);
    }

    protected Pattern userAgentPattern;

    protected Pattern regexPattern;

    protected BiFunction<String, Matcher, String> pathMapperFunc;

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    private int pageSize;

    private int currentPageNumber;

    public String id;

    public String term;

    public String query;

    public String maxSize;

    public String boost;

    public String createdBy;

    public String createdTime;

    public String versionNo;

    public void clear() {
        allRecordCount = 0;
        allPageCount = 0;