Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 70 for shallow (0.19 sec)

  1. cmd/metrics-realtime.go

    		if err != nil {
    			m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (loadStat)", byHostName, err.Error()))
    		} else {
    			m.Aggregated.CPU.LoadStat = loadStat
    		}
    	}
    	// Add types...
    
    	// ByHost is a shallow reference, so careful about sharing.
    	m.ByHost = map[string]madmin.Metrics{byHostName: m.Aggregated}
    	m.Hosts = append(m.Hosts, byHostName)
    
    	return m
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 10 16:28:08 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Save(Event) error
    	SendFromStore(store.Key) error
    	Close() error
    	Store() TargetStore
    }
    
    // TargetStore is a shallow version of a target.Store
    type TargetStore interface {
    	Len() int
    }
    
    // Stats is a collection of stats for multiple targets.
    type Stats struct {
    	TotalEvents        int64 // Deprecated
    	EventsSkipped      int64
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  3. internal/handlers/forwarder.go

    		},
    	}}
    }
    
    // ServeHTTP forwards HTTP traffic using the configured transport
    func (f *Forwarder) ServeHTTP(w http.ResponseWriter, inReq *http.Request) {
    	outReq := new(http.Request)
    	*outReq = *inReq // includes shallow copies of maps, but we handle this in Director
    
    	revproxy := httputil.ReverseProxy{
    		Director: func(req *http.Request) {
    			f.modifyRequest(req, inReq.URL)
    		},
    		BufferPool:    newBufPool(128 << 10),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 07 05:42:10 GMT 2023
    - 5.6K bytes
    - Viewed (0)
  4. cmd/acl-handlers.go

    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	// Allow putBucketACL if policy action is set, since this is a dummy call
    	// we are simply re-purposing the bucketPolicyAction.
    	if s3Error := checkRequestAuthType(ctx, r, policy.PutBucketPolicyAction, bucket, ""); s3Error != ErrNone {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 8.4K bytes
    - Viewed (0)
  5. cmd/signature-v4-utils.go

    	case emptySHA256:
    		// some broken clients set empty-sha256
    		// with > 0 content-length in the body,
    		// we should skip such clients and allow
    		// blindly such insecure clients only if
    		// S3 strict compatibility is disabled.
    
    		// We return true only in situations when
    		// deployment has asked MinIO to allow for
    		// such broken clients and content-length > 0.
    		return r.ContentLength > 0 && !globalServerCtxt.StrictS3Compat
    	}
    	return false
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  6. docs/debugging/xattr/main.go

    	data := make([]byte, 8)
    	binary.LittleEndian.PutUint64(data, value)
    	return xattr.LSet(path, name, data)
    }
    
    func main() {
    	flag.StringVar(&path, "path", "", "path name where the attribute shall be applied")
    	flag.StringVar(&name, "name", "", "attribute name or it can be a wildcard if '.' is specified")
    	flag.Uint64Var(&value, "value", 0, "attribute value expects the value to be uint64")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 29 23:52:41 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  7. helm/minio/templates/_helper_create_svcacct.txt

    MINIO_ACCESSKEY_SECRETKEY_TMP="/tmp/accessKey_and_secretKey_svcacct_tmp"
    
    # connectToMinio
    # Use a check-sleep-check loop to wait for MinIO service to be available
    connectToMinio() {
      SCHEME=$1
      ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts
      set -e ; # fail if we can't read the keys.
      ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ;
      set +e ; # The connections to minio are allowed to fail.
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 23:20:50 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  8. docs/hotfixes.md

    ## Creating a hotfix branch
    
    Customers in MinIO are allowed LTS on any release they choose to standardize. Production setups seldom change and require maintenance. Hotfix branches are such maintenance branches that allow customers to operate a production cluster without drastic changes to their deployment.
    
    ## Backporting a fix
    
    Developer is advised to clone the MinIO source and checkout the MinIO release tag customer is currently on.
    
    ```
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  9. docs/metrics/prometheus/README.md

    ### 2. Configure authentication type for Prometheus metrics
    
    MinIO supports two authentication modes for Prometheus either `jwt` or `public`, by default MinIO runs in `jwt` mode. To allow public access without authentication for prometheus metrics set environment as follows.
    
    ```
    export MINIO_PROMETHEUS_AUTH_TYPE="public"
    minio server ~/test
    ```
    
    ### 3. Configuring Prometheus
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  10. internal/event/target/webhook.go

    		manager, err := certs.NewManager(context.Background(), args.ClientCert, args.ClientKey, tls.LoadX509KeyPair)
    		if err != nil {
    			return err
    		}
    		manager.ReloadOnSignal(syscall.SIGHUP) // allow reloads upon SIGHUP
    		transport.TLSClientConfig.GetClientCertificate = manager.GetClientCertificate
    	}
    	target.httpClient = &http.Client{Transport: transport}
    
    	yes, err := target.isActive()
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
Back to top