SMBUtil.writeInt4(chunkBytes, buffer, 4);
            SMBUtil.writeInt4(totalBytes, buffer, 8);
            return buffer;
        }
    }

    @Nested
    @DisplayName("Integration Tests")
    class IntegrationTests {

        @Test
        @DisplayName("Should maintain state after multiple decodes")
        void testMultipleDecodes() throws SMBProtocolDecodingException {

                assertEquals((byte) 0xFF, buffer1[i]);
                assertEquals((byte) 0xFF, buffer2[50 + i]);
            }
        }
    }

    @Nested
    @DisplayName("Integration Pattern Tests")
    class IntegrationPatternTests {

        @Test
        @DisplayName("Should simulate usage in Smb2CreateRequest context")
        void testSimulatedUsagePattern() {

import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;

import io.restassured.RestAssured;
import io.restassured.path.json.JsonPath;
import io.restassured.response.Response;

/**
 * Integration Tests which need an execution of crawler
 * - /api/v1/documents
 * */
@Tag("it")
public class SearchApiTests extends CrawlTestBase {
    private static final Logger logger = LogManager.getLogger(SearchApiTests.class);

![cloud-native](https://github.com/minio/minio/blob/master/docs/bigdata/images/image1.png?raw=true "cloud native architecture")

Kubernetes manages stateless Spark and Hive containers elastically on the compute nodes. Spark has native scheduler integration with Kubernetes. Hive, for legacy reasons, uses YARN scheduler on top of Kubernetes.

            resultField.set(bindWithParams, 0);
            assertNull(bindWithParams.getResult(), "Should return null when result is 0");
        }
    }

    @Nested
    @DisplayName("Integration Tests")
    class IntegrationTests {

        @Test
        @DisplayName("Bind message constructor should set correct values")
        void testBindMessageConstructor() throws Exception {
            // Given

            assertNotNull(response);
            // Response should be created with same buffer and offset
        }
    }

    @Nested
    @DisplayName("Integration Tests")
    class IntegrationTests {

        @Test
        @DisplayName("Should handle complete read request workflow")
        void testCompleteReadWorkflow() {
            // Setup complete request

        assertTrue(content.contains("<meta name=\"fess:role\" content=\"admin\">"));
        assertTrue(content.contains("<meta name=\"fess:role\" content=\"user\">"));
    }

    // --- Integration-style tests ---

    @Test
    public void test_execute_fullFlow() throws IOException {
        final List<Map<String, Object>> docs = new ArrayList<>();
        final Map<String, Object> doc1 = new LinkedHashMap<>();

            // Response should be created with the same config from context
            verify(mockContext, times(1)).getConfig();
        }
    }

    @Nested
    @DisplayName("Integration Tests")
    class IntegrationTests {

        @Test
        @DisplayName("Should handle complete write request workflow")
        void testCompleteWriteWorkflow() {
            // Setup complete request

# AssumeRoleWithWebIdentity [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io)

## Introduction

MinIO supports the standard AssumeRoleWithWebIdentity STS API to enable integration with OIDC/OpenID based identity provider environments. This allows the generation of temporary credentials with pre-defined access policies for applications/users to interact with MinIO object storage.

            // Verify chunk count is zero
            assertEquals(0, SMBUtil.readInt4(buffer, startIndex + SOURCE_KEY_SIZE));
        }
    }

    @Nested
    @DisplayName("Integration Tests")
    class IntegrationTests {

        @Test
        @DisplayName("Should handle complete copy operation with multiple chunks")
        void testCompleteCopyOperation() {
            // Given