Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add coordinator MEMORY_BYTES sensor for reads #1452

Draft
wants to merge 56 commits into
base: main
Choose a base branch
from
Draft
Changes from 1 commit
Commits
Show all changes
56 commits
Select commit Hold shift + click to select a range
54b3b28
CNDB-8501 Propagate request sensors via native CQL custom payload
aymkhalil Sep 21, 2024
7613307
Propagate READ_BYTES only
aymkhalil Oct 2, 2024
c755d86
Merge branch 'main' into cndb-8501
aymkhalil Oct 8, 2024
ee9566e
Add WRITE_BYTES and customize header prefix
aymkhalil Oct 15, 2024
8bf72a9
Fix typo
aymkhalil Oct 15, 2024
1e3092a
Fix CounterMutationCallbackTest
aymkhalil Oct 15, 2024
55454d9
Track replica sensors in ResponseVerbHandler + refactor custom sensor…
aymkhalil Oct 18, 2024
f8a1fc6
Add ReplicaSensorsTrackedTest unit tests, more tests in SensorsTest d…
aymkhalil Oct 18, 2024
7c19ca5
Fix CounterMutationCallbackTest
aymkhalil Oct 18, 2024
2373ede
Cleanup
aymkhalil Oct 21, 2024
1311836
Remove unnecessary instanceof check
aymkhalil Oct 21, 2024
78ef0b5
SensorEncoder java docs
aymkhalil Oct 21, 2024
42a41f2
Address generic feedback (javadocs, code style, leftovers, class pack…
aymkhalil Oct 23, 2024
31dfa8f
Add SensorEncoder interface
aymkhalil Oct 23, 2024
fe0628b
table -> global everywhere
aymkhalil Oct 23, 2024
7a9c72f
Register sensors before the mutate call
aymkhalil Oct 23, 2024
42b8ebf
Add to instead of replacing custom payload
aymkhalil Oct 24, 2024
0a9b1c9
Avpid copying customPayload map for now
aymkhalil Oct 24, 2024
32ee16e
Refactor RequestSensorsFactory to SensorsFactory
aymkhalil Nov 6, 2024
034183f
SensorsCustomParams java docs
aymkhalil Nov 6, 2024
d39b40a
Propagate CAS sensors
aymkhalil Nov 7, 2024
bd952b4
Propagate batch insert sensors
aymkhalil Nov 7, 2024
dfafba6
Propagate range query sensors
aymkhalil Nov 7, 2024
b9b4f53
Refactor SensorsTest dtest
aymkhalil Nov 7, 2024
e01c266
Minor types + refactoring of raw type usages
aymkhalil Nov 8, 2024
26b8500
Merge branch 'main' into cndb-8501
aymkhalil Nov 8, 2024
f137fa4
Fix race condition when RequestCallback signals completion before sen…
aymkhalil Nov 13, 2024
f9c7af5
Update SensorsFactory#createRequestSensors to accept array of keyspac…
aymkhalil Nov 13, 2024
833fd89
Decouple WriteCallbackInfo#shouldHint from mutation nullability & int…
aymkhalil Nov 13, 2024
0b74852
erge branch 'main' into cndb-8501
aymkhalil Nov 14, 2024
6287335
Add Counter mutation dtest
aymkhalil Nov 14, 2024
d4a3d6e
Fix Invalid test class 'org.apache.cassandra.distributed.test.sensors…
aymkhalil Nov 14, 2024
35ba7ce
Squash AbstractSensorsTest & SensorsTest into one class
aymkhalil Nov 14, 2024
bc11b24
Rename REQUEST_SENSORS_VIA_NATIVE_PROTOCOL -> REQUEST_VIA_NATIVE_PROT…
aymkhalil Dec 2, 2024
0bc81cd
Fix typos acutal -> actual
aymkhalil Dec 2, 2024
b752ae8
Collect unique contexts from batch statements for adding sensors
aymkhalil Dec 2, 2024
e082a6f
Don't inline if for readability
aymkhalil Dec 2, 2024
118d27c
Reuse addSensorsToInternodeResponse in CounterMutationCallback
aymkhalil Dec 2, 2024
d9d70c0
Refactor RequestCallbacks#getIMutaiton to iMutation()
aymkhalil Dec 2, 2024
e4e18fc
Fix ActiveSensorsFactory javadocs
aymkhalil Dec 2, 2024
a77b5e6
Switch from ByteBuffer.allocate to ByteBuffer.wrap to spare some memo…
aymkhalil Dec 2, 2024
425d27b
Fix SensorsFactory javadocs
aymkhalil Dec 2, 2024
be77507
Fix SensorsCustomParams javadocs
aymkhalil Dec 2, 2024
b4b0076
Remove leading li tag spaces in SensorsFactory
aymkhalil Dec 2, 2024
6682ba8
Remove extra colon in StorageProxy
aymkhalil Dec 2, 2024
670f755
Better methods names in ReplicaSensorsTrackingTest
aymkhalil Dec 2, 2024
795d089
Merge branch 'main' into cndb-8501
aymkhalil Dec 2, 2024
98c0731
Refactor SensorEncoder methods to return optional & have better names
aymkhalil Dec 3, 2024
ff97dec
CNDB-11544 Add coordinator MEMORY_BYTES sensor for reads
aymkhalil Dec 4, 2024
e65faa9
Add coordinator INTERNODE_BYTES sensor for reads
aymkhalil Dec 5, 2024
4123198
Sync sensors on finally blocks
aymkhalil Dec 6, 2024
050ea94
Revert "Add coordinator INTERNODE_BYTES sensor for reads"
aymkhalil Dec 10, 2024
9f345e8
Add dtest for read
aymkhalil Dec 10, 2024
bc05df7
MEMORY_BYTES -> IN_MEMORY_BYTES
aymkhalil Dec 11, 2024
c56d960
Fix testSensorsTrackedForReadCallback by creating concrete DataResponse
aymkhalil Dec 11, 2024
cfc8278
Fix NPE when calling message#serializedSize
aymkhalil Dec 11, 2024
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
Next Next commit
Fix CounterMutationCallbackTest
  • Loading branch information
aymkhalil committed Oct 18, 2024
commit 7c19ca596ed314a8211240a4aaf4044cc3f2283a
Original file line number Diff line number Diff line change
Expand Up @@ -172,12 +172,12 @@ public void testCounterMutationCallback()
double actual = SensorsCustomParams.sensorValueFromBytes(v);
assertThat(actual).isEqualTo(COUNTER_MUTATION_WRITE_BYTES * expectedSensorValueMultiplier);
});
assertThat(customParam).hasEntrySatisfying("INTERNODE_MSG_BYTES_REQUEST.Counter",
assertThat(customParam).hasEntrySatisfying("INTERNODE_BYTES_REQUEST.Counter",
v -> {
double actual = SensorsCustomParams.sensorValueFromBytes(v);
assertThat(actual).isEqualTo(COUNTER_MUTATION_INTERNODE_BYTES * expectedSensorValueMultiplier);
});
assertThat(customParam).hasEntrySatisfying("INTERNODE_MSG_BYTES_TABLE.Counter",
assertThat(customParam).hasEntrySatisfying("INTERNODE_BYTES_TABLE.Counter",
v -> {
double actual = SensorsCustomParams.sensorValueFromBytes(v);
assertThat(actual).isEqualTo(COUNTER_MUTATION_INTERNODE_BYTES * expectedSensorValueMultiplier);
Expand Down