Skip to content
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
70 commits
Select commit Hold shift + click to select a range
c2c7dc7
progress
nehrao1 Nov 24, 2024
6600a6b
add separate endpoint
nehrao1 Dec 1, 2024
0e6d796
start
nehrao1 Dec 2, 2024
0a06791
progress
nehrao1 Dec 3, 2024
ace2685
push progress
nehrao1 Dec 16, 2024
a570c83
Update ThinClientStoreModel.java
FabianMeiswinkel Dec 16, 2024
27318e5
Skeleton for ThinClientStoreModel and RNTBD serialization
FabianMeiswinkel Dec 17, 2024
63a1816
Merge pull request #1 from FabianMeiswinkel/users/fabianm/RntbdSerial…
nehrao1 Dec 18, 2024
4733a68
fix env var
nehrao1 Dec 19, 2024
2e0672d
Adding serialization skeleton in ThinClientStoreModel
jeet1995 Dec 21, 2024
33eded2
Merge pull request #2 from jeet1995/thinclientStoreModel
nehrao1 Dec 22, 2024
b2b9b8f
progress
nehrao1 Dec 26, 2024
2ee9484
pr comments
nehrao1 Jan 6, 2025
54c6777
cleanup
nehrao1 Jan 6, 2025
7b3f273
Merge branch 'main' of https://github.com/Azure/azure-sdk-for-java in…
nehrao1 Jan 6, 2025
10f342a
changelog
nehrao1 Jan 6, 2025
2bb95f1
cleanup
nehrao1 Jan 6, 2025
e5dc25b
test
nehrao1 Jan 6, 2025
606a427
pr comments
nehrao1 Jan 10, 2025
4f0dba8
fix
nehrao1 Jan 13, 2025
7f2b881
merge main
nehrao1 Jan 13, 2025
f7ed838
Merge branch 'main' of https://github.com/Azure/azure-sdk-for-java in…
nehrao1 Jan 13, 2025
1aa70bd
changelog
nehrao1 Jan 13, 2025
e414cd5
fix test
nehrao1 Jan 13, 2025
a6cbb07
Merge branch 'thinclientAPI' into thinclientEndpointDiscovery
nehrao1 Jan 13, 2025
c74405c
progress
nehrao1 Jan 15, 2025
da31f66
progress
nehrao1 Jan 16, 2025
513bd42
merge main
nehrao1 Jan 21, 2025
8c39fca
fix
nehrao1 Jan 21, 2025
b195862
test
nehrao1 Jan 21, 2025
0e561a9
progress
nehrao1 Jan 26, 2025
f589cd4
progress
nehrao1 Jan 27, 2025
a32bf7d
progress
nehrao1 Jan 27, 2025
90071c1
progress
nehrao1 Jan 29, 2025
5f0b5e0
progress
nehrao1 Jan 31, 2025
77e6b5e
progress
nehrao1 Jan 31, 2025
fd076fa
Adding ConsolidatedLocationEndpoints to encapsulate thin proxy locati…
jeet1995 Feb 1, 2025
bf2a3b9
Adding ConsolidatedLocationEndpoints to encapsulate thin proxy locati…
jeet1995 Feb 1, 2025
93a590a
Fixing unit tests.
jeet1995 Feb 1, 2025
2d3e83e
Fixing unit tests.
jeet1995 Feb 1, 2025
d3dd778
Fixing unit tests.
jeet1995 Feb 1, 2025
089a43a
Fixing unit tests.
jeet1995 Feb 1, 2025
1558260
Fixing unit tests.
jeet1995 Feb 1, 2025
a890f7a
Remove azure-cosmos dependency.
jeet1995 Feb 1, 2025
4aafa53
Fixing unit tests.
jeet1995 Feb 1, 2025
1472a5f
Fixing unit tests.
jeet1995 Feb 2, 2025
e6540a6
Fixing CI / live tests pipeline.
jeet1995 Feb 2, 2025
d43a3b8
Fixing CI / live tests pipeline.
jeet1995 Feb 2, 2025
b18feed
fixing rntbd request
nehrao1 Feb 5, 2025
ed53372
Merge pull request #3 from jeet1995/thinclientEndpointDiscoveryRefactor
nehrao1 Feb 6, 2025
9deb80b
progress
nehrao1 Feb 6, 2025
6959d2d
fix
nehrao1 Feb 6, 2025
52ca426
fix
nehrao1 Feb 7, 2025
1002537
fix
nehrao1 Feb 11, 2025
ce8ff80
Quick fix ordering rntbd tokens
FabianMeiswinkel Feb 11, 2025
4a456ae
Changing rntbd header order
FabianMeiswinkel Feb 11, 2025
81a8866
Hack to make the dotnet-benchmark a simple repro for test against loc…
FabianMeiswinkel Feb 11, 2025
ccca04a
Iterating on quick and dirty test
FabianMeiswinkel Feb 13, 2025
5d820ca
QuickAndDirty integration for Create/Read works now
FabianMeiswinkel Feb 14, 2025
d8f916b
Merge pull request #6 from FabianMeiswinkel/users/fabianm/rntbdOrdering
nehrao1 Feb 16, 2025
9318009
merge main
nehrao1 Mar 14, 2025
9dd5907
fix merge, remove unused imports, remove whitespace
nehrao1 Mar 14, 2025
b41558c
fixes to minimize diff
nehrao1 Mar 14, 2025
2f44f73
fix build issues
nehrao1 Mar 17, 2025
e773a1e
start adding thinclient endpoints
nehrao1 Mar 18, 2025
5def354
route requests to thin client store model
nehrao1 Mar 20, 2025
ef621a5
fix issue causing encoding failure
nehrao1 Mar 24, 2025
ea75b0d
working without hardcoding RNTBD tokens
nehrao1 Apr 1, 2025
9f85a01
cleanup
nehrao1 Apr 1, 2025
823aad9
get globalDatabaseAccountName from GlobalEndpointManager
nehrao1 Apr 1, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
get globalDatabaseAccountName from GlobalEndpointManager
  • Loading branch information
