xtdb-core/xtdb.api/Xtdb/XtdbInternal

XtdbInternal

interface XtdbInternal : Xtdb

Properties

allocator

abstract val allocator: BufferAllocator

awaitToken

abstract var awaitToken: String

connection

open val connection: Connection

databaseNames

abstract val databaseNames: Collection<DatabaseName>

The names of the databases this node currently serves.

dbCatalog

abstract val dbCatalog: Database.Catalog

flightSqlPort

abstract val flightSqlPort: Int

loginTimeout

open var loginTimeout: Int

logWriter

open var logWriter: PrintWriter?

parentLogger

open val parentLogger: Logger

serverPort

abstract val serverPort: Int

serverReadOnlyPort

abstract val serverReadOnlyPort: Int

Functions

addMeterRegistry

abstract fun addMeterRegistry(meterRegistry: MeterRegistry)

abstract fun close()

connect

abstract override fun connect(): Xtdb.Connection

abstract fun connect(dbName: DatabaseName): Xtdb.Connection

Opens an in-process connection to the named database.

createConnectionBuilder

abstract override fun createConnectionBuilder(): DataSource.ConnectionBuilder

createShardingKeyBuilder

open fun createShardingKeyBuilder(): ShardingKeyBuilder?

executeTx

abstract fun executeTx(ops: List<TxOp>, opts: TxOpts = TxOpts()): Xtdb.ExecutedTx

getConnection

open override fun getConnection(): Connection

open override fun getConnection(username: String?, password: String?): Connection

getLoginTimeout

open override fun getLoginTimeout(): Int

getLogWriter

open override fun getLogWriter(): PrintWriter?

getOption

open fun <T : Any?> getOption(key: TypedKey<T?>?): T?

getParentLogger

open override fun getParentLogger(): Logger

isWrapperFor

abstract fun isWrapperFor(p0: Class<*>?): Boolean

latestCompletedTxs

abstract fun latestCompletedTxs(): Map<DatabaseName, List<TransactionKey?>>

Each database's latest-completed transaction, per partition.

module

abstract fun <T : XtdbModule> module(type: Class<T>): T?

module

inline fun <T : XtdbModule> Xtdb.module(): T?

setLoginTimeout

open override fun setLoginTimeout(seconds: Int)

setLogWriter

open override fun setLogWriter(out: PrintWriter?)

setOption

open fun <T : Any?> setOption(key: TypedKey<T?>?, value: T?)

submitTx

abstract fun submitTx(ops: List<TxOp>, opts: TxOpts = TxOpts()): Xtdb.SubmittedTx

unwrap

abstract fun <T : Any?> unwrap(p0: Class<T?>?): T?