- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for deletePits (0.46 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
client.createPit(createPITRequest, listener); } @Override public void deletePits(final DeletePitRequest deletePITRequest, final ActionListener<DeletePitResponse> listener) { client.deletePits(deletePITRequest, listener); } @Override
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 25.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
* @param deletePITRequest the delete PITs request * @param listener the response listener */ @Override public void deletePits(final DeletePitRequest deletePITRequest, final ActionListener<DeletePitResponse> listener) { client.deletePits(deletePITRequest, listener); } /** * Gets all point-in-time contexts asynchronously. *
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0) -
cmd/naughty-disk_test.go
} return d.disk.DeleteBulk(ctx, volume, paths...) } func (d *naughtyDisk) Delete(ctx context.Context, volume string, path string, deleteOpts DeleteOptions) (err error) { if err := d.calcError(); err != nil { return err } return d.disk.Delete(ctx, volume, path, deleteOpts) } func (d *naughtyDisk) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 10.1K bytes - Viewed (0) -
cmd/storage-rest-client.go
return nil }) return entries, toStorageErr(err) } // DeleteFile - deletes a file. func (client *storageRESTClient) Delete(ctx context.Context, volume string, path string, deleteOpts DeleteOptions) error { if !deleteOpts.Immediate { // add deadlines for all non-immediate purges var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout()) defer cancel() }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 08 02:38:41 UTC 2025 - 30.4K bytes - Viewed (0) -
cmd/bucket-handlers.go
if replicateDeletes { dObjects[i].ReplicationState = deleteList[i].ReplicationState() } deleteResults[dindex].delInfo = dObjects[i] continue } apiErr := toAPIError(ctx, errs[i]) deleteResults[dindex].errInfo = DeleteError{ Code: apiErr.Code, Message: apiErr.Description, Key: deleteList[i].ObjectName, VersionID: deleteList[i].VersionID, } } // Generate response
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
ctx, done, err := p.TrackDiskHealth(ctx, storageMetricDelete, volume, path) if err != nil { return err } defer done(0, &err) w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() error { return p.storage.Delete(ctx, volume, path, deleteOpts) }) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 34.5K bytes - Viewed (0) -
cmd/xl-storage.go
if err = checkPathLength(filePath); err != nil { return err } // Delete file and delete parent directory as well if it's empty. return s.deleteFile(volumeDir, filePath, deleteOpts.Recursive, deleteOpts.Immediate) } func skipAccessChecks(volume string) (ok bool) { return strings.HasPrefix(volume, minioMetaBucket) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jun 13 11:33:47 UTC 2025 - 91.7K bytes - Viewed (0)