Index (nx-gs-adapter-core 0.2.0 API)

A B C D E F G H I K N O R S T V W
All Classes and Interfaces|All Packages

A

ACTIVE - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Connected, heartbeat running.
ACTIVE - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome: 200 — adapter is connected.
AdapterConfig - Class in app.l2nx.gs.adapter.core.config: Immutable holder for adapter configuration resolved at startup.
AdapterState - Enum Class in app.l2nx.gs.adapter.core: Lifecycle states observable via NxAdapter.state() / NxAdapter.onStateChange(java.util.function.Consumer<app.l2nx.gs.adapter.core.AdapterState>).
AdapterVersion - Class in app.l2nx.gs.adapter.core.lifecycle: Resolves the adapter version from the JAR manifest's Implementation-Version.
app.l2nx.gs.adapter.core - package app.l2nx.gs.adapter.core
app.l2nx.gs.adapter.core.concurrent - package app.l2nx.gs.adapter.core.concurrent
app.l2nx.gs.adapter.core.config - package app.l2nx.gs.adapter.core.config
app.l2nx.gs.adapter.core.connect - package app.l2nx.gs.adapter.core.connect
app.l2nx.gs.adapter.core.heartbeat - package app.l2nx.gs.adapter.core.heartbeat
app.l2nx.gs.adapter.core.kafka - package app.l2nx.gs.adapter.core.kafka
app.l2nx.gs.adapter.core.lifecycle - package app.l2nx.gs.adapter.core.lifecycle

B

BackoffSchedule - Interface in app.l2nx.gs.adapter.core.connect: Stateless retry-delay generator.
build(String, String, Map<String, Object>, Consumer<KafkaState>) - Method in class app.l2nx.gs.adapter.core.kafka.DefaultKafkaFactory
build(String, String, Map<String, Object>, Consumer<KafkaState>) - Method in interface app.l2nx.gs.adapter.core.kafka.KafkaFactory: Create or replace the NxKafka singleton with this configuration.

C

