// Post Policy related
	AmzMetaUUID = "X-Amz-Meta-Uuid"
	AmzMetaName = "X-Amz-Meta-Name"

	// Delete special flag to force delete a bucket or a prefix
	MinIOForceDelete = "x-minio-force-delete"

	// Create special flag to force create a bucket
	MinIOForceCreate = "x-minio-force-create"

	// Header indicates if the mtime should be preserved by client
	MinIOSourceMTime = "x-minio-source-mtime"

	token string

	// Role ARN to use
	roleArn string

	// Display credentials flag
	displayCreds bool

	// Credential expiry duration
	expiryDuration time.Duration

	// Bucket to list
	bucketToList string
)

func init() {
	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")

":0,"objectsReplicationIn":null,"bucketsCount":1,"bucket multisitea/data/disterasure/xl6/.minio.sys/buckets/bucket/.metadata.bin/xl.meta XL2 Æ } Ä$•Ä Ó É Ñ©XÈÄ Í#| Å Qƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ­„ï P L;»ô5,éº ¡¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ iªPartASizes‘Ñ i¤SizeÑ i¥MTimeÓ É Ñ©XȧMetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ 929f74acf4e3cc5de554¬content-type¸application/octet-stream¡v Î Ü­ ¤nullćHæ5·L¦ fi;~W´goú¹ªŒ€. ÀÐ8£+ŸŸÞ1...

    private boolean isRecoverableError(Exception error) {
        // Timeout errors are often recoverable
        if (error instanceof SocketTimeoutException) {
            return true;
        }

        // Some socket errors might be recoverable
        if (error instanceof SocketException) {
            String message = error.getMessage();
            if (message != null) {
                message = message.toLowerCase();

	"encoding/hex"
	"errors"
	"io"
	"mime"
	"net/http"
	"net/url"
	"strconv"
	"strings"
	"sync/atomic"
	"time"

	"github.com/minio/minio/internal/auth"
	objectlock "github.com/minio/minio/internal/bucket/object/lock"
	"github.com/minio/minio/internal/etag"
	"github.com/minio/minio/internal/hash"
	xhttp "github.com/minio/minio/internal/http"
	xjwt "github.com/minio/minio/internal/jwt"
	"github.com/minio/minio/internal/logger"

    display-name: "elastic / elasticsearch # %BRANCH% - release tests"
    description: "Release version tests for the Elasticsearch %BRANCH% branch.\n"
    node: "general-purpose && docker"
    builders:
      - inject:
          properties-file: '.ci/java-versions.properties'
          properties-content: |
            JAVA_HOME=$HOME/.java/$ES_BUILD_JAVA

        log.info("Setting up Samba container for SMB integration tests");

        // Check if Docker is available
        assumeTrue(isDockerAvailable(), "Docker is not available - skipping integration tests");
        assumeTrue(sambaContainer != null, "Container not initialized - Docker not available");

        // Create temporary directory structure for SMB shares

)

// ExcludedPrefix - holds individual prefixes excluded from being versioned.
type ExcludedPrefix struct {
	Prefix string
}

// Versioning - Configuration for bucket versioning.
type Versioning struct {
	XMLNS   string   `xml:"xmlns,attr,omitempty"`
	XMLName xml.Name `xml:"VersioningConfiguration"`
	// MFADelete State    `xml:"MFADelete,omitempty"` // not supported yet.

		}
	}

	var apiString string
	if entry.API != nil {
		apiString = "API: " + entry.API.Name
		if entry.API.Args != nil {
			args := ""
			if entry.API.Args.Bucket != "" {
				args = args + "bucket=" + entry.API.Args.Bucket
			}
			if entry.API.Args.Object != "" {
				args = args + ", object=" + entry.API.Args.Object
			}
			if entry.API.Args.VersionID != "" {

    public static ElasticsearchDistributionType DEB = new DebElasticsearchDistributionType();
    public static ElasticsearchDistributionType RPM = new RpmElasticsearchDistributionType();
    public static ElasticsearchDistributionType DOCKER = new DockerElasticsearchDistributionType();
    public static ElasticsearchDistributionType DOCKER_UBI = new DockerUbiElasticsearchDistributionType();