Skip to content

Commit f3a8835

Browse files
committed
Update JavaDocs
1 parent b016d82 commit f3a8835

File tree

94 files changed

+238
-490
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

94 files changed

+238
-490
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@
8989
<groupId>com.fasterxml.jackson</groupId>
9090
<artifactId>jackson-bom</artifactId>
9191
<version>${jackson.version}</version>
92-
<scope>import</scope>
92+
<scope>runtime</scope>
9393
<type>pom</type>
9494
</dependency>
9595
<dependency>

src/main/java/com/datastax/astra/client/Collection.java

Lines changed: 17 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,13 @@
2020
* #L%
2121
*/
2222

23+
import com.datastax.astra.client.DataAPIOptions;
2324
import com.datastax.astra.client.exception.DataApiException;
2425
import com.datastax.astra.client.exception.DataApiFaultyResponseException;
2526
import com.datastax.astra.client.exception.TooManyDocumentsToCountException;
2627
import com.datastax.astra.client.model.Command;
2728
import com.datastax.astra.client.model.Document;
28-
import com.datastax.astra.client.model.api.ApiResponse;
29+
import com.datastax.astra.client.internal.ApiResponse;
2930
import com.datastax.astra.client.model.collections.CollectionDefinition;
3031
import com.datastax.astra.client.model.collections.CollectionOptions;
3132
import com.datastax.astra.client.model.delete.DeleteOneOptions;
@@ -50,10 +51,10 @@
5051
import com.datastax.astra.client.model.update.Update;
5152
import com.datastax.astra.client.model.update.UpdateOneOptions;
5253
import com.datastax.astra.client.model.update.UpdateResult;
53-
import com.datastax.astra.internal.AbstractCommandRunner;
54-
import com.datastax.astra.internal.http.HttpClientOptions;
55-
import com.datastax.astra.internal.utils.Assert;
56-
import com.datastax.astra.internal.utils.JsonUtils;
54+
import com.datastax.astra.client.internal.AbstractCommandRunner;
55+
import com.datastax.astra.client.internal.http.HttpClientOptions;
56+
import com.datastax.astra.client.internal.utils.Assert;
57+
import com.datastax.astra.client.internal.utils.JsonUtils;
5758
import lombok.Getter;
5859
import lombok.extern.slf4j.Slf4j;
5960

@@ -70,12 +71,12 @@
7071
import java.util.concurrent.atomic.AtomicInteger;
7172
import java.util.stream.Collectors;
7273

73-
import static com.datastax.astra.internal.utils.AnsiUtils.cyan;
74-
import static com.datastax.astra.internal.utils.AnsiUtils.green;
75-
import static com.datastax.astra.internal.utils.AnsiUtils.magenta;
76-
import static com.datastax.astra.internal.utils.AnsiUtils.yellow;
77-
import static com.datastax.astra.internal.utils.Assert.hasLength;
78-
import static com.datastax.astra.internal.utils.Assert.notNull;
74+
import static com.datastax.astra.client.internal.utils.AnsiUtils.cyan;
75+
import static com.datastax.astra.client.internal.utils.AnsiUtils.green;
76+
import static com.datastax.astra.client.internal.utils.AnsiUtils.magenta;
77+
import static com.datastax.astra.client.internal.utils.AnsiUtils.yellow;
78+
import static com.datastax.astra.client.internal.utils.Assert.hasLength;
79+
import static com.datastax.astra.client.internal.utils.Assert.notNull;
7980