CLOSED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Terminal — JVM shutdown hook fired or NxAdapter.shutdown() called.
ConfigResolver - Class in app.l2nx.gs.adapter.core.config: Resolves adapter configuration from a two-source chain (per key), file-first: Properties file — either the path given by -Dl2nx.config-file=<path> (operator-preferred; absolute or relative to the JVM working directory), or l2nx.properties in the JVM working directory of the host application as a fallback when l2nx.config-file is unset. JVM system property (e.g.
ConfigResolver() - Constructor for class app.l2nx.gs.adapter.core.config.ConfigResolver
connect(String, String, ConnectRequest) - Method in interface app.l2nx.gs.adapter.core.connect.ConnectClient: Send the connect request and return a typed result.
connect(String, String, ConnectRequest) - Method in class app.l2nx.gs.adapter.core.connect.HttpURLConnectionConnectClient
ConnectClient - Interface in app.l2nx.gs.adapter.core.connect: Performs the platform-side POST /api/tenants/servers/connect handshake.
ConnectFlow - Class in app.l2nx.gs.adapter.core.connect: Drives the POST /api/tenants/servers/connect lifecycle and emits an ConnectFlow.Outcome per logical state transition.
ConnectFlow(AdapterConfig, ConnectClient, BackoffSchedule, ScheduledExecutorService, Consumer<ConnectFlow.Outcome>) - Constructor for class app.l2nx.gs.adapter.core.connect.ConnectFlow
ConnectFlow(AdapterConfig, ConnectClient, BackoffSchedule, ScheduledExecutorService, Consumer<ConnectFlow.Outcome>, Consumer<ConnectResponse>) - Constructor for class app.l2nx.gs.adapter.core.connect.ConnectFlow
ConnectFlow.Outcome - Enum Class in app.l2nx.gs.adapter.core.connect: Coarse-grained connect-flow events surfaced to the orchestrator (NxAdapter).
ConnectResult - Class in app.l2nx.gs.adapter.core.connect: Outcome of a single ConnectClient.connect(java.lang.String, java.lang.String, app.l2nx.gs.adapter.api.rest.ConnectRequest) invocation.

D

DefaultBackoffSchedule - Class in app.l2nx.gs.adapter.core.connect: Canonical retry schedule: 30s → 1m → 2m → 5m, capped at 5m for all subsequent attempts.
DefaultBackoffSchedule() - Constructor for class app.l2nx.gs.adapter.core.connect.DefaultBackoffSchedule
DefaultKafkaFactory - Class in app.l2nx.gs.adapter.core.kafka: Default KafkaFactory that bridges to NxKafka.configure().build().
DefaultKafkaFactory() - Constructor for class app.l2nx.gs.adapter.core.kafka.DefaultKafkaFactory
DEGRADED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Transient failure (5xx / 409 / network) — retry scheduled.
DISABLED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Adapter is loaded but l2nx.enabled=false — no work performed.

E

emit(NxLog, String) - Static method in class app.l2nx.gs.adapter.core.lifecycle.StartupBanner
ErrorEnvelope - Class in app.l2nx.gs.adapter.core.connect: Platform-side error response body — Gson-deserialized from 4xx / 5xx responses.
ErrorEnvelope(String, String) - Constructor for class app.l2nx.gs.adapter.core.connect.ErrorEnvelope

F

FAILED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Terminal failure due to config error or 401 (invalid server-key).
FAILED - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome: Terminal non-recoverable failure — no further retries.

G

getAdapterVersion() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig
getCode() - Method in class app.l2nx.gs.adapter.core.connect.ErrorEnvelope
getError() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult
getIoException() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult
getMessage() - Method in class app.l2nx.gs.adapter.core.connect.ErrorEnvelope
getPlatformUrl() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig
getResponse() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult
getServerKey() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig
getStatusCode() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult

H

HeartbeatService - Class in app.l2nx.gs.adapter.core.heartbeat: Publishes a HeartbeatEvent every 60L seconds via the supplied HeartbeatService.KafkaPublisher on the supplied scheduler.
HeartbeatService(HeartbeatService.KafkaPublisher, ScheduledExecutorService, String) - Constructor for class app.l2nx.gs.adapter.core.heartbeat.HeartbeatService
HeartbeatService.KafkaPublisher - Interface in app.l2nx.gs.adapter.core.heartbeat
httpError(int, ErrorEnvelope) - Static method in class app.l2nx.gs.adapter.core.connect.ConnectResult
HttpURLConnectionConnectClient - Class in app.l2nx.gs.adapter.core.connect: JDK-only ConnectClient backed by HttpURLConnection + Gson.
HttpURLConnectionConnectClient() - Constructor for class app.l2nx.gs.adapter.core.connect.HttpURLConnectionConnectClient

I

init(KafkaConfig, String, Consumer<KafkaState>) - Method in class app.l2nx.gs.adapter.core.kafka.KafkaInitializer: Build the Kafka client and return the post-build state.
INIT - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Initial state before NxAdapter.start() runs.
ioFailure(IOException) - Static method in class app.l2nx.gs.adapter.core.connect.ConnectResult
isEnabled() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig
isIoFailure() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult

K

KafkaFactory - Interface in app.l2nx.gs.adapter.core.kafka: Test seam over the NxKafka.configure().build() singleton bootstrap.
KafkaInitializer - Class in app.l2nx.gs.adapter.core.kafka: Bootstraps the nx-gs-kafka singleton from a platform-issued KafkaConfig.
KafkaInitializer(KafkaFactory) - Constructor for class app.l2nx.gs.adapter.core.kafka.KafkaInitializer

N

next(int) - Method in interface app.l2nx.gs.adapter.core.connect.BackoffSchedule
next(int) - Method in class app.l2nx.gs.adapter.core.connect.DefaultBackoffSchedule
NxAdapter - Class in app.l2nx.gs.adapter.core: Adapter entry point — singleton-style facade exposing the lifecycle to the host JVM.

O

onStateChange(Consumer<AdapterState>) - Static method in class app.l2nx.gs.adapter.core.NxAdapter: Register a state-transition callback.

R

REGISTERING - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Connect attempt in flight (first attempt, or any retry).
REJECTED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState: Terminal — server deactivated by tenant (403 GAME_SERVER_DEACTIVATED).
REJECTED - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome: Terminal — server deactivated by tenant.
resolve() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver
resolve() - Static method in class app.l2nx.gs.adapter.core.lifecycle.AdapterVersion
resolveAdapterVersion() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver
resolveBoolean(String, boolean) - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver
resolveEnabled() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver
resolvePlatformUrl() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver
resolveServerKey() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver
resolveString(String) - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver
run() - Method in class app.l2nx.gs.adapter.core.connect.ConnectFlow

S

SafeRunnable - Class in app.l2nx.gs.adapter.core.concurrent: Wraps a Runnable so any uncaught Throwable is logged and swallowed.
send(String, String, Object) - Method in interface app.l2nx.gs.adapter.core.heartbeat.HeartbeatService.KafkaPublisher
shutdown() - Method in class app.l2nx.gs.adapter.core.NxAdapter: Idempotent shutdown — cancel heartbeat, cancel connect scheduler, shut down the Kafka client if alive, and transition to AdapterState.CLOSED.
start() - Static method in class app.l2nx.gs.adapter.core.NxAdapter: Resolve config and (if enabled) initiate the connect flow on a daemon scheduler.
start(String, String) - Method in class app.l2nx.gs.adapter.core.heartbeat.HeartbeatService
STARTING - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome: A connect attempt is about to be executed (initial submit or retry).
StartupBanner - Class in app.l2nx.gs.adapter.core.lifecycle: Emits the L2NX startup wordmark and adapter version.
state() - Static method in class app.l2nx.gs.adapter.core.NxAdapter: Current adapter state.
stop() - Method in class app.l2nx.gs.adapter.core.heartbeat.HeartbeatService
success(ConnectResponse) - Static method in class app.l2nx.gs.adapter.core.connect.ConnectResult

T

TRANSIENT - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome: Transient failure — retry scheduled.

V

valueOf(String) - Static method in enum class app.l2nx.gs.adapter.core.AdapterState: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome: Returns the enum constant of this class with the specified name.
values() - Static method in enum class app.l2nx.gs.adapter.core.AdapterState: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome: Returns an array containing the constants of this enum class, in the order they are declared.

W

wrap(Runnable, NxLog) - Static method in class app.l2nx.gs.adapter.core.concurrent.SafeRunnable

A B C D E F G H I K N O R S T V W
All Classes and Interfaces|All Packages