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

Ugrade to Quarkus 3.17.5 and Java SDK 3.7.7 #123

Merged
merged 29 commits into from
Jan 17, 2025
Merged
Changes from 1 commit
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
500fbdf
Upgrade to Quarkus 3.15.1 and SDK 3.7.3
emilienbev Oct 9, 2024
b33ec8f
Update to Java SDK 3.7.4
emilienbev Oct 10, 2024
8baa417
Update readme
emilienbev Oct 11, 2024
e81b03c
Update to Quarkus 3.16.1, SDK to 3.7.5-SNAPSHOT (to change), fix segf…
emilienbev Nov 4, 2024
752d968
Fix segfaults caused by MpscArrayQueue in OrphanReporter and Threshol…
emilienbev Nov 4, 2024
3c8a654
Adjusted MpscArrayQueue processing with future SDK changes
emilienbev Nov 14, 2024
098d580
Added new processing for instances of MpscArrayQueue.
emilienbev Nov 14, 2024
eeeebfa
Merge branch 'quarkiverse:main' into main
emilienbev Nov 19, 2024
427f7eb
Additional classes registered for reflection.
emilienbev Nov 22, 2024
a8ced2d
Register BucketManager-related classes for reflection.
emilienbev Nov 25, 2024
d8a8ec8
Added reactive Readiness smallrye health check, some transaction clas…
emilienbev Dec 5, 2024
d113262
Updated Java SDK to 3.7.6, updated subtitutions and processing
emilienbev Dec 6, 2024
22db759
Ready Health check now specifies Mgmt and KV services, with a configu…
emilienbev Dec 6, 2024
4ecb7b3
Re-enable devservices in the integration test module
emilienbev Dec 6, 2024
1b513ce
Remove Management service from waitUntilReady in Health Check
emilienbev Dec 9, 2024
3f64ed9
Fix health check, which now pings GCCCP connection on each KV node di…
emilienbev Dec 10, 2024
936cd01
Run formatting
emilienbev Dec 10, 2024
6cfaed9
Add links to the Dev UI card
emilienbev Dec 11, 2024
fce8724
Add Micrometer metrics support via quarkus-micrometer
emilienbev Dec 13, 2024
93f9a6e
Added documentation
emilienbev Jan 8, 2025
6a16179
Updated README.md
emilienbev Jan 8, 2025
d40a7d6
Improved/simplified host extraction from connection string for the De…
emilienbev Jan 9, 2025
1aac1cb
Updated Netty substitutions, added CoreHttpRequest$Builder for runtim…
emilienbev Jan 9, 2025
5e12446
Cleaned up connection string util, simplified configuring metrics for…
emilienbev Jan 10, 2025
a89791f
Re-add defaults to integration-tests application.properties
emilienbev Jan 11, 2025
45ce195
Removed unnecessary dependency and cleaned up CouchbaseRecorder metri…
emilienbev Jan 16, 2025
b570585
Upgrade to SDK 3.7.7 and rework Metrics, docs.
emilienbev Jan 17, 2025
5f076d8
Update docs on configuring metrics, add license header.
emilienbev Jan 17, 2025
7b6b3f0
Update metrics-micrometer dependency
emilienbev Jan 17, 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
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.couchbase.quarkus.extension.deployment;

import com.couchbase.client.core.util.ConnectionString;
import com.couchbase.quarkus.extension.runtime.CouchbaseConfig;

import io.quarkus.deployment.IsDevelopment;
Expand Down Expand Up @@ -42,26 +43,11 @@ public CardPageBuildItem pages(CouchbaseConfig config) {
* @return The first hostname, or "localhost" by default.
*/
private String extractHostnameFromConnectionString(String connectionString) {
if (connectionString == null || connectionString.isEmpty()) {
ConnectionString connStr = ConnectionString.create(connectionString);
if (connStr.hosts().isEmpty()) {
return "localhost";
} else {
return connStr.hosts().get(0).host();
}

var hosts = connectionString;
if (hosts.startsWith("couchbase://")) {
hosts = hosts.substring("couchbase://".length());
}

var hostPorts = hosts.split(",");
if (hostPorts.length == 0) {
return "localhost";
}

var firstHostPort = hostPorts[0].trim();
int colonIndex = firstHostPort.indexOf(':');
if (colonIndex == -1) {
return firstHostPort;
}

return firstHostPort.substring(0, colonIndex);
}
}
Loading