Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 497 for packet (0.06 seconds)

  1. docs/distributed/decom-compressed-sse-s3.sh

    ret=$?
    if [ $ret -ne 0 ]; then
    	echo "BUG: expected no missing entries after decommission: $out"
    	exit 1
    fi
    
    ./s3-check-md5 -versions -access-key minioadmin -secret-key minioadmin -endpoint http://127.0.0.1:9001/ -bucket versioned
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon May 27 19:17:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  2. cmd/xl-storage-format-utils_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"slices"
    	"sort"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func Test_hashDeterministicString(t *testing.T) {
    	tests := []struct {
    		name string
    		arg  map[string]string
    	}{
    		{
    			name: "zero",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  3. internal/http/server.go

    }
    
    // UseCustomLogger use customized logger for this HTTP *Server
    func (srv *Server) UseCustomLogger(l *log.Logger) *Server {
    	srv.ErrorLog = l
    	return srv
    }
    
    // UseTCPOptions use custom TCP options on raw socket
    func (srv *Server) UseTCPOptions(opts TCPOptions) *Server {
    	srv.TCPOptions = opts
    	return srv
    }
    
    // NewServer - creates new HTTP server using given arguments.
    func NewServer(addrs []string) *Server {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  4. internal/logger/help.go

    			Key:         KafkaBrokers,
    			Description: "comma separated list of Kafka broker addresses",
    			Type:        "csv",
    		},
    		config.HelpKV{
    			Key:         KafkaTopic,
    			Description: "Kafka topic used for bucket notifications",
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         KafkaSASLUsername,
    			Description: "username for SASL/PLAIN or SASL/SCRAM authentication",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Sep 11 22:20:42 GMT 2024
    - 7.4K bytes
    - Click Count (0)
  5. internal/grid/handlers.go

    	// There is flow control in both directions.
    	StreamHandler struct {
    		// Handle an incoming request. Initial payload is sent.
    		// Additional input packets (if any) are streamed to request.
    		// Upstream will block when request channel is full.
    		// Response packets can be sent at any time.
    		// Any non-nil error sent as response means no more responses are sent.
    		Handle StreamHandlerFn
    
    		// Subroute for handler.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  6. docs/sts/README.md

    ```
    
    This will open the login page of keycloak, upon successful login, STS credentials along with any buckets discovered using the credentials will be printed on the screen, for example:
    
    ```
    {
      "buckets": [
        "bucket-x"
      ],
      "credentials": {
        "AccessKeyID": "6N2BALX7ELO827DXS3GK",
        "SecretAccessKey": "23JKqAD+um8ObHqzfIh+bfqwG9V8qs9tFY6MqeFR+xxx",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  7. cmd/format-erasure.go

    }
    
    // Represents the V2 backend disk structure version
    // under `.minio.sys` and actual data namespace.
    // formatErasureV2 - structure holds format config version '2'.
    // The V2 format to support "large bucket" support where a bucket
    // can span multiple erasure sets.
    type formatErasureV2 struct {
    	formatMetaV1
    	Erasure struct {
    		Version string `json:"version"` // Version of 'xl' format.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  8. internal/grid/muxclient.go

    	}
    	m.addResponse(Response{Err: &err})
    }
    
    func (m *muxClient) ack(seq uint32) {
    	if !m.checkSeq(seq) {
    		return
    	}
    	if m.acked || m.outBlock == nil {
    		return
    	}
    	available := cap(m.outBlock)
    	for range available {
    		m.outBlock <- struct{}{}
    	}
    	m.acked = true
    }
    
    func (m *muxClient) unblockSend(seq uint32) {
    	if !m.checkSeq(seq) {
    		return
    	}
    	select {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  9. internal/s3select/select_test.go

    		},
    		{
    			name:       "indexed-list-square-bracket",
    			query:      `SELECT * from s3object s WHERE [7,8.5,9] = s.nested[1]`,
    			wantResult: `{"id":3,"title":"Second Record","desc":"another text","nested":[[2,3,4],[7,8.5,9]]}`,
    		},
    		{
    			name:       "indexed-list-square-bracket",
    			query:      `SELECT * from s3object s WHERE [7,8.5,9] IN s.nested`,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 76.1K bytes
    - Click Count (0)
  10. docs/sts/keycloak.md

    ```
    
    This will open the login page of keycloak, upon successful login, STS credentials along with any buckets discovered using the credentials will be printed on the screen, for example:
    
    ```
    {
      "buckets": [
        "bucket-x"
      ],
      "credentials": {
        "AccessKeyID": "6N2BALX7ELO827DXS3GK",
        "SecretAccessKey": "23JKqAD+um8ObHqzfIh+bfqwG9V8qs9tFY6MqeFR+xxx",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.1K bytes
    - Click Count (0)
Back to Top