8081
/**
8182
* A Data API collection, the main object to interact with the Data API, especially for DDL operations.
@@ -86,7 +87,7 @@
8687
* options to specialize the usage as vector collections or advanced indexing parameters.
8788
* </p>
8889
* <p>
89-
* A Collection is typed object designed to work both with default @{@link com.datastax.astra.client.model.Document} (wrapper for a Map) and application
90+
* A Collection is typed object designed to work both with default @{@link Document} (wrapper for a Map) and application
9091
* plain old java objects (pojo). The serialization is performed with Jackson and application beans can be annotated.
9192
* </p>
9293
* <p>Example usage:</p>
@@ -220,7 +221,7 @@ public CollectionOptions getOptions() {
220221
* Retrieves the class type of the POJO (Plain Old Java Object) used for unmarshalling documents
221222
* within the collection. This class type is crucial for converting the raw data from the collection
222223
* into more manageable, object-oriented representations. By default, this method returns the
223-
* {@link com.datastax.astra.client.model.Document} class, which serves as the standard container
224+
* {@link Document} class, which serves as the standard container
224225
* for document data. Custom implementations can override this default to utilize a different POJO
225226
* that better suits their data structure and requirements.
226227
*
@@ -664,8 +665,8 @@ public <FIELD> DistinctIterable<DOC, FIELD> distinct(String fieldName, Filter fi
664665
*
665666
* <p>
666667
* Takes in a `upperBound` option which dictates the maximum number of documents that may be present before a
667-
* {@link com.datastax.astra.client.exception.TooManyDocumentsToCountException} is thrown. If the limit is higher than the highest limit accepted by the
668-
* Data API, a {@link com.datastax.astra.client.exception.TooManyDocumentsToCountException} will be thrown anyway (i.e. `1000`).
668+
* {@link TooManyDocumentsToCountException} is thrown. If the limit is higher than the highest limit accepted by the
669+
* Data API, a {@link TooManyDocumentsToCountException} will be thrown anyway (i.e. `1000`).
669670
* </p>
670671
* <p>
671672
* Count operations are expensive: for this reason, the best practice is to provide a reasonable `upperBound`
@@ -679,7 +680,7 @@ public <FIELD> DistinctIterable<DOC, FIELD> distinct(String fieldName, Filter fi
679680
* The maximum number of documents to count.
680681
* @return
681682
* The number of documents in the collection.
682-
* @throws com.datastax.astra.client.exception.TooManyDocumentsToCountException
683+
* @throws TooManyDocumentsToCountException
683684
* If the number of documents counted exceeds the provided limit.
684685
*/
685686
public int countDocuments(int upperBound) throws TooManyDocumentsToCountException {

src/main/java/com/datastax/astra/client/DataAPIClient.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,14 +20,15 @@
2020
* #L%
2121
*/
2222

23-
import com.datastax.astra.internal.astra.AstraApiEndpoint;
24-
import com.datastax.astra.internal.utils.Assert;
23+
import com.datastax.astra.client.admin.AstraDBAdmin;
24+
import com.datastax.astra.client.internal.AstraApiEndpoint;
25+
import com.datastax.astra.client.internal.utils.Assert;
2526
import com.dtsx.astra.sdk.utils.AstraEnvironment;
2627

2728
import java.util.Optional;
2829
import java.util.UUID;
2930

30-
import static com.datastax.astra.client.AstraDBAdmin.DEFAULT_NAMESPACE;
31+
import static com.datastax.astra.client.admin.AstraDBAdmin.DEFAULT_NAMESPACE;
3132

3233
/**
3334
* Entry point to access the Data API.

src/main/java/com/datastax/astra/client/DataAPIClients.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,11 @@
2020
* #L%
2121
*/
2222

23-
import com.datastax.astra.client.observer.LoggingCommandObserver;
24-
import com.datastax.astra.internal.DataAPIDatabaseAdmin;
25-
import com.datastax.astra.internal.auth.StargateAuthenticationService;
23+
import com.datastax.astra.client.internal.observer.LoggingCommandObserver;
24+
import com.datastax.astra.client.admin.DataAPIDatabaseAdmin;
25+
import com.datastax.astra.client.internal.auth.StargateAuthenticationService;
2626

27-
import static com.datastax.astra.client.AstraDBAdmin.DEFAULT_NAMESPACE;
27+
import static com.datastax.astra.client.admin.AstraDBAdmin.DEFAULT_NAMESPACE;
2828

2929
/**
3030
* Initialization of the client in a Static way.
@@ -48,7 +48,7 @@ private DataAPIClients() {}
4848
public static DataAPIClient localClient() {
4949
return new DataAPIClient(
5050
new StargateAuthenticationService().getToken(),
51-
DataAPIOptions.builder().withDestination(DataAPIDestination.CASSANDRA).build());
51+
DataAPIOptions.builder().withDestination(DataAPIOptions.DataAPIDestination.CASSANDRA).build());
5252
}
5353

5454
/**
@@ -78,7 +78,7 @@ public static Database localDatabase() {
7878
public static DataAPIClient astra(String token) {
7979
return new DataAPIClient(token, DataAPIOptions
8080
.builder()
81-
.withDestination(DataAPIDestination.ASTRA)
81+
.withDestination(DataAPIOptions.DataAPIDestination.ASTRA)
8282
.build());
8383
}
8484

@@ -93,7 +93,7 @@ public static DataAPIClient astra(String token) {
9393
public static DataAPIClient astraDev(String token) {
9494
return new DataAPIClient(token, DataAPIOptions
9595
.builder()
96-
.withDestination(DataAPIDestination.ASTRA_DEV)
96+
.withDestination(DataAPIOptions.DataAPIDestination.ASTRA_DEV)
9797
.build());
9898
}
9999

@@ -108,7 +108,7 @@ public static DataAPIClient astraDev(String token) {
108108
public static DataAPIClient astraTest(String token) {
109109
return new DataAPIClient(token, DataAPIOptions
110110
.builder()
111-
.withDestination(DataAPIDestination.ASTRA_TEST)
111+
.withDestination(DataAPIOptions.DataAPIDestination.ASTRA_TEST)
112112
.build());
113113
}
114114

src/main/java/com/datastax/astra/client/DataAPIDestination.java

Lines changed: 0 additions & 57 deletions
This file was deleted.

src/main/java/com/datastax/astra/client/DataAPIOptions.java

Lines changed: 38 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@
2020
* #L%
2121
*/
2222

23-
import com.datastax.astra.internal.http.HttpClientOptions;
24-
import com.datastax.astra.internal.utils.Assert;
23+
import com.datastax.astra.client.internal.http.HttpClientOptions;
24+
import com.datastax.astra.client.internal.utils.Assert;
2525
import lombok.Getter;
2626

2727
import java.net.http.HttpClient;
@@ -106,6 +106,42 @@ private DataAPIOptions(DataAPIClientOptionsBuilder builder) {
106106
this.httpClientOptions = httpClientOptions;
107107
}
108108

109+
/**
110+
* Represent the destination of the data API.
111+
*/
112+
public enum DataAPIDestination {
113+
114+
/**
115+
* Astra Production environment
116+
*/
117+
ASTRA,
118+
119+
/**
120+
* Astra Development environment
121+
*/
122+
ASTRA_DEV,
123+
124+
/**
125+
* Astra Test environment
126+
*/
127+
ASTRA_TEST,
128+
129+
/**
130+
* Local installation of Datastax Enterprise
131+
*/
132+
DSE,
133+
134+
/**
135+
* Local installation of Apache Cassandra
136+
*/
137+
CASSANDRA,
138+
139+
/**
140+
* Extra local installation .
141+
*/
142+
OTHERS
143+
}
144+
109145
/**
110146
* Builder for the DataAPIClientOptions.
111147
*/

src/main/java/com/datastax/astra/client/Database.java

Lines changed: 12 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -20,27 +20,30 @@
2020
* #L%
2121
*/
2222

23+
import com.datastax.astra.client.DataAPIOptions.DataAPIDestination;
24+
import com.datastax.astra.client.admin.AstraDBAdmin;
25+
import com.datastax.astra.client.admin.DatabaseAdmin;
2326
import com.datastax.astra.client.model.Command;
2427
import com.datastax.astra.client.model.Document;
2528
import com.datastax.astra.client.model.collections.CollectionDefinition;
2629
import com.datastax.astra.client.model.collections.CollectionOptions;
2730
import com.datastax.astra.client.model.find.SimilarityMetric;
28-
import com.datastax.astra.internal.AbstractCommandRunner;
29-
import com.datastax.astra.internal.DataAPIDatabaseAdmin;
30-
import com.datastax.astra.internal.astra.AstraApiEndpoint;
31-
import com.datastax.astra.internal.AstraDBDatabaseAdmin;
32-
import com.datastax.astra.internal.http.HttpClientOptions;
33-
import com.datastax.astra.internal.utils.JsonUtils;
31+
import com.datastax.astra.client.internal.AbstractCommandRunner;
32+
import com.datastax.astra.client.admin.DataAPIDatabaseAdmin;
33+
import com.datastax.astra.client.internal.AstraApiEndpoint;
34+
import com.datastax.astra.client.admin.AstraDBDatabaseAdmin;
35+
import com.datastax.astra.client.internal.http.HttpClientOptions;
36+
import com.datastax.astra.client.internal.utils.JsonUtils;
3437
import lombok.Getter;
3538
import lombok.NonNull;
3639
import lombok.extern.slf4j.Slf4j;
3740

3841
import java.util.Objects;
3942
import java.util.stream.Stream;
4043

41-
import static com.datastax.astra.internal.utils.AnsiUtils.green;
42-
import static com.datastax.astra.internal.utils.Assert.hasLength;
43-
import static com.datastax.astra.internal.utils.Assert.notNull;
44+
import static com.datastax.astra.client.internal.utils.AnsiUtils.green;
45+
import static com.datastax.astra.client.internal.utils.Assert.hasLength;
46+
import static com.datastax.astra.client.internal.utils.Assert.notNull;
4447

4548
/**
4649
* Class to interact with a Namespace.

src/main/java/com/datastax/astra/client/AstraDBAdmin.java renamed to src/main/java/com/datastax/astra/client/admin/AstraDBAdmin.java

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.datastax.astra.client;
1+
package com.datastax.astra.client.admin;
22

33
/*-
44
* #%L
@@ -19,10 +19,9 @@
1919
* limitations under the License.
2020
* #L%
2121
*/
22-
23-
import com.datastax.astra.internal.astra.AstraApiEndpoint;
24-
import com.datastax.astra.internal.AstraDBDatabaseAdmin;
25-
import com.datastax.astra.internal.utils.Assert;
22+
import com.datastax.astra.client.DataAPIOptions;
23+
import com.datastax.astra.client.internal.AstraApiEndpoint;
24+
import com.datastax.astra.client.internal.utils.Assert;
2625
import com.dtsx.astra.sdk.db.AstraDBOpsClient;
2726
import com.dtsx.astra.sdk.db.DbOpsClient;
2827
import com.dtsx.astra.sdk.db.domain.CloudProviderType;
@@ -48,7 +47,7 @@
4847
import java.util.stream.Collectors;
4948
import java.util.stream.Stream;
5049

51-
import static com.datastax.astra.internal.utils.AnsiUtils.green;
50+
import static com.datastax.astra.client.internal.utils.AnsiUtils.green;
5251
import static com.dtsx.astra.sdk.utils.Utils.readEnvVariable;
5352

5453
/**
@@ -108,7 +107,7 @@ public class AstraDBAdmin {
108107
* @param env
109108
* astra environment
110109
*/
111-
AstraDBAdmin(String token, AstraEnvironment env, DataAPIOptions options) {
110+
public AstraDBAdmin(String token, AstraEnvironment env, DataAPIOptions options) {
112111
Assert.hasLength(token, "token");
113112
Assert.notNull(env, "environment");
114113
Assert.notNull(options, "options");
@@ -294,7 +293,7 @@ public boolean dropDatabase(@NonNull UUID databaseId) {
294293
*/
295294
public boolean dropDatabase(@NonNull String databaseName) {
296295
Assert.hasLength(databaseName, "database");
297-
com.datastax.astra.internal.utils.Assert.hasLength(databaseName, "Database ");
296+
Assert.hasLength(databaseName, "Database ");
298297
Optional<Database> db = listDatabases().filter(d -> d.getInfo().getName().equals(databaseName)).findFirst();
299298
if (db.isPresent()) {
300299
devopsDbClient.database(db.get().getId()).delete();

src/main/java/com/datastax/astra/internal/AstraDBDatabaseAdmin.java renamed to src/main/java/com/datastax/astra/client/admin/AstraDBDatabaseAdmin.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.datastax.astra.internal;
1+
package com.datastax.astra.client.admin;
22

33
/*-
44
* #%L
@@ -21,8 +21,7 @@
2121
*/
2222

2323
import com.datastax.astra.client.DataAPIOptions;
24-
import com.datastax.astra.client.DatabaseAdmin;
25-
import com.datastax.astra.internal.astra.AstraApiEndpoint;
24+
import com.datastax.astra.client.internal.AstraApiEndpoint;
2625
import com.dtsx.astra.sdk.db.AstraDBOpsClient;
2726
import com.dtsx.astra.sdk.db.domain.Database;
2827
import com.dtsx.astra.sdk.db.exception.DatabaseNotFoundException;

0 commit comments

Comments
 (0)