<item index="5" class="java.lang.String" itemvalue="io.reactivex.annotations.Nullable" />
          <item index="6" class="java.lang.String" itemvalue="io.reactivex.rxjava3.annotations.Nullable" />
          <item index="7" class="java.lang.String" itemvalue="jakarta.annotation.Nullable" />
          <item index="8" class="java.lang.String" itemvalue="javax.annotation.CheckForNull" />

    private static final String FILTER_TYPE = "filterType";

    private static final String INCLUDE = "include";

    private static final String EXCLUDE = "exclude";

    protected LoadingCache<String, List<Pattern>> includeFilterCache;

    protected LoadingCache<String, List<Pattern>> excludeFilterCache;

    protected int filterCacheExpireAfterWrite = 10; // 10sec

 *
 */
public class UrlQueueImpl<IDTYPE> implements UrlQueue<IDTYPE> {
    protected IDTYPE id;

    protected String sessionId;

    protected String method;

    protected String url;

    protected String metaData;

    protected String encoding;

    protected String parentUrl;

    protected Integer depth;

    protected Long lastModified;

    protected Long createTime;

    void setId(IDTYPE id);

    String getSessionId();

    void setSessionId(String sessionId);

    String getMethod();

    void setMethod(String method);

    String getUrl();

    void setUrl(String url);

    String getMetaData();

    void setMetaData(String metaData);

    String getEncoding();

    void setEncoding(String encoding);

    String getParentUrl();

    @Override
    public int getCount(final String sessionId) {
        return getCount(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId)));
    }

    @Override
    public void delete(final String sessionId) {
        deleteBySessionId(sessionId);
    }

    @Override
    public OpenSearchAccessResult getAccessResult(final String sessionId, final String url) {

    @Override
    public void updateSessionId(final String oldSessionId, final String newSessionId) {
        SearchResponse response = getClient().get(c -> c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout))
                .setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize)
                .execute());
        String scrollId = response.getScrollId();
        try {

    protected String searchPreference;

    protected String[] targetIndices;

    public FesenClient() {
        address = System.getProperty(HTTP_ADDRESS, "localhost:9200").trim();
        final String targets = System.getProperty(TARGET_INDICES);
        if (StringUtil.isNotBlank(targets)) {
            targetIndices = Arrays.stream(targets.split(",")).map(String::trim).toArray(n -> new String[n]);
        }

type BuildRowFunc func(obj interface{}) Row

type Cell struct {
	Value      string
	Attributes []color.Attribute
}

type Row struct {
	Cells []Cell
}

func NewCell(value string, attributes ...color.Attribute) Cell {
	attrs := append([]color.Attribute{}, attributes...)
	return Cell{value, attrs}
}

func (cell Cell) String() string {
	if len(cell.Attributes) == 0 {
		return cell.Value
	}

public class OpenSearchUrlFilter implements ToXContent {

    public static final String SESSION_ID = "sessionId";

    public static final String FILTER_TYPE = "filterType";

    public static final String URL = "url";

    private String id;

    private String sessionId;

    private String filterType;

    private String url;

    public String getId() {
        return id;
    }

    @Override
    protected String prepareConfigFile() {
        return "app.xml";
    }

    @Override
    protected boolean isUseOneTimeContainer() {
        return true;
    }

    @Override
    public void setUp() throws Exception {
        // create runner instance
        runner = new OpenSearchRunner();
        // create ES nodes
        final String clusterName = UUID.randomUUID().toString();