}
		sys.arnRemotesMap[tgt.Arn] = arnTarget{Client: tgtClient}
		sys.updateBandwidthLimit(bucket, tgt.Arn, tgt.BandwidthLimit)
	}
	sys.targetsMap[bucket] = cfg.Targets
}

// Returns a minio-go Client configured to access remote host described in replication target config.
func (sys *BucketTargetSys) getRemoteTargetClient(tcfg *madmin.BucketTarget) (*TargetClient, error) {
	config := tcfg.Credentials

            ACE ace = mock(ACE.class);
            when(ace.getSID()).thenReturn(null);

            SID result = ace.getSID();
            assertNull(result, "getSID() should return null when configured");
            verify(ace).getSID();
        }

        @Test
        @DisplayName("Should handle zero access mask")
        void shouldHandleZeroAccessMask() {
            ACE ace = mock(ACE.class);

    fi

    # Make sure we don't use any predefined locale, as we check some exception message strings and rely on english language
    # As those strings are created by the OS, they are dependent on the configured locale
    LANG=en_US.UTF-8
    LC_ALL=en_US.UTF-8

    export HOSTNAME=`hostname -s`

    cd "$FESS_HOME"

    if [ "x$daemonized" = "x" ]; then

     * Returns the name of this LLM client.
     *
     * @return the client name (e.g., "ollama", "openai", "gemini")
     */
    String getName();

    /**
     * Checks if this LLM client is available and properly configured.
     *
     * @return true if the client is available, false otherwise
     */
    boolean isAvailable();

    // RAG workflow methods

    /**
     * Detects the intent of a user message.
     *

        this.pageNumberList = pageNumberList;
    }

    /**
     * Gets the default page size from the Fess configuration.
     *
     * @return the default page size configured in the system
     */
    protected int getDefaultPageSize() {
        return ComponentUtil.getFessConfig().getPagingPageSizeAsInteger();
    }

/**
 * A request to resolve a version range to a list of matching versions.
 * This request is used by {@link VersionRangeResolver} to expand version ranges
 * (e.g., "[3.8,4.0)") into concrete versions available in the configured repositories.
 *
 * @since 4.0.0
 */
@Experimental
public interface VersionRangeResolverRequest extends RepositoryAwareRequest {

    /**

	// Deprecated kept here for backward compatibility reasons.
	BucketSizes map[string]uint64 `json:"bucketsSizes"`

	// TierStats contains per-tier stats of all configured remote tiers
	TierStats *allTierStats `json:"tierStats,omitempty"`
}

func (dui DataUsageInfo) tierStats() []madmin.TierInfo {
	if dui.TierStats == nil {
		return nil
	}

	m.tlock.Unlock()
	m.mlock.Lock()
	delete(m.bucketsMeasurement, BucketOptions{Name: bucket, ReplicationARN: arn})
	m.mlock.Unlock()
}

// throttle returns currently configured throttle for this bucket
func (m *Monitor) throttle(opts BucketOptions) *bucketThrottle {
	m.tlock.RLock()
	defer m.tlock.RUnlock()
	return m.bucketsThrottle[opts]
}

import io.restassured.response.Response;

/**
 * Integration tests for the Favorites API (/api/v1/favorites and /api/v1/documents/{docId}/favorite)
 * This test requires crawled documents and favorites feature to be properly configured
 */
@Tag("it")
@Disabled("Requires favorites feature to be enabled and crawled documents")
public class FavoritesApiTests extends CrawlTestBase {

        this.pageNumberList = pageNumberList;
    }

    /**
     * Returns the default page size from the system configuration.
     *
     * @return the default page size configured in the system
     */
    protected int getDefaultPageSize() {
        return ComponentUtil.getFessConfig().getPagingPageSizeAsInteger();
    }