data class IndexerConfig(var logLimit: Long = 64, var pageLimit: Long = 1024, var rowsPerBlock: Long = 102400, var flushDuration: Duration = Duration.ofHours(4), var skipTxs: List<MessageId> = System.getenv("XTDB_SKIP_TXS")?.let(::parseSkipTxsEnv).orEmpty(), var enabled: Boolean = true)

InetAddressSerde

object InetAddressSerde : KSerializer<InetAddress?>

IngestNode

class IngestNode : AutoCloseable

A node that does nothing but ingest from external sources — it runs a Database per configured external source, joins leader election, and runs the source only on the database for which it's elected leader. There's no query/client surface: no pgwire, no Flight SQL — though it can serve the healthz endpoints (Config.healthz) for metrics and liveness.

OAuthClientCredentialsResult

data class OAuthClientCredentialsResult(val userId: String, var expiresAt: Instant, val accessToken: String, val clientId: String, val clientSecret: String) : OAuthResult

OAuthPasswordResult

data class OAuthPasswordResult(val userId: String, var expiresAt: Instant, val accessToken: String, val refreshToken: String) : OAuthResult

OAuthResult

interface OAuthResult : AuthResult

PasswordHash

@Serializable

sealed interface PasswordHash

A stored password hash, tagged in YAML with the algorithm that produced it (!Argon2id, !BCrypt).

Remote

interface Remote : AutoCloseable

A named, node-local handle for an external system XT authenticates against — a Postgres instance, a cloud identity (AWS/Azure/GCP), etc.

RemoteAlias

typealias RemoteAlias = String

ResultCursor

interface ResultCursor : ICursor

ServerConfig

@Serializable

data class ServerConfig(var host: InetAddress? = InetAddress.getLoopbackAddress(), var port: Int = 0, var readOnlyPort: Int = -1, var numThreads: Int = 42, var ssl: ServerConfig.SslSettings? = null)

SimpleResult

data class SimpleResult(val userId: String) : AuthResult

SingleRootUserAuthenticator

class SingleRootUserAuthenticator(password: String?) : Authenticator

UserListAuthenticator

class UserListAuthenticator(users: Map<String, PasswordHash>, rules: List<Authenticator.MethodRule>) : Authenticator

Xtdb

interface Xtdb : DataSource, AdbcDatabase, AutoCloseable

Properties

DEFAULT_RULES

val DEFAULT_RULES: List<Authenticator.MethodRule>

Functions

module

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