From: Yuval Lifshitz Date: Tue, 24 Feb 2026 16:12:09 +0000 (+0000) Subject: rgw/s3vectors: support S3V4 auth X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=ac09bafafa2312dc25cc607d6b9d261b3619bf4c;p=ceph.git rgw/s3vectors: support S3V4 auth Signed-off-by: Yuval Lifshitz --- diff --git a/src/rgw/rgw_rest_s3.cc b/src/rgw/rgw_rest_s3.cc index 03f857b8c0f..3f222487f2d 100644 --- a/src/rgw/rgw_rest_s3.cc +++ b/src/rgw/rgw_rest_s3.cc @@ -6654,6 +6654,22 @@ AWSGeneralAbstractor::get_auth_data_v4(const req_state* const s, case RGW_OP_POST_BUCKET_LOGGING: case RGW_OP_GET_BUCKET_LOGGING: case RGW_OP_PUT_BUCKET_OWNERSHIP_CONTROLS: + case RGW_OP_S3VECTOR_CREATE_INDEX: + case RGW_OP_S3VECTOR_CREATE_VECTOR_BUCKET: + case RGW_OP_S3VECTOR_DELETE_INDEX: + case RGW_OP_S3VECTOR_DELETE_VECTOR_BUCKET: + case RGW_OP_S3VECTOR_DELETE_VECTOR_BUCKET_POLICY: + case RGW_OP_S3VECTOR_DELETE_VECTORS: + case RGW_OP_S3VECTOR_GET_INDEX: + case RGW_OP_S3VECTOR_GET_VECTOR_BUCKET: + case RGW_OP_S3VECTOR_GET_VECTOR_BUCKET_POLICY: + case RGW_OP_S3VECTOR_GET_VECTORS: + case RGW_OP_S3VECTOR_LIST_INDEXES: + case RGW_OP_S3VECTOR_LIST_VECTOR_BUCKETS: + case RGW_OP_S3VECTOR_LIST_VECTORS: + case RGW_OP_S3VECTOR_PUT_VECTOR_BUCKET_POLICY: + case RGW_OP_S3VECTOR_PUT_VECTORS: + case RGW_OP_S3VECTOR_QUERY_VECTORS: break; default: ldpp_dout(s, 10) << "ERROR: AWS4 completion for operation: " << s->op_type << ", NOT IMPLEMENTED" << dendl; diff --git a/src/test/rgw/s3vectors/s3vector_test.py b/src/test/rgw/s3vectors/s3vector_test.py index 9144288ed78..e918a79aef3 100644 --- a/src/test/rgw/s3vectors/s3vector_test.py +++ b/src/test/rgw/s3vectors/s3vector_test.py @@ -64,7 +64,7 @@ def connection(service_name='s3vectors'): scheme = 'http://' if service_name == 's3vectors': - config = Config(signature_version='s3') + config = Config(signature_version='s3v4') else: config = None @@ -93,7 +93,7 @@ def connection2(service_name='s3vectors'): scheme = 'http://' if service_name == 's3vectors': - config = Config(signature_version='s3') + config = Config(signature_version='s3v4') else: config = None @@ -127,7 +127,7 @@ def another_user(tenant=None): endpoint_url=scheme+hostname+':'+str(port_no), aws_access_key_id=access_key, aws_secret_access_key=secret_key, - config=Config(signature_version='s3')) + config=Config(signature_version='s3v4')) return client