- **Google Site Search (GSS) / Google Custom Search (CSE)** - JavaScript replacement
- **Elasticsearch / OpenSearch** - Direct data migration via bulk APIs
- **Apache Solr** - Document import via REST API
- **Database Systems** - Direct connection via DataStore plugins
- **File Systems** - SMB, FTP, local file crawling
- **Custom Systems** - REST API for bulk document indexing

---

## Pre-Migration Planning

- `volatile` for status flags
- Synchronized blocks for critical sections
- Thread-local storage via `CrawlingParameterUtil`

**Resource Management**:
- `AutoCloseable` throughout
- `DeferredFileOutputStream` for large responses (temp files for >1MB)
- Connection pooling with limits
- Background temp file deletion via `FileUtil.deleteInBackground()`

**Fault Tolerance**:
- `FaultTolerantClient` wrapper (retry, circuit breaker)

        // Absent key -> CIFSException
        CIFSException noKey = assertThrows(CIFSException.class, session::getSessionKey);
        assertTrue(noKey.getMessage().contains("No session key"));

        // Set a key via reflection and verify retrieval
        byte[] key = new byte[] { 1, 2, 3, 4 };
        setField(session, "sessionKey", key);
        assertArrayEquals(key, session.getSessionKey());
    }

    @Test

    enum SubjectVariant {
        DEFAULT_NO_PS, // configuration null, no preset Subject
        DEFAULT_WITH_PS, // configuration null, but super.getSubject() returns non-null
        WITH_CONFIG // configuration provided via StaticJAASConfiguration
    }

    private JAASAuthenticator buildAuthenticator(SubjectVariant variant) {
        switch (variant) {
        case DEFAULT_WITH_PS: {
            JAASAuthenticator a = new JAASAuthenticator();

                                     readRegion.getSize());
            
            // Send request header via RDMA send
            sendWithRdmaSendReceive(request);
            
            // Wait for server to write data directly to our buffer via RDMA
            // No additional receive needed - data written directly to memory
            
            // Create response with data from RDMA buffer

        assertEquals(domain, domCap.getValue());
        assertEquals(rn, rnCap.getValue());
    }

    // Edge case: test with empty name
    @Test
    @DisplayName("getDfsReferrals handles empty name via CIFSException")
    void getDfsReferrals_emptyName() throws Exception {
        String emptyName = "";
        doThrow(new jcifs.CIFSException("invalid dfs name")).when(transport)

                // Initialize response chain (also for chained query)
                Smb2CreateResponse cr = create.initResponse(cifsContext);

                // Access chained Smb2QueryDirectoryRequest via reflection
                Smb2QueryDirectoryRequest q = (Smb2QueryDirectoryRequest) getNextOf(create);

                // Provide a query response with two entries

final class TopKSelector<
    T extends @Nullable Object> {

  /**
   * Returns a {@code TopKSelector} that collects the lowest {@code k} elements added to it,
   * relative to the natural ordering of the elements, and returns them via {@link #topK} in
   * ascending order.
   *
   * @throws IllegalArgumentException if {@code k < 0} or {@code k > Integer.MAX_VALUE / 2}
   */
  public static <T extends Comparable<? super T>> TopKSelector<T> least(int k) {

    }

    @Test
    public void test_ProtectedConstructor() throws Exception {
        // ## Test that protected constructor can be accessed via reflection ##

        // ## Act ##
        final Constructor<Curl> constructor = Curl.class.getDeclaredConstructor();
        constructor.setAccessible(true);
        final Curl instance = constructor.newInstance();

        // SMB2 negotiation never exposes key via this API
        setField(transport, "negotiated", new Smb2NegotiateResponse(cfg));
        assertNull(transport.getServerEncryptionKey());
    }

    @Test
    @DisplayName("Signing enforced/optional adhere to flags and negotiation")
    void signingModes() throws Exception {
        // Enforced via constructor flag -> optional false, enforced true regardless of negotiation