L226: // LDAP: cn=%s L227: // AD: (&(objectClass=user)(sAMAccountName=%s)) L228: final String filter = String.format(accountFilter, ldapUser.getName()); L229: if (logger.isDebugEnabled()) { L230: logger.debug("Account Filter: {}", filter); L231: } L232: final Set<String> subRoleSet = new HashSet<>(); L233: search(bindDn, filter, new String[] { fessConfig.getLdapMemberofAttribute() }, () -> ldapUser.getEnvironment(), result -> { L234: ...

final String LDAP_SECURITY_AUTHENTICATION = "ldap.security.authentication"; L383: L384: public static final String LDAP_INITIAL_CONTEXT_FACTORY = "ldap.initial.context.factory"; L385: L386: public static final String LDAP_ACCOUNT_FILTER = "ldap.account.filter"; L387: L388: public static final String LDAP_GROUP_FILTER = "ldap.group.filter"; L389: L390: public static final String LDAP_MEMBEROF_ATTRIBUTE = "ldap.memberof.attribute"; L391: L392: public static final String NOTIFICATION_LOGIN...

L398: /** The key of the message: mode */ L399: public static final String LABELS_CRUD_MODE = "{labels.crudMode}"; L400: L401: /** The key of the message: Max Error Count */ L402: public static final String LABELS_ERROR_COUNT_MAX = "{labels.errorCountMax}"; L403: L404: /** The key of the message: Min Error Count */ L405: public static final String LABELS_ERROR_COUNT_MIN = "{labels.errorCountMin}"; L406: L407: /** The key of the message: Facet */ L408: public static final String...

String url, final String clickCountField) { L173: final SearchLogHelper searchLogHelper = ComponentUtil.getSearchLogHelper(); L174: final int count = searchLogHelper.getClickCount(url); L175: doc.put(clickCountField, count); L176: if (logger.isDebugEnabled()) { L177: logger.debug("Click Count: {}, url: {}", count, url); L178: } L179: } L180: L181: protected void addFavoriteCountField(final Map<String, Object> doc, final String url, final String favoriteCountField)...

h.aggregations.metrics.Cardinality; L61: L62:import jakarta.annotation.Resource; L63: L64:public class SearchLogService { L65: L66: private static final String YYYY_MM_DD_HH_MM = "yyyy-MM-dd HH:mm"; L67: L68: private static final String COUNT = "count"; L69: L70: private static final String KEY = "key"; L71: L72: private static final String ID = "id"; L73: L74: private static final String USER_INFO_ID = "userInfoId"; L75: L76: private static final String QUERY_TIME = "queryTime";...

public ApiResult result() { L85: return new ApiResult(this); L86: } L87: } L88: L89: public static class ApiDeleteResponse extends ApiResponse { L90: protected long count = 1; L91: L92: public ApiDeleteResponse count(final long count) { L93: this.count = count; L94: return this; L95: } L96: L97: @Override L98: public ApiResult result() { L99: return new ApiResult(this); L100: } L101: } L102: L103: ...

public static class JvmPoolObj { L247: public String key; L248: public long count; L249: public long used; L250: public long capacity; L251: } L252: L253: public static class JvmGcObj { L254: public String key; L255: public long count; L256: public long time; L257: } L258: L259: public static class JvmThreadsObj { L260: public int count; L261: public int peak; L262: } L263: L264: public static class JvmClassesObj {...

serialVersionUID = 1L; L271: L272: protected final AtomicInteger count; L273: L274: public StatsObject() { L275: put(BEGIN_KEY, ComponentUtil.getSystemHelper().getCurrentTimeAsLong()); L276: count = new AtomicInteger(1); L277: } L278: L279: public int increment() { L280: return count.incrementAndGet(); L281: } L282: L283: public int decrement() { L284: return count.decrementAndGet(); L285: } L286: } L287: L288: ...

tName())).append("\":{"); L99: append(b, "count", () -> c.getCollectionCount()).append(','); L100: append(b, "time", () -> c.getCollectionTime().getMillis()).append('}'); L101: return b.toString(); L102: }).collect(Collectors.joining(","))); L103: buf.append("},"); L104: final Threads threads = jvmStats.getThreads(); L105: buf.append("\"threads\":{"); L106: append(buf, "count", () -> threads.getCount()).append(','); L107: ...

scheduler.get("running"); L70: } L71: if (300 <= count) { L72: logger.info("Time out: Failed to start crawler)"); L73: fail(); // Time Out L74: } L75: L76: logger.info("Crawler is running"); L77: count = 0; L78: isRunning = true; L79: while (count < 300 && isRunning) { // Wait until the crawler terminates L80: ThreadUtil.sleep(1000); L81: count++; L82: final Map<String, Object> scheduler = getS...