"_score", org.opensearch.search.sort.SortOrder.DESC);

            assertNotNull(result);
            assertTrue(result.toString().contains("_score"));
        } catch (Exception e) {
            fail("Failed to test createFieldSortBuilder for score field: " + e.getMessage());
        }
    }

    public void test_getRescorers_emptyList() {

        });

        // Add function score
        queryContext.addFunctionScore(list -> {
            list.add(new FilterFunctionBuilder(QueryBuilders.termQuery("boost", "true"), ScoreFunctionBuilders.weightFactorFunction(3.0f)));
        });

        // Add sorts
        queryContext.addSorts(SortBuilders.fieldSort("_score"), SortBuilders.fieldSort("date").unmappedType("date"));

            builder.setSize(size);
        }

        // set query.
        final QueryBuilder q = buildQuery(query, fields);

        // set function score
        final QueryBuilder queryBuilder = buildFunctionScoreQuery(query, q);
        builder.addSort("_score", SortOrder.DESC);

        // set filter query.
        final List<QueryBuilder> filterList = new ArrayList<>(10);
        if (!tags.isEmpty()) {

        // Test that constants have expected values
        assertEquals("score", QueryFieldConfig.SCORE_FIELD);
        assertEquals("_score", QueryFieldConfig.DOC_SCORE_FIELD);
        assertEquals("site", QueryFieldConfig.SITE_FIELD);
        assertEquals("inurl", QueryFieldConfig.INURL_FIELD);
        assertEquals("score", QueryFieldConfig.SCORE_SORT_VALUE);
    }

    public void test_constructor() {

MINIO_NOTIFY_AMQP_COMMENT        (sentence)  optionally add a comment to this setting
```

                logger.warn("Failed to update scores: {}", response.buildFailureMessage());
            }
            bulkRequestBuilder = null;
        }
    }

    /**
     * Gets the priority of this score booster.
     * @return The priority.
     */
    public int getPriority() {
        return priority;
    }

    /**
     * Sets the priority of this score booster.
     * @param priority The priority.

 */
package org.codelibs.fess.score;

import java.util.Collections;
import java.util.HashMap;
import java.util.Map;

import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;
import org.opensearch.search.rescore.QueryRescorerBuilder;
import org.opensearch.search.rescore.RescorerBuilder;

		logger.Info("IAM expired STS purge took %.2fs", took)
	}

	// Store the newly populated map in the iam cache. This takes care of
	// removing stale entries from the existing map.
	cache.iamSTSAccountsMap = stsAccountsFromStore

	stsAccPoliciesFromStore.Range(func(k string, v MappedPolicy) bool {
		cache.iamSTSPolicyMap.Store(k, v)
		return true
	})

	return nil
}

	var p MappedPolicy
	err := ies.loadIAMConfig(ctx, &p, getMappedPolicyPath(name, userType, isGroup))
	if err != nil {
		if err == errConfigNotFound {
			return errNoSuchPolicy
		}
		return err
	}
	m.Store(name, p)
	return nil
}

func getMappedPolicy(kv *mvccpb.KeyValue, m *xsync.MapOf[string, MappedPolicy], basePrefix string) error {
	var p MappedPolicy
	err := getIAMConfig(&p, kv.Value, string(kv.Key))

func (store *IAMStoreSys) ListGroups(ctx context.Context) (res []string, err error) {
	cache := store.lock()
	defer store.unlock()

	return store.updateGroups(ctx, cache)
}

// listGroups - lists groups - fetch groups from cache
func (store *IAMStoreSys) listGroups(ctx context.Context) (res []string, err error) {
	cache := store.rlock()
	defer store.runlock()