Java 구성과 host 공개 인터페이스¶
이 문서는 Java application이 Mesh, Channel role, handler와 Framework host를 구성할 때 사용하는 공개 인터페이스를 고정한다. Application은 아래 builder로 구성을 선언하고, Framework는 host를 시작할 때 그 구성이 계약에 맞는지 검사한다.
ZLinkCodecRegistrar의 content-type에는 parameter가 없는 ASCII type/subtype을 전달한다.
Registry는 startup에 값 앞뒤의 SP와 TAB을 제거하고 ASCII 대문자를 소문자로 바꾼다. 이 결과가
registry에서 사용하는 canonical content-type이다. Parameter, 값 내부의 공백 또는 non-ASCII
token이 있으면 ZLinkConfigurationException으로 거부한다. 같은 canonical content-type을 다시
등록하면 마지막 등록이 앞의 등록을 교체한다.
Framework service wire에서 받은 값은 이미 canonical content-type이어야 한다. 다른 표기의 값은
ZLinkFrameworkErrorKind.PROTOCOL_ERROR로 완료한다.
두 인자 addSerializer(contentType, serializer)는 모든 declared message type에 맞는 serializer를
등록한다. 세 인자 overload는 송신 호출 지점의 declared Class<?>를 Predicate<Class<?>>에
전달한다. 둘 이상의 등록이 맞으면 나중에 등록한 serializer를 사용하고, 맞는 등록이 없으면
Framework JSON serializer를 사용한다. Runtime instance의 구체적인 subclass는 declared type을
대신하지 않는다.
Registry는 startup 뒤 바뀌지 않는다. 송신 선택 결과는 declared type 1,024개까지 저장하며, 이 한도에 도달해도 기존 entry를 제거하지 않는다. 그 뒤 처음 보는 type은 송신할 때마다 등록 목록을 다시 평가하고 결과를 저장하지 않는다.
public interface ZLinkFrameworkOptions {
Duration defaultRequestTimeout();
void setDefaultRequestTimeout(Duration timeout);
ZLinkCodecRegistryBuilder codecs();
void addHandlersFromPackageOf(Class<?> markerType);
ZLinkMetadataPolicyBuilder configureMetadata();
void addLocationStore(ZLinkLocationStore store);
void addRelocationStore(ZLinkRelocationStore store);
void setApplicationVersion(long version);
void setMaintenanceWave(String waveId);
ZLinkLocationOptions configureLocations();
ZLinkInboundDispatchOptions configureInboundDispatch();
ZLinkNetworkOptions configureNetwork();
ZLinkMeshNodeBuilder addRouteMesh(String meshName);
ClientServerChannelBuilder addClientServerChannel(String channelName);
FanoutChannelBuilder addFanoutChannel(String channelName);
ZLinkStreamNodeBuilder addStreamNode(String name);
void useFilter(Class<? extends ZLinkHandlerFilter> filterType);
ZLinkDispatchOptions configureDispatch();
ZLinkStreamCompressionBuilder configureStreamCompression();
ZLinkWorkerOptions configureWorkers();
void useVirtualThreadHandlers();
void useHandlerExecutor(Executor executor);
}
public enum ZLinkCoreHwmProfile {
COMPACT,
LOW_LATENCY,
BALANCED,
THROUGHPUT
}
public enum ZLinkApplicationJobQueueProfile {
COMPACT,
LOW_LATENCY,
BALANCED,
THROUGHPUT
}
public interface ZLinkInboundDispatchOptions {
OptionalLong coreHwmMemoryLimitBytes();
void setCoreHwmMemoryLimitBytes(long value);
OptionalLong coreHwmBudgetBytes();
void setCoreHwmBudgetBytes(long value);
ZLinkCoreHwmProfile coreHwmProfile();
void setCoreHwmProfile(ZLinkCoreHwmProfile value);
ZLinkApplicationJobQueueProfile applicationJobQueueProfile();
void setApplicationJobQueueProfile(ZLinkApplicationJobQueueProfile value);
OptionalLong maxQueuedApplicationJobs();
void setMaxQueuedApplicationJobs(long value);
int applicationJobQueuePauseThresholdPercent();
void setApplicationJobQueuePauseThresholdPercent(int value);
int applicationJobQueueResumeThresholdPercent();
void setApplicationJobQueueResumeThresholdPercent(int value);
}
public interface ZLinkLocationOptions {
Duration ownerLeaseRenewInterval();
void setOwnerLeaseRenewInterval(Duration value);
Duration ownerLeaseTtl();
void setOwnerLeaseTtl(Duration value);
Duration pollingInterval();
void setPollingInterval(Duration value);
Duration storeFailureGrace();
void setStoreFailureGrace(Duration value);
Duration ownerLeaseFencingMargin();
void setOwnerLeaseFencingMargin(Duration value);
Duration ownerLeaseRenewTimeout();
void setOwnerLeaseRenewTimeout(Duration value);
Duration routeCacheMaxAge();
void setRouteCacheMaxAge(Duration value);
Duration messageFollowDuration();
void setMessageFollowDuration(Duration value);
Duration sessionRelocationSealTimeout();
void setSessionRelocationSealTimeout(Duration value);
long relocationPayloadChunkLimitBytes();
void setRelocationPayloadChunkLimitBytes(long value);
long relocationInFlightPayloadBudgetBytes();
void setRelocationInFlightPayloadBudgetBytes(long value);
long relocationNodeInFlightPayloadBudgetBytes();
void setRelocationNodeInFlightPayloadBudgetBytes(long value);
Duration relocationCutoverWaitTimeout();
void setRelocationCutoverWaitTimeout(Duration value);
}
public interface ZLinkNetworkOptions {
String bindHost();
void setBindHost(String host);
Optional<String> advertiseHost();
void setAdvertiseHost(String host);
}
public interface ZLinkMeshNodeSocketConfig {
long sendHighWaterMark();
void setSendHighWaterMark(long value);
long receiveHighWaterMark();
void setReceiveHighWaterMark(long value);
long mailboxMessageBudget();
void setMailboxMessageBudget(long value);
long mailboxByteBudget();
void setMailboxByteBudget(long value);
Optional<Duration> receiveTimeout();
void setReceiveTimeout(Duration value);
Optional<Duration> sendTimeout();
void setSendTimeout(Duration value);
}
@FunctionalInterface
public interface ZLinkFrameworkConfigurer {
void configure(ZLinkFrameworkOptions framework);
}
public interface ZLinkMeshNodeBuilder {
ZLinkMeshChannelBuilder channel(String channelName);
ZLinkMeshNodeBuilder listen(String endpoint);
ZLinkMeshNodeBuilder listen();
ZLinkMeshNodeBuilder listen(int port);
ZLinkMeshNodeBuilder setBindHost(String host);
ZLinkMeshNodeBuilder setAdvertiseHost(String host);
ZLinkMeshNodeBuilder setRoutingId(RoutingId routingId);
ZLinkMeshNodeBuilder setRoutingIdPrefix(String prefix);
ZLinkMeshNodeBuilder setPlacementWeight(int weight);
ZLinkMeshNodeBuilder setActorCapacity(int maxActors);
ZLinkMeshNodeBuilder setSpotCapacity(int maxSpots);
ZLinkMeshNodeBuilder setActivationConcurrency(int maxConcurrentActivations);
ZLinkMeshNodeBuilder setInstanceSpotIdleTimeout(Duration timeout);
ZLinkMeshObjectRoleBuilder objects();
ZLinkMeshNodeSocketConfig configureRouterSocket();
ZLinkSpotPublisherConfig configureSpotPublisher();
ZLinkMeshPeerConnections peerConnections();
ZLinkMeshNodeBuilder setDefaultRequestTimeout(Duration timeout);
<THandler, TMessage>
ZLinkMeshNodeBuilder addRouteSendHandler(
Class<THandler> handlerType,
Class<TMessage> messageType);
<THandler, TRequest, TReply>
ZLinkMeshNodeBuilder addRouteRequestHandler(
Class<THandler> handlerType,
Class<TRequest> requestType,
Class<TReply> replyType);
}
public interface ZLinkMeshObjectRoleBuilder {
ZLinkMeshObjectClientBuilder client();
ZLinkMeshObjectServerBuilder server();
}
public interface ZLinkMeshObjectClientBuilder {}
public interface ZLinkMeshObjectServerBuilder {
ZLinkMeshObjectServerBuilder addEntrySpot(Class<? extends ZLinkEntrySpot> entrySpotClass);
<TSpot extends ZLinkSpot> ZLinkMeshObjectServerBuilder addSpotFactory(
String spotType, Class<TSpot> spotClass,
Consumer<ZLinkUserSpotFactoryBuilder<TSpot>> configure);
<TSpot extends ZLinkInstanceSpot> ZLinkMeshObjectServerBuilder addInstanceSpotFactory(
String instanceSpotType, Class<TSpot> spotClass,
Consumer<ZLinkInstanceSpotFactoryBuilder<TSpot>> configure);
<TActor extends ZLinkActor> ZLinkMeshObjectServerBuilder addActorFactory(
String actorType,
Class<TActor> actorClass,
Class<? extends ZLinkActorFactory> factoryClass,
Consumer<ZLinkActorFactoryBuilder<TActor>> configure);
}
public enum ZLinkUserSpotExecutionMode {
SPOT_WIDE(0), PER_ACTOR(1);
private final int value;
ZLinkUserSpotExecutionMode(int value) { this.value = value; }
public int value() { return value; }
}
public enum ZLinkSpotRelocationCoordinationMode {
FRAMEWORK_MANAGED(0), APPLICATION_SIGNALED(1);
private final int value;
ZLinkSpotRelocationCoordinationMode(int value) { this.value = value; }
public int value() { return value; }
}
public interface ZLinkActorFactoryBuilder<TActor extends ZLinkActor> {
void disableRelocation();
void recreateOnRelocation();
void preserveStateWith(
Class<? extends ZLinkActorRelocationAdapter<TActor>> adapterClass);
}
public interface ZLinkUserSpotFactoryBuilder<TSpot extends ZLinkSpot> {
ZLinkUserSpotFactoryBuilder<TSpot> stableTypeLimit(int limit);
ZLinkUserSpotFactoryBuilder<TSpot> executionMode(ZLinkUserSpotExecutionMode mode);
ZLinkUserSpotFactoryBuilder<TSpot> relocationCoordinationMode(
ZLinkSpotRelocationCoordinationMode mode);
void disableRelocation();
void recreateOnRelocation();
void preserveStateWith(
Class<? extends ZLinkSpotRelocationAdapter<TSpot>> adapterClass);
}
public interface ZLinkInstanceSpotFactoryBuilder<TSpot extends ZLinkInstanceSpot> {
ZLinkInstanceSpotFactoryBuilder<TSpot> stableTypeLimit(int limit);
void disableRelocation();
void recreateOnRelocation();
void preserveStateWith(
Class<? extends ZLinkSpotRelocationAdapter<TSpot>> adapterClass);
}
public interface FanoutChannelBuilder {
FanoutChannelBuilder enablePublisher(String endpoint);
FanoutChannelBuilder enablePublisher();
FanoutChannelBuilder enablePublisher(int port);
FanoutChannelBuilder setBindHost(String host);
FanoutChannelBuilder setAdvertiseHost(String host);
FanoutChannelBuilder setRoutingId(RoutingId publisherRoutingId);
FanoutChannelBuilder setRoutingIdPrefix(String prefix);
FanoutChannelBuilder enableSubscriber();
FanoutChannelBuilder connect(String endpoint);
ZLinkEndpointConnections subscriberConnections();
FanoutChannelBuilder addHandlerGroup(String groupName);
}
configureInboundDispatch()가 반환하는 ZLinkInboundDispatchOptions의 coreHwmMemoryLimitBytes,
coreHwmBudgetBytes, coreHwmProfile은 Core에 전달한다. Java binding은
양수 유한 Runtime.maxMemory()를 runtime memory hint로 전달한다. Core와 job queue profile은 기본값
BALANCED인 독립된 enum과 계산이다. Manual job cap은 1..2,147,483,647이고 생략하면 common startup
CPU snapshot과 32/64/128/256 계수를 사용한다. Pressure threshold 기본값은 pause 80, resume 60이고,
pause는 1..100, resume은 0..99의 정수이며 resume은 pause보다 작아야 한다. 이 범위·순서 위반과
capacity overflow는 bind 전에 실패하며 runtime 중 다시 계산하지 않는다.
Application listener의 maxMessageSize() 기본값은 16_777_216L bytes다.
configureNetwork()은 process의 RouteMesh, ClientServer, classic fanout과 stream listener가 사용하는
기본 host를 반환한다. 기본 BindHost는 127.0.0.1이다. Listener별 setBindHost(...)와
setAdvertiseHost(...)를 호출하면 해당 listener에서만 root 기본값을 덮어쓴다. Port 0을 사용한 경우
Framework는 bind 뒤 확정된 port와 AdvertiseHost를 결합해 discovery descriptor에 기록한다. Stream
listener는 discovery 대상이 아니므로 같은 규칙으로 계산한 advertised endpoint를 운영 정보에 사용하며,
remote connector endpoint를 자동 게시하지 않는다.
다음 예제는 서로 다른 host 구성에서 같은 RouteMesh에 호출만 시작하는 node와 요청을 처리하는 node를
각각 등록하는 최소 형태다. clientOptions와 serverOptions는 각각 별도 host의
ZLinkFrameworkOptions다. 예제의 이름과 weight는 설명을 위한 값이며 계약 기본값을 뜻하지 않는다.
clientOptions.addRouteMesh("orders")
.channel("checkout")
.client(); // 이 node는 checkout 호출을 시작하지만 server 후보에는 포함되지 않는다.
serverOptions.addRouteMesh("orders")
.channel("checkout")
.server()
.setWeight(100)
.addRequestHandler(
CheckoutHandler.class,
CheckoutRequest.class,
CheckoutReply.class); // 이 node를 checkout 요청 처리 후보로 등록한다.
Automatic RouteMesh는 RID를 canonical byte order로 비교하고 더 작은 RID의 MeshNode만 상대 endpoint로 connect한다. Manual topology는 application endpoint 구성에 따라 한쪽 또는 양쪽에서 connect할 수 있다. 양쪽 연결이나 automatic discovery 경합·오래된 snapshot으로 중복 후보가 생기면 handshake와 admission이 같은 RID와 lifecycle generation을 확인해 하나만 ready 상태로 유지한다.
두 MeshNode의 object role이 모두 Client이고 양쪽 모두 RouteMesh Channel Server membership이 없을
때만 peer connection이 필요하지 않다. Channel Client membership만 등록한 경우도 같다. 어느 한쪽에라도
Channel Server membership이 있으면 weight가 0이어도 connection을 만들고 liveness를 유지한다.
ClientServer와 classic fanout registration은 별도 물리 topology이므로 이 판정에 포함하지 않는다.
ClientServer는 manual endpoint와 location store automatic discovery를 함께 사용할 수 있다. 두 source가 같은
Server RID와 lifecycle generation을 가리키면 connection intent와 ready target을 하나로 합친다. Automatic과
manual 모두 Client만 server로 connect하며 Server는 client endpoint를 찾거나 outbound connect를 시작하지
않는다. 같은 ChannelName에는 Client와 Server를 각각 한 번 등록할 수 있고 (ChannelName, Role) key의
별도 registration으로 하나의 ClientServer topology를 공유한다. 같은 역할을 두 번 등록하면 startup이
실패하며 RouteMesh ChannelName 충돌 규칙은
유지한다. Local Server도 listener와 service admission 뒤 remote Server와 같은 readiness·weight·drain
조건으로 선택하며 local 우선순위나 direct handler 호출을 사용하지 않는다.
Fanout에서는 Publisher가 descriptor만 게시하고 outbound connect를 시작하지 않는다. Subscriber만 publisher endpoint로 connect하며 automatic subscriber는 Publisher RID와 lifecycle generation마다 connection intent 하나를 만든다. 한 ChannelName에 automatic subscriber와 manual subscriber endpoint를 함께 구성하면 startup이 실패한다.
Object role을 생략하면 None이다. client()는 global object operation만 제공하고 placement target이 되지
않으며 server()는 Client capability와 Entry Spot·factory registration을 제공한다. Client와 Server는
Location Store가 필수다. Actor·User Spot·Instance Spot factory는 stable type과 configure callback을
반드시 받으며 relocation 동작 선택을 생략하는 overload는 없다.
Object Client에도 RouteMesh Channel Server를 등록할 수 있다. Application Node direct handler는 등록할 수 없으며 Object Client RID를 Node direct target으로 지정하면 다른 RID로 바꾸지 않고 not-found로 끝낸다.
Configure callback은 disableRelocation(), recreateOnRelocation(), preserveStateWith(...) 중 정확히 하나를
호출해야 한다. 누락하거나 둘 이상 호출하면 socket bind 전에 startup configuration error다. Actor builder는
같은 Actor type의 ZLinkActorRelocationAdapter, User·Instance Spot builder는 같은 Spot type의
ZLinkSpotRelocationAdapter만 받는다. 별도 등록 API는 없다.
Framework는 configure callback을 등록 호출 안에서 동기적으로 한 번만 실행한다. Callback이 반환된 뒤 보관한 builder를 다시 호출하면 configuration error다. Callback이 예외를 던지면 해당 factory를 등록하지 않고 같은 예외를 호출자에게 전달한다.
ZLinkUserSpotExecutionMode.PER_ACTOR는 recreateOnRelocation()만
허용한다. 다른 policy를 함께 등록하면 startup configuration
error다. PerActor Spot은 stateless execution shell이며 Actor policy와 adapter가
Actor state를 각각 처리한다.
relocationCoordinationMode의 기본값은 FRAMEWORK_MANAGED다.
APPLICATION_SIGNALED는 SPOT_WIDE에서만 허용하며 PER_ACTOR와 함께 등록하면
socket bind 전에 startup configuration error다. Spot callback은 default no-op
method이므로 application override는 필수가 아니다.
Node placement weight는 0..10000이고 기본값은 100이다. 범위 밖 값은 startup 설정과 runtime 변경에서
configuration error다. Node capacity 기본값은 active 10,000, pending 128이다.
Type별 limit을 생략하면 node limit을 공유한다. 명시한 값은 1..Integer.MAX_VALUE여야 하며 node limit보다
작은 값을 적용한다. stableTypeLimit(0)과 음수는 callback 실행 중 configuration error다. Capacity filter를
weight보다 먼저 적용한다.
enableActorDispatch()는 인자가 없으며 global ActorId가 Mesh를 resolve한다.
Object Server의 Entry Spot ID는 MeshNode diagnostic prefix를 사용한
<prefix>-entry-<lowercase-canonical-uuid-v4> 형식이며 MeshNode와 별도로 생성한 UUID v4를 사용한다.
Framework 내부 descriptor의 entrySpotId가 같은 lifecycle의 mapping을 제공한다. Global Spot ID가
active owner와 충돌하면 새 UUID로 다시 시도하지 않고 즉시 configuration exception으로 startup을
실패시킨다. Caller가 지정한 User·Instance Spot ID가 이 예약 형식과 일치하면 Store와 factory를 시작하기
전에 INVALID_OPERATION으로 거부한다.
Location provider는 ZLinkLocationStore를 통해 Framework의 opaque record read, version 조건부 atomic
batch와 bounded snapshot scan을 제공한다. 별도 domain별 Store instance를 host에 등록하지 않는다.
recreateOnRelocation() 또는 preserveStateWith(...)를
하나라도 선택했거나 Instance Spot factory를 하나라도 등록한 host는 ZLinkRelocationStore를 정확히 하나 등록한다.
Instance Spot factory가 없고 모든 factory가 disableRelocation()을 선택하며 same-node join만 사용하는 host는 Relocation Store가 없어도 된다.
Missing 또는 duplicate Store registration은 socket bind 전에 startup
configuration error다. Location과 Relocation capability를 함께 등록하는 API와 Redis 전용 registration helper는
제공하지 않는다.
ApplicationVersion은 0..Long.MAX_VALUE 범위의 배포 순번이다. 음수는 startup validation에서 거부한다.
Application traffic과 무관한 5초 periodic probe와 같은 current connection의 matching ACK 15초 deadline은
JVM service runtime의 고정 liveness profile이다. 다른 inbound frame은 deadline을 충족하지 않는다. 이 값을
Channel·handler·peer별 public option으로 노출하지 않는다. Location owner lease option은 별도 store 계약이며
transport liveness를 대신하지 않는다.
ZLinkMeshNodeSocketConfig는 RouteMesh SS의 Framework-level message-size 설정을 제공하지 않는다.
Sender와 receiver는 Framework-level complete-message 상한으로 message를 거부하지 않는다. Transport와
service-wire 표현 한계, HWM과 mailbox budget은 별도 자원·wire guard로 유지한다.
mailboxMessageBudget와 mailboxByteBudget은 owner별 application mailbox의 메시지 수와 byte 합계
상한이다. Byte 회계는 payload 크기만 세지 않는다 — payload 크기 + metadata 크기 + 작업당 고정 비용을
더한다. Payload가 비어 있어도 작업 하나는 0 byte가 아니며, 큰 payload에서도 고정 비용은 그대로
더한다. 합이 long 표현 범위를 넘으면 Long.MAX_VALUE로 고정하고 그 제출을 거절한다. 회계 규칙은
Framework API §8.2가 소유한다.
두 값은 startup 전에만 설정한다. 0은 unlimited가 아니라 Framework profile의 유한 기본값을
선택한다. 음수는 startup 설정 오류다. Logical Multicast의 local target도 이 용량 제한으로 admission을
판단한다.
setInstanceSpotIdleTimeout(...)은 유휴 Instance Spot 정리 기준 시간이다. 기본값은 Duration.ZERO이고
Duration.ZERO는 정리하지 않음을 뜻한다. 허용 범위는 Duration.ZERO와 양수이며 null과 음수는
startup 설정 오류다. 값은 MeshNode lifecycle 시작 전에 고정하고 runtime setter를 제공하지 않는다.
ZLinkWorkerOptions.idleTimeout(...)과는 별개의 설정이며 서로 값을 상속하지 않는다. 정리 대상은
Instance Spot뿐이고 Entry Spot과 User Spot은 이 설정의 영향을 받지 않는다. 유휴 판정 조건,
ZLinkSpotCloseReason.IDLE_EVICTED 전달과 정리 뒤 cold activation 규칙은
Spot 모델 §6.2가 소유한다.
Automatic RID는 prefix-<lowercase-canonical-uuid-v4> 형식이다. UUID v4는 8-4-4-4-12 자리의
lowercase canonical 문자열로 표현한다. Prefix는 ASCII [A-Za-z0-9._-] 1..64자이며 active
owner와 충돌하면 새 UUID로 다시 시도하지 않고 즉시
ROUTING_ID_CONFLICT로 실패한다. Fixed RID는 automatic discovery topology에서도, object role이 있는 MeshNode에서도 허용한다. 구현·시험 시나리오가 peer를 이름으로 지목해야 할 때가 있고, 자동 UUID로는 그럴 수 없기 때문이다. Fixed RID를 쓴 node가 재시작해 이전 active owner claim과 충돌하면 자동 RID와 같은 규칙으로 처리한다 — 새 값을 만들어 재시도하지 않고 즉시 conflict로 실패하며, 이전 owner lease가 만료된 뒤 재시작이 성공한다. Slot count, allocation group과 public allocation provider는 제공하지 않는다.
Framework가 모든 registration에서 만든 fully encoded MeshNode descriptor는 1 MiB 이하여야 한다. Spot type과 object capability collection은 각각 최대 1024개다. Relocation adapter class와 opaque application bytes는 peer descriptor에 게시하지 않는다. Runtime은 완성된 descriptor를 socket bind 전에 한 번에 검증한다. Bound를 넘으면 startup을 실패시키며 collection을 truncate·split하거나 descriptor 일부를 게시하지 않는다.
public member javap inventory¶
아래 선언은 javap가 출력하는 binary signature 형식으로 이 category의 Java public type과 member를 고정한다.
public interface systems.zlink.framework.spring.ZLinkFrameworkConfigurer {
public abstract void configure(systems.zlink.framework.configuration.ZLinkFrameworkOptions);
}
public interface systems.zlink.framework.configuration.ZLinkNetworkOptions {
public abstract java.lang.String bindHost();
public abstract void setBindHost(java.lang.String);
public abstract java.util.Optional<java.lang.String> advertiseHost();
public abstract void setAdvertiseHost(java.lang.String);
}
public interface systems.zlink.framework.configuration.FanoutChannelBuilder {
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder enablePublisher(java.lang.String);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder enablePublisher();
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder enablePublisher(int);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder setBindHost(java.lang.String);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder setAdvertiseHost(java.lang.String);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder setRoutingId(systems.zlink.contracts.core.RoutingId);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder setRoutingIdPrefix(java.lang.String);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder enableSubscriber();
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder connect(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkEndpointConnections subscriberConnections();
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder addHandlerGroup(java.lang.String);
public abstract void addPublishHandler(java.lang.Class<?>, java.lang.Class<?>);
public abstract void addPublishHandler(java.lang.Class<?>, java.lang.Class<?>, java.lang.String);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder addPublishHandler(java.lang.Class<?>);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder addPublishHandler(java.lang.Class<?>, java.lang.String);
}
public interface systems.zlink.framework.configuration.ZLinkCodecExtension {
public abstract void register(systems.zlink.framework.configuration.ZLinkCodecRegistrar);
}
public interface systems.zlink.framework.configuration.ZLinkCodecRegistrar {
public abstract void addSerializer(java.lang.String, systems.zlink.framework.ZLinkMessageSerializer);
public abstract void addSerializer(java.lang.String, systems.zlink.framework.ZLinkMessageSerializer, java.util.function.Predicate<java.lang.Class<?>>);
public abstract void addStreamCodec(java.lang.String, systems.zlink.framework.streams.ZLinkStreamCodec);
}
public interface systems.zlink.framework.configuration.ZLinkCodecRegistryBuilder {
public abstract void use(systems.zlink.framework.configuration.ZLinkCodecExtension);
}
public interface systems.zlink.framework.configuration.ZLinkDiagnosticsOptions {
public abstract systems.zlink.framework.configuration.ZLinkMessageFlowLogMode messageFlow();
public abstract double sampleRate();
public abstract boolean includeMessageSizes();
}
public final class systems.zlink.framework.configuration.ZLinkCoreHwmProfile extends java.lang.Enum<systems.zlink.framework.configuration.ZLinkCoreHwmProfile> {
public static final systems.zlink.framework.configuration.ZLinkCoreHwmProfile COMPACT;
public static final systems.zlink.framework.configuration.ZLinkCoreHwmProfile LOW_LATENCY;
public static final systems.zlink.framework.configuration.ZLinkCoreHwmProfile BALANCED;
public static final systems.zlink.framework.configuration.ZLinkCoreHwmProfile THROUGHPUT;
public static systems.zlink.framework.configuration.ZLinkCoreHwmProfile[] values();
public static systems.zlink.framework.configuration.ZLinkCoreHwmProfile valueOf(java.lang.String);
}
public final class systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile extends java.lang.Enum<systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile> {
public static final systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile COMPACT;
public static final systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile LOW_LATENCY;
public static final systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile BALANCED;
public static final systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile THROUGHPUT;
public static systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile[] values();
public static systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile valueOf(java.lang.String);
}
public interface systems.zlink.framework.configuration.ZLinkDispatchOptions {
public abstract systems.zlink.framework.configuration.ZLinkUnhandledDispatchOptions unhandled();
public abstract systems.zlink.framework.configuration.ZLinkDiagnosticsOptions diagnostics();
public abstract systems.zlink.framework.configuration.ZLinkDispatchOptions messageFlow(systems.zlink.framework.configuration.ZLinkMessageFlowLogMode);
public abstract systems.zlink.framework.configuration.ZLinkDispatchOptions traceSampleRate(double);
public abstract systems.zlink.framework.configuration.ZLinkDispatchOptions includeMessageSizes(boolean);
}
public interface systems.zlink.framework.configuration.ZLinkInboundDispatchOptions {
public abstract java.util.OptionalLong coreHwmMemoryLimitBytes();
public abstract void setCoreHwmMemoryLimitBytes(long);
public abstract java.util.OptionalLong coreHwmBudgetBytes();
public abstract void setCoreHwmBudgetBytes(long);
public abstract systems.zlink.framework.configuration.ZLinkCoreHwmProfile coreHwmProfile();
public abstract void setCoreHwmProfile(systems.zlink.framework.configuration.ZLinkCoreHwmProfile);
public abstract systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile applicationJobQueueProfile();
public abstract void setApplicationJobQueueProfile(systems.zlink.framework.configuration.ZLinkApplicationJobQueueProfile);
public abstract java.util.OptionalLong maxQueuedApplicationJobs();
public abstract void setMaxQueuedApplicationJobs(long);
public abstract int applicationJobQueuePauseThresholdPercent();
public abstract void setApplicationJobQueuePauseThresholdPercent(int);
public abstract int applicationJobQueueResumeThresholdPercent();
public abstract void setApplicationJobQueueResumeThresholdPercent(int);
}
public interface systems.zlink.framework.configuration.ZLinkEndpointConnections {
public abstract void connect(java.lang.String);
public abstract void disconnect(java.lang.String);
public abstract java.util.List<java.lang.String> listConnections();
}
public interface systems.zlink.framework.configuration.ZLinkMeshNodeSocketConfig {
public abstract long sendHighWaterMark();
public abstract void setSendHighWaterMark(long);
public abstract long receiveHighWaterMark();
public abstract void setReceiveHighWaterMark(long);
public abstract long mailboxMessageBudget();
public abstract void setMailboxMessageBudget(long);
public abstract long mailboxByteBudget();
public abstract void setMailboxByteBudget(long);
public abstract java.util.Optional<java.time.Duration> receiveTimeout();
public abstract void setReceiveTimeout(java.time.Duration);
public abstract java.util.Optional<java.time.Duration> sendTimeout();
public abstract void setSendTimeout(java.time.Duration);
}
public final class systems.zlink.framework.configuration.ZLinkMeshPeerConnection extends java.lang.Record {
public systems.zlink.framework.configuration.ZLinkMeshPeerConnection(java.lang.String, java.util.Optional<systems.zlink.contracts.core.RoutingId>);
public final java.lang.String toString();
public final int hashCode();
public final boolean equals(java.lang.Object);
public java.lang.String endpoint();
public java.util.Optional<systems.zlink.contracts.core.RoutingId> expectedRoutingId();
}
public interface systems.zlink.framework.configuration.ZLinkMeshPeerConnections {
public abstract void connect(java.lang.String);
public abstract void connect(systems.zlink.contracts.core.RoutingId, java.lang.String);
public abstract void disconnect(java.lang.String);
public abstract java.util.List<systems.zlink.framework.configuration.ZLinkMeshPeerConnection> listConnections();
}
public interface systems.zlink.framework.configuration.ZLinkMessageFlowControl {
public abstract void setMessageFlowMode(systems.zlink.framework.configuration.ZLinkMessageFlowLogMode);
public abstract systems.zlink.framework.configuration.ZLinkMessageFlowLogMode messageFlowMode();
}
public final class systems.zlink.framework.configuration.ZLinkMessageFlowLogMode extends java.lang.Enum<systems.zlink.framework.configuration.ZLinkMessageFlowLogMode> {
public static final systems.zlink.framework.configuration.ZLinkMessageFlowLogMode OFF;
public static final systems.zlink.framework.configuration.ZLinkMessageFlowLogMode ERRORS;
public static final systems.zlink.framework.configuration.ZLinkMessageFlowLogMode NORMAL;
public static final systems.zlink.framework.configuration.ZLinkMessageFlowLogMode DETAILED;
public static systems.zlink.framework.configuration.ZLinkMessageFlowLogMode[] values();
public static systems.zlink.framework.configuration.ZLinkMessageFlowLogMode valueOf(java.lang.String);
public int value();
}
public interface systems.zlink.framework.configuration.ZLinkMetadataPolicyBuilder {
public abstract systems.zlink.framework.configuration.ZLinkMetadataPolicyBuilder allowSessionToActor(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkMetadataPolicyBuilder allowActorToSession(java.lang.String);
}
public interface systems.zlink.framework.configuration.ZLinkSpotPublisherConfig {
public abstract long sendHighWaterMark();
public abstract void setSendHighWaterMark(long);
public abstract java.util.Optional<java.time.Duration> sendTimeout();
public abstract void setSendTimeout(java.time.Duration);
public abstract java.util.Optional<java.time.Duration> linger();
public abstract void setLinger(java.time.Duration);
}
public interface systems.zlink.framework.configuration.ZLinkStreamCompressionBuilder {
public abstract systems.zlink.framework.configuration.ZLinkStreamCompressionBuilder useDefault();
public abstract systems.zlink.framework.configuration.ZLinkStreamCompressionBuilder useLz4();
public abstract systems.zlink.framework.configuration.ZLinkStreamCompressionBuilder use(systems.zlink.framework.streams.ZLinkStreamCompressionCodec);
public abstract systems.zlink.framework.configuration.ZLinkStreamCompressionBuilder disable();
}
public interface systems.zlink.framework.configuration.ZLinkStreamNodeBuilder {
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder bind(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder bind();
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder bind(int);
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder setBindHost(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder setAdvertiseHost(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkStreamSocketConfig configureSocket();
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder setTlsServer(java.lang.String, java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder setTlsServer(java.lang.String, java.lang.String, boolean);
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder registerSession(java.lang.Class<? extends systems.zlink.framework.streams.ZLinkSession>);
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder enableActorDispatch();
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder addSessionPacketHandler(java.lang.Class<?>);
}
public interface systems.zlink.framework.configuration.ZLinkStreamSocketConfig {
public abstract long maxMessageSize();
public abstract void setMaxMessageSize(long);
}
public final class systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction extends java.lang.Enum<systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction> {
public static final systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction REPLY_ERROR;
public static final systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction LOG_AND_DROP;
public static final systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction DROP;
public static final systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction THROW;
public static systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction[] values();
public static systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction valueOf(java.lang.String);
public int value();
}
public interface systems.zlink.framework.configuration.ZLinkUnhandledDispatchOptions {
public abstract void setRequest(systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction);
public abstract void setSend(systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction);
public abstract void setPublish(systems.zlink.framework.configuration.ZLinkUnhandledDispatchAction);
public abstract void setSendLogLevel(systems.zlink.framework.configuration.ZLinkLogLevel);
public abstract void setPublishLogLevel(systems.zlink.framework.configuration.ZLinkLogLevel);
}
public interface systems.zlink.framework.configuration.ZLinkWorkerOptions {
public abstract systems.zlink.framework.configuration.ZLinkWorkerOptions minThreads(int);
public abstract systems.zlink.framework.configuration.ZLinkWorkerOptions maxThreads(int);
public abstract systems.zlink.framework.configuration.ZLinkWorkerOptions idleTimeout(java.time.Duration);
public abstract systems.zlink.framework.configuration.ZLinkWorkerOptions maxQueueLength(int);
}
ZLinkMessageFlowLogMode의 네 값은 진단 비활성화, 오류만 기록, 주요 전이 기록, 상세 진단을 각각
나타낸다. Startup에서 지정하지 않은 diagnostics level의 기본값은 ERRORS다. Framework는 application이
구성한 표준 logger·trace·metric provider에 structured record를
기록한다. Dispatch configuration의 diagnostics member는 level, sampling rate와 message size 포함 여부만 제공하며 file path,
label, exporter lifecycle 또는 provider sink를 받지 않는다. Message-flow observer callback, runtime error sink와 raw event DTO는 public contract가 아니다.
Provider 호출 실패는 원래 message operation의 terminal 결과를 바꾸지 않으며 별도 진단으로 격리한다.
ZLinkStreamNodeBuilder.configureSocket().setMaxMessageSize(...)의 기본값은 64 KiB다. 이
설정은 StreamNode의 Core STREAM inbound에서 client→server complete message를 검사할 때만
사용하며, 크기는 6-byte prefix를 제외한 header와 payload의 합이다. 0은 Core -1로
변환되어 Framework 상한을 사용하지 않고, 음수는 startup configuration error다. 상한을 넘은
message는 handler에 일부도 전달하지 않으며 server는 EMSGSIZE와 진단 trace를 남긴 뒤 연결을
종료한다. raw client는 별도 wire error code가 아니라 연결 종료를 관찰한다. server→client
outbound에는 이 Framework 상한을 적용하지 않으며 ClientServer와 RouteMesh SS에는 이 설정이 없다.
나머지 구성 public member javap inventory¶
아래 선언은 위 inventory에 포함하지 않은 application-facing configuration type을 javap가 출력하는
binary signature 형식으로 고정한다.
public interface systems.zlink.framework.configuration.ZLinkFrameworkOptions {
public abstract java.time.Duration defaultRequestTimeout();
public abstract void setDefaultRequestTimeout(java.time.Duration);
public abstract systems.zlink.framework.configuration.ZLinkCodecRegistryBuilder codecs();
public abstract void addHandlersFromPackageOf(java.lang.Class<?>);
public abstract systems.zlink.framework.configuration.ZLinkMetadataPolicyBuilder configureMetadata();
public abstract void addRelocationStore(systems.zlink.framework.locations.ZLinkRelocationStore);
public abstract void setApplicationVersion(long);
public abstract void setMaintenanceWave(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder addRouteMesh(java.lang.String);
public abstract systems.zlink.framework.configuration.ClientServerChannelBuilder addClientServerChannel(java.lang.String);
public abstract systems.zlink.framework.configuration.FanoutChannelBuilder addFanoutChannel(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkStreamNodeBuilder addStreamNode(java.lang.String);
public abstract void addLocationStore(systems.zlink.framework.locations.ZLinkLocationStore);
public abstract systems.zlink.framework.locations.ZLinkLocationOptions configureLocations();
public abstract systems.zlink.framework.configuration.ZLinkInboundDispatchOptions configureInboundDispatch();
public abstract systems.zlink.framework.configuration.ZLinkNetworkOptions configureNetwork();
public abstract void useFilter(java.lang.Class<? extends systems.zlink.framework.ZLinkHandlerFilter>);
public abstract systems.zlink.framework.configuration.ZLinkDispatchOptions configureDispatch();
public abstract systems.zlink.framework.configuration.ZLinkStreamCompressionBuilder configureStreamCompression();
public abstract systems.zlink.framework.configuration.ZLinkWorkerOptions configureWorkers();
public abstract void useVirtualThreadHandlers();
public abstract void useHandlerExecutor(java.util.concurrent.Executor);
}
public interface systems.zlink.framework.locations.ZLinkLocationOptions {
public abstract java.time.Duration ownerLeaseRenewInterval();
public abstract void setOwnerLeaseRenewInterval(java.time.Duration);
public abstract java.time.Duration ownerLeaseTtl();
public abstract void setOwnerLeaseTtl(java.time.Duration);
public abstract java.time.Duration pollingInterval();
public abstract void setPollingInterval(java.time.Duration);
public abstract java.time.Duration storeFailureGrace();
public abstract void setStoreFailureGrace(java.time.Duration);
public abstract java.time.Duration ownerLeaseFencingMargin();
public abstract void setOwnerLeaseFencingMargin(java.time.Duration);
public abstract java.time.Duration ownerLeaseRenewTimeout();
public abstract void setOwnerLeaseRenewTimeout(java.time.Duration);
public abstract java.time.Duration routeCacheMaxAge();
public abstract void setRouteCacheMaxAge(java.time.Duration);
public abstract java.time.Duration messageFollowDuration();
public abstract void setMessageFollowDuration(java.time.Duration);
public abstract java.time.Duration sessionRelocationSealTimeout();
public abstract void setSessionRelocationSealTimeout(java.time.Duration);
public abstract long relocationPayloadChunkLimitBytes();
public abstract void setRelocationPayloadChunkLimitBytes(long);
public abstract long relocationInFlightPayloadBudgetBytes();
public abstract void setRelocationInFlightPayloadBudgetBytes(long);
public abstract long relocationNodeInFlightPayloadBudgetBytes();
public abstract void setRelocationNodeInFlightPayloadBudgetBytes(long);
public abstract java.time.Duration relocationCutoverWaitTimeout();
public abstract void setRelocationCutoverWaitTimeout(java.time.Duration);
}
public final class systems.zlink.framework.configuration.ZLinkLogLevel extends java.lang.Enum<systems.zlink.framework.configuration.ZLinkLogLevel> {
public static final systems.zlink.framework.configuration.ZLinkLogLevel TRACE;
public static final systems.zlink.framework.configuration.ZLinkLogLevel DEBUG;
public static final systems.zlink.framework.configuration.ZLinkLogLevel INFO;
public static final systems.zlink.framework.configuration.ZLinkLogLevel WARN;
public static final systems.zlink.framework.configuration.ZLinkLogLevel ERROR;
public static systems.zlink.framework.configuration.ZLinkLogLevel[] values();
public static systems.zlink.framework.configuration.ZLinkLogLevel valueOf(java.lang.String);
public int value();
}
public interface systems.zlink.framework.configuration.ZLinkMeshNodeBuilder {
public abstract systems.zlink.framework.configuration.ZLinkMeshChannelBuilder channel(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder listen(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder listen();
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder listen(int);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setBindHost(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setAdvertiseHost(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setRoutingId(systems.zlink.contracts.core.RoutingId);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setRoutingIdPrefix(java.lang.String);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setPlacementWeight(int);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setActorCapacity(int);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setSpotCapacity(int);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setActivationConcurrency(int);
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setInstanceSpotIdleTimeout(java.time.Duration);
public abstract systems.zlink.framework.configuration.ZLinkMeshObjectRoleBuilder objects();
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeSocketConfig configureRouterSocket();
public abstract systems.zlink.framework.configuration.ZLinkSpotPublisherConfig configureSpotPublisher();
public abstract systems.zlink.framework.configuration.ZLinkMeshPeerConnections peerConnections();
public abstract systems.zlink.framework.configuration.ZLinkMeshNodeBuilder setDefaultRequestTimeout(java.time.Duration);
public abstract <THandler, TMessage> systems.zlink.framework.configuration.ZLinkMeshNodeBuilder addRouteSendHandler(java.lang.Class<THandler>, java.lang.Class<TMessage>);
public abstract <THandler, TRequest, TReply> systems.zlink.framework.configuration.ZLinkMeshNodeBuilder addRouteRequestHandler(java.lang.Class<THandler>, java.lang.Class<TRequest>, java.lang.Class<TReply>);
}
public interface systems.zlink.framework.configuration.ZLinkMeshObjectRoleBuilder {
public abstract systems.zlink.framework.configuration.ZLinkMeshObjectClientBuilder client();
public abstract systems.zlink.framework.configuration.ZLinkMeshObjectServerBuilder server();
}
public interface systems.zlink.framework.configuration.ZLinkMeshObjectClientBuilder {
}
public interface systems.zlink.framework.configuration.ZLinkMeshObjectServerBuilder {
public abstract systems.zlink.framework.configuration.ZLinkMeshObjectServerBuilder addEntrySpot(java.lang.Class<? extends systems.zlink.framework.spots.ZLinkEntrySpot<?>>);
public abstract <TSpot extends systems.zlink.framework.spots.ZLinkSpot<?>> systems.zlink.framework.configuration.ZLinkMeshObjectServerBuilder addSpotFactory(java.lang.String, java.lang.Class<TSpot>, java.util.function.Consumer<systems.zlink.framework.configuration.ZLinkUserSpotFactoryBuilder<TSpot>>);
public abstract <TSpot extends systems.zlink.framework.spots.ZLinkInstanceSpot> systems.zlink.framework.configuration.ZLinkMeshObjectServerBuilder addInstanceSpotFactory(java.lang.String, java.lang.Class<TSpot>, java.util.function.Consumer<systems.zlink.framework.configuration.ZLinkInstanceSpotFactoryBuilder<TSpot>>);
public abstract <TActor extends systems.zlink.framework.actors.ZLinkActor> systems.zlink.framework.configuration.ZLinkMeshObjectServerBuilder addActorFactory(java.lang.String, java.lang.Class<TActor>, java.lang.Class<? extends systems.zlink.framework.actors.ZLinkActorFactory>, java.util.function.Consumer<systems.zlink.framework.configuration.ZLinkActorFactoryBuilder<TActor>>);
}
public final class systems.zlink.framework.configuration.ZLinkUserSpotExecutionMode extends java.lang.Enum<systems.zlink.framework.configuration.ZLinkUserSpotExecutionMode> {
public static final systems.zlink.framework.configuration.ZLinkUserSpotExecutionMode SPOT_WIDE;
public static final systems.zlink.framework.configuration.ZLinkUserSpotExecutionMode PER_ACTOR;
public static systems.zlink.framework.configuration.ZLinkUserSpotExecutionMode[] values();
public static systems.zlink.framework.configuration.ZLinkUserSpotExecutionMode valueOf(java.lang.String);
public int value();
}
public final class systems.zlink.framework.configuration.ZLinkSpotRelocationCoordinationMode extends java.lang.Enum<systems.zlink.framework.configuration.ZLinkSpotRelocationCoordinationMode> {
public static final systems.zlink.framework.configuration.ZLinkSpotRelocationCoordinationMode FRAMEWORK_MANAGED;
public static final systems.zlink.framework.configuration.ZLinkSpotRelocationCoordinationMode APPLICATION_SIGNALED;
public static systems.zlink.framework.configuration.ZLinkSpotRelocationCoordinationMode[] values();
public static systems.zlink.framework.configuration.ZLinkSpotRelocationCoordinationMode valueOf(java.lang.String);
public int value();
}
public interface systems.zlink.framework.configuration.ZLinkActorFactoryBuilder<TActor extends systems.zlink.framework.actors.ZLinkActor> {
public abstract void disableRelocation();
public abstract void recreateOnRelocation();
public abstract void preserveStateWith(java.lang.Class<? extends systems.zlink.framework.actors.ZLinkActorRelocationAdapter<TActor>>);
}
public interface systems.zlink.framework.configuration.ZLinkUserSpotFactoryBuilder<TSpot extends systems.zlink.framework.spots.ZLinkSpot<?>> {
public abstract systems.zlink.framework.configuration.ZLinkUserSpotFactoryBuilder<TSpot> stableTypeLimit(int);
public abstract systems.zlink.framework.configuration.ZLinkUserSpotFactoryBuilder<TSpot> executionMode(systems.zlink.framework.configuration.ZLinkUserSpotExecutionMode);
public abstract systems.zlink.framework.configuration.ZLinkUserSpotFactoryBuilder<TSpot> relocationCoordinationMode(systems.zlink.framework.configuration.ZLinkSpotRelocationCoordinationMode);
public abstract void disableRelocation();
public abstract void recreateOnRelocation();
public abstract void preserveStateWith(java.lang.Class<? extends systems.zlink.framework.spots.ZLinkSpotRelocationAdapter<TSpot>>);
}
public interface systems.zlink.framework.configuration.ZLinkInstanceSpotFactoryBuilder<TSpot extends systems.zlink.framework.spots.ZLinkInstanceSpot> {
public abstract systems.zlink.framework.configuration.ZLinkInstanceSpotFactoryBuilder<TSpot> stableTypeLimit(int);
public abstract void disableRelocation();
public abstract void recreateOnRelocation();
public abstract void preserveStateWith(java.lang.Class<? extends systems.zlink.framework.spots.ZLinkSpotRelocationAdapter<TSpot>>);
}
public interface systems.zlink.framework.spring.EnableZLinkFramework extends java.lang.annotation.Annotation {
}
public interface systems.zlink.framework.spring.ZLinkMetricsCustomizer {
public abstract void customize(io.micrometer.core.instrument.MeterRegistry);
}
Spring bean 계약¶
Spring starter는 ZLinkFrameworkRuntime, ZLinkRouteMeshRuntime, ZLinkClientServerRuntime과
ZLinkFanoutRuntime을 singleton bean으로 제공한다. 세 topology bean은 runtime의 대응 accessor가 반환한
객체를 그대로 등록하므로 새 adapter나 별도 runtime을 만들지 않는다. Public client와 나머지 runtime service
bean도 같은 ZLinkFrameworkRuntime이 소유한 객체를 사용한다.
Bean을 생성하는 동안 service socket, discovery loop와 application worker를 시작하지 않는다.
SmartLifecycle.start()가 같은 runtime의 start를 한 번 호출한다. Application에 보장하는 계약은 public bean의
type, singleton 수명과 reference identity다. Auto-configuration class, bean factory method, lifecycle adapter와
그 constructor는 implementation detail이며 application public signature가 아니다.
Core의 internal bootstrap package는 starter module에만 qualified export한다. Application이 module path나
classpath에서 ZLinkFrameworkRuntime.start(...)를 호출하면 compile에 실패해야 한다. Contract test는
실제 module path에서 bootstrap을 호출하고 runtime이 SERVING에 도달하는지 확인한다.
Contract test는 네 runtime bean을 각각 두 번 resolve해 singleton인지 확인한다. 이어서 세 topology bean을
runtime.routeMeshRuntime(), runtime.clientServerRuntime()과 runtime.fanoutRuntime()의 반환값과
assertSame으로 비교한다. Lifecycle 회귀 test는 bean 생성 전후에 service socket이 시작되지 않고, start와
shutdown이 같은 ZLinkFrameworkRuntime에 한 번씩 전달되는지 확인한다.
Inbound queue와 Session seal option¶
Java binding은 양수 유한 Runtime.maxMemory()를 Core runtime memory hint로 전달한다. Core와 job queue
profile은 독립된 enum이며 둘 다 기본값은 BALANCED다. Manual job cap은 1..2,147,483,647이고 생략하면
common startup CPU snapshot과 32/64/128/256 계수를 사용한다. 범위 위반과 overflow는 bind 전에 실패하며
runtime 중 다시 계산하지 않는다.
sessionRelocationSealTimeout은 startup-only 양수 Duration, 기본값 3초다. Millisecond로 유한하게
표현할 수 없는 값도 bind 전에 실패한다.
relocationPayloadChunkLimitBytes은 relocation payload를 나눈 encoded chunk 하나의 최대 크기(byte)이고
기본값은 256 KiB다. Transport가 협상한 frame 한도를 넘게 설정하면 socket bind 전에 startup
configuration error다. relocationInFlightPayloadBudgetBytes은 peer 연결 하나에 대해 동시에 전송 중인
relocation chunk byte 합계의 상한이고 기본값은 16 MiB이며 0은 예산을 적용하지 않는다.
relocationNodeInFlightPayloadBudgetBytes은 같은 계상 규칙을 node 전체 합계에 적용하며 기본값 0은
미적용이다. relocationCutoverWaitTimeout은 target이 cutover를 기다리는 시간이자 source가 재전송용
boundary batch 사본을 유지하는 시간이고 기본값은 1초다. 네 값 모두 startup-only이며 음수는 socket
bind 전에 configuration error다.