Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for applyActions (0.21 sec)

  1. cmd/data-scanner.go

    		})
    	}
    
    	return objInfos, nil
    }
    
    // applyActions will apply lifecycle checks on to a scanned item.
    // The resulting size on disk will always be returned.
    // The metadata will be compared to consensus on the object layer before any changes are applied.
    // If no metadata is supplied, -1 is returned if no action is taken.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
  2. cmd/xl-storage.go

    		var objDeleted bool
    		for _, oi := range objInfos {
    			done = globalScannerMetrics.time(scannerMetricApplyVersion)
    			var sz int64
    			objDeleted, sz = item.applyActions(ctx, objAPI, oi, &sizeS)
    			done()
    
    			// DeleteAllVersionsAction: The object and all its
    			// versions are expired and
    			// doesn't contribute toward data usage.
    			if objDeleted {
    				break
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  3. operator/cmd/mesh/shared.go

    		return nil, nil, fmt.Errorf("check minimum supported Kubernetes version: %v", err)
    	}
    	return kubeClient, client, nil
    }
    
    // applyOptions contains the startup options for applying the manifest.
    type applyOptions struct {
    	// Path to the kubeconfig file.
    	Kubeconfig string
    	// ComponentName of the kubeconfig context to use.
    	Context string
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  4. internal/bucket/encryption/bucket-sse-config.go

    			}
    		}
    	}
    
    	if config.XMLNS == "" {
    		config.XMLNS = xmlNS
    	}
    	return &config, nil
    }
    
    // ApplyOptions ask for specific features to be enabled,
    // when bucketSSEConfig is empty.
    type ApplyOptions struct {
    	AutoEncrypt bool
    }
    
    // Apply applies the SSE bucket configuration on the given HTTP headers and
    // sets the specified SSE headers.
    //
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 4.9K bytes
    - Viewed (0)
  5. operator/cmd/mesh/operator-init.go

    		l.LogAndFatal(err)
    	}
    
    	installerScope.Debugf("Installing operator charts with the following values:\n%s", vals)
    	installerScope.Debugf("Using the following manifest to install operator:\n%s\n", mstr)
    
    	opts := &applyOptions{
    		DryRun: args.DryRun,
    	}
    
    	// If CR was passed, we must create a namespace for it and install CR into it.
    	customResource, istioNamespace, err := getCRAndNamespaceFromFile(oiArgs.inFilename, l)
    	if err != nil {
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  6. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      repeated ServerAddressByClientCIDR serverAddressByClientCIDRs = 2;
    }
    
    // ApplyOptions may be provided when applying an API object.
    // FieldManager is required for apply requests.
    // ApplyOptions is equivalent to PatchOptions. It is provided as a convenience with documentation
    // that speaks specifically to how the options fields relate to apply.
    message ApplyOptions {
      // When present, indicates that modifications should not be
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 53.3K bytes
    - Viewed (0)
  7. cmd/object-handlers.go

    		return
    	}
    
    	// Check if bucket encryption is enabled
    	sseConfig, _ := globalBucketSSEConfigSys.Get(dstBucket)
    	sseConfig.Apply(r.Header, sse.ApplyOptions{
    		AutoEncrypt: globalAutoEncryption,
    	})
    
    	var srcOpts, dstOpts ObjectOptions
    	srcOpts, err = copySrcOpts(ctx, r, srcBucket, srcObject)
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 125K bytes
    - Viewed (0)
  8. cmd/object-multipart-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Check if bucket encryption is enabled
    	sseConfig, _ := globalBucketSSEConfigSys.Get(bucket)
    	sseConfig.Apply(r.Header, sse.ApplyOptions{
    		AutoEncrypt: globalAutoEncryption,
    	})
    
    	// Validate storage class metadata if present
    	if sc := r.Header.Get(xhttp.AmzStorageClass); sc != "" {
    		if !storageclass.IsValid(sc) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    	pReader := NewPutObjReader(rawReader)
    	var objectEncryptionKey crypto.ObjectKey
    
    	// Check if bucket encryption is enabled
    	sseConfig, _ := globalBucketSSEConfigSys.Get(bucket)
    	sseConfig.Apply(formValues, sse.ApplyOptions{
    		AutoEncrypt: globalAutoEncryption,
    	})
    
    	var opts ObjectOptions
    	opts, err = putOptsFromReq(ctx, r, bucket, object, metadata)
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
Back to top