Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 461 for Buckets (0.05 seconds)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSocketFactory.kt

     */
    package okhttp3
    
    import java.io.IOException
    import java.net.InetAddress
    import java.net.Socket
    import javax.net.SocketFactory
    
    /**
     * A [SocketFactory] that delegates calls. Sockets can be configured after creation by
     * overriding [.configureSocket].
     */
    open class DelegatingSocketFactory(
      private val delegate: SocketFactory,
    ) : SocketFactory() {
      @Throws(IOException::class)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  2. internal/crypto/sse-c.go

    // and returns the decrypted object key.
    func (s3 ssec) UnsealObjectKey(h http.Header, metadata map[string]string, bucket, object string) (key ObjectKey, err error) {
    	clientKey, err := s3.ParseHTTP(h)
    	if err != nil {
    		return key, err
    	}
    	return unsealObjectKey(clientKey[:], metadata, bucket, object)
    }
    
    // CreateMetadata encodes the sealed key into the metadata
    // and returns the modified metadata. It allocates a new
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  3. docs/extensions/s3zip/examples/minio-go/main.go

    	}
    
    	var opts minio.GetObjectOptions
    
    	// Add extract header to request:
    	opts.Set("x-minio-extract", "true")
    
    	// Download API.md from the archive
    	rd, err := s3Client.GetObject(context.Background(), "your-bucket", "path/to/file.zip/data.csv", opts)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	_, err = io.Copy(os.Stdout, rd)
    	if err != nil {
    		log.Fatalln(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Jun 14 18:04:14 GMT 2021
    - 694 bytes
    - Click Count (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingServerSocketFactory.kt

     */
    package okhttp3
    
    import java.io.IOException
    import java.net.InetAddress
    import java.net.ServerSocket
    import javax.net.ServerSocketFactory
    
    /**
     * A [ServerSocketFactory] that delegates calls. Sockets can be configured after creation by
     * overriding [.configureServerSocket].
     */
    open class DelegatingServerSocketFactory(
      private val delegate: ServerSocketFactory,
    ) : ServerSocketFactory() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/FallbackTestClientSocketFactory.kt

    package okhttp3
    
    import javax.net.ssl.SSLSocket
    import javax.net.ssl.SSLSocketFactory
    import okhttp3.FallbackTestClientSocketFactory.Companion.TLS_FALLBACK_SCSV
    
    /**
     * An SSLSocketFactory that delegates calls. Sockets created by the delegate are wrapped with ones
     * that will not accept the [TLS_FALLBACK_SCSV] cipher, thus bypassing server-side fallback
     * checks on platforms that support it. Unfortunately this wrapping will disable any
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 2K bytes
    - Click Count (0)
  6. internal/event/target/amqp.go

    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	headers := make(amqp091.Table)
    	// Add more information here as required, but be aware to not overload headers
    	headers["minio-bucket"] = eventData.S3.Bucket.Name
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  7. cmd/erasure-healing-common.go

    			// parts. This is considered an outdated disk, since
    			// it needs healing too.
    			verifyResp, verifyErr = onlineDisk.VerifyFile(ctx, bucket, object, meta)
    		default:
    			verifyResp, verifyErr = onlineDisk.CheckParts(ctx, bucket, object, meta)
    		}
    
    		for p := range latestMeta.Parts {
    			if verifyErr != nil {
    				dataErrsByPart[p][i] = convPartErrToInt(verifyErr)
    			} else {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  8. PULL_REQUESTS_ETIQUETTE.md

    A strong MinIO PR:
    - Delivers a complete, valuable change (feature, bug fix, or improvement).
    - Has a concise title (e.g., `[S3] Fix bucket policy parsing #1234`) and a summary with context, referencing issues (e.g., `#1234`).
    - Contains well-written, logical commits explaining *why* changes were made (e.g., “Add S3 bucket tagging support so that users can organize resources efficiently”).
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun May 25 16:32:03 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  9. cmd/handler-utils_test.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/xml"
    	"io"
    	"net/http"
    	"net/textproto"
    	"os"
    	"reflect"
    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    // Tests validate bucket LocationConstraint.
    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocketFactory.kt

    package okhttp3
    
    import java.io.IOException
    import java.net.InetAddress
    import java.net.Socket
    import javax.net.ssl.SSLSocket
    import javax.net.ssl.SSLSocketFactory
    
    /**
     * A [SSLSocketFactory] that delegates calls. Sockets can be configured after creation by
     * overriding [.configureSocket].
     */
    open class DelegatingSSLSocketFactory(
      private val delegate: SSLSocketFactory,
    ) : SSLSocketFactory() {
      @Throws(IOException::class)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.8K bytes
    - Click Count (0)
Back to Top