- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 114 for nide (0.14 sec)
-
cmd/bucket-object-lock.go
} } return false } // enforceRetentionBypassForDelete enforces whether an existing object under governance can be deleted // with governance bypass headers set in the request. // Objects under site wide WORM can never be overwritten. // For objects in "Governance" mode, overwrite is allowed if a) object retention date is past OR // governance bypass headers are set and user has governance bypass permissions.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/storage-rest-server.go
// An optional error can be sent which will be picked as text only error, // without its original type by the receiver. // waitForHTTPResponse should be used to the receiving side. func keepHTTPReqResponseAlive(w http.ResponseWriter, r *http.Request) (resp func(error), body io.ReadCloser) { bodyDoneCh := make(chan struct{}) doneCh := make(chan error) ctx := r.Context() go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/dsync/lock-args.go
UID string // Resources contains single or multiple entries to be locked/unlocked. Resources []string // Source contains the line number, function and file name of the code // on the client node that requested the lock. Source string // Owner represents unique ID for this instance, an owner who originally requested // the locked resource, useful primarily in figuring out stale locks. Owner string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/tier.go
t.requestsCount[tier] = stat } var ( // {minio_node}_{tier}_{ttlb_seconds_distribution} tierTTLBMD = MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: tierSubsystem, Name: ttlbDistribution, Help: "Distribution of time to last byte for objects downloaded from warm tier", Type: gaugeMetric, } // {minio_node}_{tier}_{requests_success} tierRequestsSuccessMD = MetricDescription{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } q := r.Form node := q.Get("node") keepAliveTicker := time.NewTicker(500 * time.Millisecond) defer keepAliveTicker.Stop() mrfCh, err := globalNotificationSys.GetReplicationMRF(ctx, bucket, node) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/metrics-v3-cluster-health.go
"Count of offline nodes in the cluster") healthNodesOnlineCountMD = NewGaugeMD(healthNodesOnlineCount, "Count of online nodes in the cluster") ) // loadClusterHealthNodeMetrics - `MetricsLoaderFn` for cluster health node // metrics. func loadClusterHealthNodeMetrics(ctx context.Context, m MetricValues, c *metricsCache, ) error { nodesUpDown, _ := c.nodesUpDown.Get() m.Set(healthNodesOfflineCount, float64(nodesUpDown.Offline))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/crypto/sse.go
type Type interface { fmt.Stringer IsRequested(http.Header) bool IsEncrypted(map[string]string) bool } // IsRequested returns true and the SSE Type if the HTTP headers // indicate that some form server-side encryption is requested. // // If no SSE headers are present then IsRequested returns false // and no Type. func IsRequested(h http.Header) (Type, bool) { switch { case S3.IsRequested(h): return S3, true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 4.4K bytes - Viewed (0) -
cmd/encryption-v1.go
errInvalidSSEParameters = errors.New("The SSE-C key for key-rotation is not correct") // special access denied errKMSNotConfigured = errors.New("KMS not configured for a server side encrypted objects") errKMSKeyNotFound = errors.New("Unknown KMS key ID") errKMSDefaultKeyAlreadyConfigured = errors.New("A default encryption already exists on KMS") // Additional MinIO errors for SSE-C requests.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 16 18:28:30 GMT 2022 - 6.1K bytes - Viewed (0) -
cmd/iam-store.go
// response to a notification (i.e. isFromNotification = true), it skips the // validation of policy usage and the attempt to delete in the backend as well // (as this is already done by the notifying node). func (store *IAMStoreSys) DeletePolicy(ctx context.Context, policy string, isFromNotification bool) error { if policy == "" { return errInvalidArgument } cache := store.lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2)