nehrao1 committed Apr 1, 2025
commit 823aad96eec08c36afc766b7f39c9765674a796f
Original file line number Diff line number Diff line change
Expand Up @@ -1186,13 +1186,9 @@ public void setEffectivePartitionKey(String effectivePartitionKey) {
this.effectivePartitionKey = effectivePartitionKey;
}

public void setThinclientHeaders(String operationType, String resourceType, String regionalHost, String resourceId) {
public void setThinclientHeaders(String operationType, String resourceType, String globalDatabaseAccountName, String resourceId) {
this.headers.put(HttpConstants.HttpHeaders.THINCLIENT_PROXY_OPERATION_TYPE, operationType);
this.headers.put(HttpConstants.HttpHeaders.THINCLIENT_PROXY_RESOURCE_TYPE, resourceType);

String host = regionalHost.substring(0, regionalHost.indexOf("."));
int lastIndexOfHyphen = host.lastIndexOf("-");
String globalDatabaseAccountName = host.substring(0, lastIndexOfHyphen);
this.headers.put(HttpConstants.HttpHeaders.GLOBAL_DATABASE_ACCOUNT_NAME, globalDatabaseAccountName);
this.headers.put(WFConstants.BackendHeaders.COLLECTION_RID, resourceId);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -129,10 +129,11 @@ public StoreResponse unwrapToStoreResponse(RxDocumentServiceRequest request, int
@Override
public HttpRequest wrapInHttpRequest(RxDocumentServiceRequest request, URI requestUri) throws Exception {

String globalDatabaseAccountName = this.globalEndpointManager.getLatestDatabaseAccount().getId();
request.setThinclientHeaders(
request.getOperationType().name(),
request.getResourceType().name(),
requestUri.getHost(),
globalDatabaseAccountName,
request.getResourceId());

byte[] epk = request.getPartitionKeyInternal().getEffectivePartitionKeyBytes(request.getPartitionKeyInternal(), request.getPartitionKeyDefinition());
Expand Down
Loading