Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 194 for delegate (0.18 sec)

  1. cmd/storage-datatypes.go

    	SuccessorModTime time.Time `msg:"smt"`
    
    	Fresh bool `msg:"fr"` // indicates this is a first time call to write FileInfo.
    
    	// Position of this version or object in a multi-object delete call,
    	// no other caller must set this value other than multi-object delete call.
    	// usage in other calls in undefined please avoid.
    	Idx int `msg:"i"`
    
    	// Combined checksum when object was uploaded.
    	Checksum []byte `msg:"cs,allownil"`
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom.go

    			// if all versions were decommissioned, then we can delete the object versions.
    			if decommissioned == len(fivs.Versions) {
    				stopFn := globalDecommissionMetrics.log(decomMetricDecommissionRemoveObject, idx, bi.Name, entry.name)
    				_, err := set.DeleteObject(ctx,
    					bi.Name,
    					encodeDirObject(entry.name),
    					ObjectOptions{
    						DeletePrefix:       true, // use prefix delete to delete all versions at once.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  3. cmd/tier.go

    			return nil
    		}
    		return err
    	}
    	if inuse, err := d.InUse(ctx); err != nil {
    		return err
    	} else if inuse {
    		return errTierBackendNotEmpty
    	}
    	config.Lock()
    	delete(config.Tiers, tier)
    	delete(config.drivercache, tier)
    	config.Unlock()
    	return nil
    }
    
    // Verify verifies if tier's config is valid by performing all supported
    // operations on the corresponding warmbackend.
    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)
  4. internal/event/target/postgresql.go

    	psqlUpdateRow = `INSERT INTO %s (key, value) VALUES ($1, $2) ON CONFLICT (key) DO UPDATE SET value = EXCLUDED.value;`
    	psqlDeleteRow = `DELETE FROM %s WHERE key = $1;`
    	psqlInsertRow = `INSERT INTO %s (event_time, event_data) VALUES ($1, $2);`
    )
    
    // Postgres constants
    const (
    	PostgresFormat             = "format"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  5. cmd/api-response.go

    		if equals(k, xhttp.AmzMetaUnencryptedContentLength, xhttp.AmzMetaUnencryptedContentMD5) {
    			toRemove = append(toRemove, k)
    			continue
    		}
    	}
    
    	for _, k := range toRemove {
    		delete(m, k)
    		delete(m, strings.ToLower(k))
    	}
    
    	return m
    }
    
    // generates an ListBucketVersions response for the said bucket with other enumerated options.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  6. cmd/handler-utils.go

    		} else {
    			// Trimmed content encoding is empty when the header
    			// value is set to "aws-chunked" only.
    
    			// Make sure to delete the content-encoding parameter
    			// for a streaming signature which is set to value
    			// for example: "aws-chunked"
    			delete(metadata, strings.ToLower(xhttp.ContentEncoding))
    		}
    	}
    
    	// Success.
    	return metadata, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  7. cmd/bucket-lifecycle.go

    		// remote object
    		opts.SkipFreeVersion = true
    	} else {
    		transitionLogIf(ctx, err)
    	}
    
    	// Now, delete object from hot-tier namespace
    	if _, err := objectAPI.DeleteObject(ctx, oi.Bucket, oi.Name, opts); err != nil {
    		return err
    	}
    
    	// Send audit for the lifecycle delete operation
    	defer auditLogLifecycle(ctx, *oi, ILMExpiry, tags, traceFn)
    
    	eventName := event.ObjectRemovedDelete
    	if oi.DeleteMarker {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. cmd/metacache-server-pool.go

    			return
    		}
    		objInfo := fi.ToObjectInfo(o.Bucket, obj.name, versioned)
    		if o.Lifecycle != nil {
    			act := evalActionFromLifecycle(ctx, *o.Lifecycle, o.Retention, o.Replication.Config, objInfo).Action
    			skip = act.Delete() && !act.DeleteRestored()
    		}
    	}
    
    	fiv, err := obj.fileInfoVersions(o.Bucket)
    	if err != nil {
    		return
    	}
    
    	// Expire all versions if needed, if not attempt to queue for replication.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    	return nil
    }
    
    // DeleteFileHandler - delete a file.
    func (s *storageRESTServer) DeleteFileHandler(p *DeleteFileHandlerParams) (grid.NoPayload, *grid.RemoteErr) {
    	if !s.checkID(p.DiskID) {
    		return grid.NewNPErr(errDiskNotFound)
    	}
    	return grid.NewNPErr(s.getStorage().Delete(context.Background(), p.Volume, p.FilePath, p.Opts))
    }
    
    // DeleteVersionsErrsResp - collection of delete errors
    // for bulk version deletes
    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)
  10. cmd/storage-rest-client.go

    	}
    	err = st.Results(func(resp *ListDirResult) error {
    		entries = resp.Entries
    		return nil
    	})
    	return entries, toStorageErr(err)
    }
    
    // DeleteFile - deletes a file.
    func (client *storageRESTClient) Delete(ctx context.Context, volume string, path string, deleteOpts DeleteOptions) error {
    	_, err := storageDeleteFileRPC.Call(ctx, client.gridConn, &DeleteFileHandlerParams{
    		DiskID:   *client.diskID.Load(),
    		Volume:   volume,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
Back to top