Skip to content

Commit 04b805b

Browse files
committed
rename ElasticsearchClient to JavaClient
1 parent 4a1a17c commit 04b805b

22 files changed

+128
-132
lines changed
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
app.softnetwork.elastic.client.spi.ElasticsearchClientSpi
1+
app.softnetwork.elastic.client.spi.JavaClientSpi
Lines changed: 47 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -54,31 +54,31 @@ import scala.concurrent.{ExecutionContext, Future}
5454
import scala.language.implicitConversions
5555
import scala.util.{Failure, Success, Try}
5656

57-
trait ElasticsearchClientApi
57+
trait JavaClientApi
5858
extends ElasticClientApi
59-
with ElasticsearchClientIndicesApi
60-
with ElasticsearchClientAliasApi
61-
with ElasticsearchClientSettingsApi
62-
with ElasticsearchClientMappingApi
63-
with ElasticsearchClientRefreshApi
64-
with ElasticsearchClientFlushApi
65-
with ElasticsearchClientCountApi
66-
with ElasticsearchClientIndexApi
67-
with ElasticsearchClientUpdateApi
68-
with ElasticsearchClientDeleteApi
69-
with ElasticsearchClientGetApi
70-
with ElasticsearchClientSearchApi
71-
with ElasticsearchClientBulkApi
72-
with ElasticsearchClientScrollApi
73-
with ElasticsearchClientCompanion
74-
with ElasticsearchClientVersionApi
59+
with JavaClientIndicesApi
60+
with JavaClientAliasApi
61+
with JavaClientSettingsApi
62+
with JavaClientMappingApi
63+
with JavaClientRefreshApi
64+
with JavaClientFlushApi
65+
with JavaClientCountApi
66+
with JavaClientIndexApi
67+
with JavaClientUpdateApi
68+
with JavaClientDeleteApi
69+
with JavaClientGetApi
70+
with JavaClientSearchApi
71+
with JavaClientBulkApi
72+
with JavaClientScrollApi
73+
with JavaClientCompanion
74+
with JavaClientVersionApi
7575

