class DBConfiguration extends AnyRef
This class is a wrapper of ElasticSearch client from Elastic4s It builds the client using configuration (ElasticSearch addresses, cluster and index name) It add timed annotation in order to measure storage metrics
- Annotations
- @Singleton()
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DBConfiguration
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
-
new
DBConfiguration(config: Configuration, lifecycle: ApplicationLifecycle, version: Int, ec: ExecutionContext, actorSystem: ActorSystem)
- Annotations
- @Inject()
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- implicit val actorSystem: ActorSystem
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
val
client: ElasticClient
Underlying ElasticSearch client
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- lazy val credentialsProviderMaybe: Option[CredentialsProvider]
- implicit val ec: ExecutionContext
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def execute[T, U](t: T)(implicit handler: Handler[T, U], manifest: Manifest[U]): Future[U]
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def httpClientConfig: HttpClientConfigCallback
-
val
indexName: String
Name of the index, suffixed by the current version
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
previousVersion: DBConfiguration
return a new instance of DBConfiguration that points to the previous version of the index schema
- def requestConfigCallback: RequestConfigCallback
-
def
sink[T](implicit builder: RequestBuilder[T]): Sink[T, Future[Unit]]
Create a Sink (akka stream) that create entity in ElasticSearch
-
def
source(searchRequest: SearchRequest): Source[SearchHit, NotUsed]
Creates a Source (akka stream) from the result of the search
- lazy val sslContextMaybe: Option[SSLContext]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- val version: Int
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()