Method removeObjectsSingle

api-remove.go:665–692

removeObjectsSingle deletes objects one by one using single DELETE requests. This is used for endpoints that do not support multi-object delete (e.g., GCS).

(ctx context.Context, bucketName string, objectsCh <-chan ObjectInfo, resultCh chan<- RemoveObjectResult, opts RemoveObjectsOptions)

// removeObjectsSingle deletes objects one by one using single DELETE requests.
// This is used for endpoints that do not support multi-object delete (e.g., GCS).
func (c *Client) removeObjectsSingle(ctx context.Context, bucketName string, objectsCh <-chan ObjectInfo, resultCh chan<- RemoveObjectResult, opts RemoveObjectsOptions) {
	for {
		select {
		case <-ctx.Done():
			return
		case object, ok := <-objectsCh:
			if !ok {
				return
			}
			removeResult := c.removeObject(ctx, bucketName, object.Key, RemoveObjectOptions{
				VersionID:        object.VersionID,
				GovernanceBypass: opts.GovernanceBypass,
			})
			if err := removeResult.Err; err != nil {
				// Version/object does not exist is not an error, ignore and continue.
				switch ToErrorResponse(err).Code {
				case NoSuchVersion, NoSuchKey:
					continue
				}
			}
			select {
			case <-ctx.Done():
				return
			case resultCh <- removeResult:
			}
		}
	}
}

// removeObjectsSingleIter deletes objects one by one using single DELETE requests.
// This is used for endpoints that do not support multi-object delete (e.g., GCS).