7676
/** Elasticsearch client implementation using the Java Client
7777
* @see
7878
* [[VersionApi]] for version information
7979
*/
80-
trait ElasticsearchClientVersionApi extends VersionApi with ElasticsearchClientHelpers {
81-
_: SerializationApi with ElasticsearchClientCompanion =>
80+
trait JavaClientVersionApi extends VersionApi with JavaClientHelpers {
81+
_: SerializationApi with JavaClientCompanion =>
8282
override private[client] def executeVersion(): result.ElasticResult[String] =
8383
executeJavaAction(
8484
operation = "version",
@@ -95,10 +95,8 @@ trait ElasticsearchClientVersionApi extends VersionApi with ElasticsearchClientH
9595
* @see
9696
* [[IndicesApi]] for index management operations
9797
*/
98-
trait ElasticsearchClientIndicesApi
99-
extends IndicesApi
100-
with RefreshApi
101-
with ElasticsearchClientHelpers { _: ElasticsearchClientCompanion =>
98+
trait JavaClientIndicesApi extends IndicesApi with RefreshApi with JavaClientHelpers {
99+
_: JavaClientCompanion =>
102100
override private[client] def executeCreateIndex(
103101
index: String,
104102
settings: String
@@ -198,8 +196,8 @@ trait ElasticsearchClientIndicesApi
198196
* @see
199197
* [[AliasApi]] for alias management operations
200198
*/
201-
trait ElasticsearchClientAliasApi extends AliasApi with ElasticsearchClientHelpers {
202-
_: IndicesApi with ElasticsearchClientCompanion =>
199+
trait JavaClientAliasApi extends AliasApi with JavaClientHelpers {
200+
_: IndicesApi with JavaClientCompanion =>
203201

204202
override private[client] def executeAddAlias(
205203
index: String,
@@ -305,8 +303,8 @@ trait ElasticsearchClientAliasApi extends AliasApi with ElasticsearchClientHelpe
305303
* @see
306304
* [[SettingsApi]] for settings management operations
307305
*/
308-
trait ElasticsearchClientSettingsApi extends SettingsApi with ElasticsearchClientHelpers {
309-
_: IndicesApi with ElasticsearchClientCompanion =>
306+
trait JavaClientSettingsApi extends SettingsApi with JavaClientHelpers {
307+
_: IndicesApi with JavaClientCompanion =>
310308

311309
override private[client] def executeUpdateSettings(
312310
index: String,
@@ -346,8 +344,8 @@ trait ElasticsearchClientSettingsApi extends SettingsApi with ElasticsearchClien
346344
* @see
347345
* [[MappingApi]] for mapping management operations
348346
*/
349-
trait ElasticsearchClientMappingApi extends MappingApi with ElasticsearchClientHelpers {
350-
_: SettingsApi with IndicesApi with RefreshApi with ElasticsearchClientCompanion =>
347+
trait JavaClientMappingApi extends MappingApi with JavaClientHelpers {
348+
_: SettingsApi with IndicesApi with RefreshApi with JavaClientCompanion =>
351349

352350
override private[client] def executeSetMapping(
353351
index: String,
@@ -413,8 +411,8 @@ trait ElasticsearchClientMappingApi extends MappingApi with ElasticsearchClientH
413411
* @see
414412
* [[RefreshApi]] for index refresh operations
415413
*/
416-
trait ElasticsearchClientRefreshApi extends RefreshApi with ElasticsearchClientHelpers {
417-
_: ElasticsearchClientCompanion =>
414+
trait JavaClientRefreshApi extends RefreshApi with JavaClientHelpers {
415+
_: JavaClientCompanion =>
418416

419417
override private[client] def executeRefresh(index: String): result.ElasticResult[Boolean] =
420418
executeJavaBooleanAction(
@@ -439,8 +437,8 @@ trait ElasticsearchClientRefreshApi extends RefreshApi with ElasticsearchClientH
439437
* @see
440438
* [[FlushApi]] for index flush operations
441439
*/
442-
trait ElasticsearchClientFlushApi extends FlushApi with ElasticsearchClientHelpers {
443-
_: ElasticsearchClientCompanion =>
440+
trait JavaClientFlushApi extends FlushApi with JavaClientHelpers {
441+
_: JavaClientCompanion =>
444442

445443
override private[client] def executeFlush(
446444
index: String,
@@ -469,8 +467,8 @@ trait ElasticsearchClientFlushApi extends FlushApi with ElasticsearchClientHelpe
469467
* @see
470468
* [[CountApi]] for count operations
471469
*/
472-
trait ElasticsearchClientCountApi extends CountApi with ElasticsearchClientHelpers {
473-
_: ElasticsearchClientCompanion =>
470+
trait JavaClientCountApi extends CountApi with JavaClientHelpers {
471+
_: JavaClientCompanion =>
474472

475473
override private[client] def executeCount(
476474
query: ElasticQuery
@@ -506,8 +504,8 @@ trait ElasticsearchClientCountApi extends CountApi with ElasticsearchClientHelpe
506504
* @see
507505
* [[IndexApi]] for index operations
508506
*/
509-
trait ElasticsearchClientIndexApi extends IndexApi with ElasticsearchClientHelpers {
510-
_: RefreshApi with ElasticsearchClientCompanion with SerializationApi =>
507+
trait JavaClientIndexApi extends IndexApi with JavaClientHelpers {
508+
_: RefreshApi with JavaClientCompanion with SerializationApi =>
511509

512510
override private[client] def executeIndex(
513511
index: String,
@@ -561,8 +559,8 @@ trait ElasticsearchClientIndexApi extends IndexApi with ElasticsearchClientHelpe
561559
* @see
562560
* [[UpdateApi]] for update operations
563561
*/
564-
trait ElasticsearchClientUpdateApi extends UpdateApi with ElasticsearchClientHelpers {
565-
_: RefreshApi with ElasticsearchClientCompanion with SerializationApi =>
562+
trait JavaClientUpdateApi extends UpdateApi with JavaClientHelpers {
563+
_: RefreshApi with JavaClientCompanion with SerializationApi =>
566564

567565
override private[client] def executeUpdate(
568566
index: String,
@@ -624,8 +622,8 @@ trait ElasticsearchClientUpdateApi extends UpdateApi with ElasticsearchClientHel
624622
* @see
625623
* [[DeleteApi]] for delete operations
626624
*/
627-
trait ElasticsearchClientDeleteApi extends DeleteApi with ElasticsearchClientHelpers {
628-
_: RefreshApi with ElasticsearchClientCompanion =>
625+
trait JavaClientDeleteApi extends DeleteApi with JavaClientHelpers {
626+
_: RefreshApi with JavaClientCompanion =>
629627

630628
override private[client] def executeDelete(
631629
index: String,
@@ -670,8 +668,8 @@ trait ElasticsearchClientDeleteApi extends DeleteApi with ElasticsearchClientHel
670668
* @see
671669
* [[GetApi]] for get operations
672670
*/
673-
trait ElasticsearchClientGetApi extends GetApi with ElasticsearchClientHelpers {
674-
_: ElasticsearchClientCompanion with SerializationApi =>
671+
trait JavaClientGetApi extends GetApi with JavaClientHelpers {
672+
_: JavaClientCompanion with SerializationApi =>
675673

676674
override private[client] def executeGet(
677675
index: String,
@@ -724,8 +722,8 @@ trait ElasticsearchClientGetApi extends GetApi with ElasticsearchClientHelpers {
724722
* @see
725723
* [[SearchApi]] for search operations
726724
*/
727-
trait ElasticsearchClientSearchApi extends SearchApi with ElasticsearchClientHelpers {
728-
_: ElasticsearchClientCompanion with SerializationApi =>
725+
trait JavaClientSearchApi extends SearchApi with JavaClientHelpers {
726+
_: JavaClientCompanion with SerializationApi =>
729727

730728
override implicit def sqlSearchRequestToJsonQuery(sqlSearch: SQLSearchRequest): String =
731729
implicitly[ElasticSearchRequest](sqlSearch).query
@@ -809,8 +807,8 @@ trait ElasticsearchClientSearchApi extends SearchApi with ElasticsearchClientHel
809807
* @see
810808
* [[BulkApi]] for bulk operations
811809
*/
812-
trait ElasticsearchClientBulkApi extends BulkApi with ElasticsearchClientHelpers {
813-
_: RefreshApi with SettingsApi with IndexApi with ElasticsearchClientCompanion =>
810+
trait JavaClientBulkApi extends BulkApi with JavaClientHelpers {
811+
_: RefreshApi with SettingsApi with IndexApi with JavaClientCompanion =>
814812
override type BulkActionType = BulkOperation
815813
override type BulkResultType = BulkResponse
816814

@@ -1058,8 +1056,8 @@ trait ElasticsearchClientBulkApi extends BulkApi with ElasticsearchClientHelpers
10581056
* @see
10591057
* [[ScrollApi]] for scroll operations
10601058
*/
1061-
trait ElasticsearchClientScrollApi extends ScrollApi with ElasticsearchClientHelpers {
1062-
_: SearchApi with ElasticsearchClientCompanion =>
1059+
trait JavaClientScrollApi extends ScrollApi with JavaClientHelpers {
1060+
_: SearchApi with JavaClientCompanion =>
10631061

10641062
/** Classic scroll (works for both hits and aggregations)
10651063
*/
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import org.slf4j.{Logger, LoggerFactory}
3131
import java.util.concurrent.CompletableFuture
3232
import scala.concurrent.{Future, Promise}
3333

34-
trait ElasticsearchClientCompanion extends ElasticClientCompanion[ElasticsearchClient] {
34+
trait JavaClientCompanion extends ElasticClientCompanion[ElasticsearchClient] {
3535

3636
val logger: Logger = LoggerFactory getLogger getClass.getName
3737

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import co.elastic.clients.json.jackson.JacksonJsonpMapper
2222
import java.io.{IOException, StringWriter}
2323
import scala.util.Try
2424

25-
trait ElasticsearchConversion { _: ElasticsearchClientCompanion =>
25+
trait JavaClientConversion { _: JavaClientCompanion =>
2626
private[this] val jsonpMapper = new JacksonJsonpMapper(mapper)
2727

2828
/** Convert any Elasticsearch response to JSON string */
Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@ import app.softnetwork.elastic.client.result.{ElasticError, ElasticResult}
2121

2222
import scala.util.{Failure, Success, Try}
2323

24-
trait ElasticsearchClientHelpers extends ElasticClientHelpers with ElasticsearchConversion {
25-
_: ElasticsearchClientCompanion =>
24+
trait JavaClientHelpers extends ElasticClientHelpers with JavaClientConversion {
25+
_: JavaClientCompanion =>
2626

2727
// ========================================================================
2828
// GENERIC METHODS FOR EXECUTING JAVA CLIENT ACTIONS
Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,10 @@
1717
package app.softnetwork.elastic.client.spi
1818

1919
import app.softnetwork.elastic.client.ElasticClientApi
20-
import app.softnetwork.elastic.client.java.ElasticsearchClientApi
20+
import app.softnetwork.elastic.client.java.JavaClientApi
2121
import com.typesafe.config.Config
2222

23-
class ElasticsearchClientSpi extends ElasticClientSpi {
23+
class JavaClientSpi extends ElasticClientSpi {
2424

2525
//format:off
2626
/** Creates an Elasticsearch client instance.
@@ -40,7 +40,7 @@ class ElasticsearchClientSpi extends ElasticClientSpi {
4040
*/
4141
//format:on
4242
override def client(conf: Config): ElasticClientApi =
43-
new ElasticsearchClientApi {
43+
new JavaClientApi {
4444
override def config: Config = conf
4545
}
4646
}

es8/java/src/test/scala/app/softnetwork/elastic/client/ElasticsearchClientSpec.scala

Lines changed: 0 additions & 3 deletions
This file was deleted.
Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package app.softnetwork.elastic.client
22

33
import akka.actor.ActorSystem
4-
import app.softnetwork.elastic.client.java.ElasticsearchClientCompanion
4+
import app.softnetwork.elastic.client.java.JavaClientCompanion
55
import app.softnetwork.elastic.scalatest.ElasticDockerTestKit
66
import app.softnetwork.persistence.generateUUID
77
import com.typesafe.config.ConfigFactory
@@ -16,7 +16,7 @@ import scala.concurrent.duration.Duration
1616
import scala.concurrent.{Await, ExecutionContextExecutor, Future}
1717
import scala.util.Try
1818

19-
class ElasticsearchClientCompanionSpec
19+
class JavaClientCompanionSpec
2020
extends AnyWordSpec
2121
with ElasticDockerTestKit
2222
with Matchers
@@ -89,7 +89,7 @@ class ElasticsearchClientCompanionSpec
8989
}
9090
}
9191

92-
case class TestCompanion(config: ElasticConfig) extends ElasticsearchClientCompanion {
92+
case class TestCompanion(config: ElasticConfig) extends JavaClientCompanion {
9393
override def elasticConfig: ElasticConfig = config
9494
}
9595

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
package app.softnetwork.elastic.client
2+
3+
class JavaClientSpec extends ElasticClientSpec

es8/java/src/test/scala/app/softnetwork/elastic/persistence/person/ElasticsearchClientPersonHandlerSpec.scala

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

0 commit comments

Comments
 (0)