Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- ACCEPTED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
202 Accepted / принято в обработку.
- acquire() - Method in class ru.pathcreator.pyc.rpc.core.internal.OffloadTask.Pool
-
Берет задачу из пула или создает новую при временном переполнении.
- acquire() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCallPool
-
Берет слот из пула или создает новый при временном переполнении.
- actual() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.PayloadTooLargeException
-
Возвращает фактический размер payload, который был отклонен.
- aeronDir() - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig
-
Возвращает Aeron directory.
- aeronDir(String) - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig.Builder
-
Задаёт Aeron directory, через который узел подключается к MediaDriver.
- ALREADY_REPORTED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
208 Already Reported / уже сообщено.
- analyze() - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Performs non-fatal startup-time analysis and returns advisory issues that may still be worth reviewing before a service starts taking traffic.
- await(PendingCall, long) - Method in class ru.pathcreator.pyc.rpc.core.internal.SyncWaiter
-
Ожидает завершения вызова до истечения таймаута.
- awaitDrained(long, TimeUnit) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Waits until the channel has no in-flight client calls and no in-flight server handlers.
B
- BACKOFF - Enum constant in enum class ru.pathcreator.pyc.rpc.core.IdleStrategyKind
-
Backoff-стратегия Agrona: spin, затем yield, затем park.
- BackpressureException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Исключение, которое сигнализирует, что сообщение не удалось отправить из-за backpressure.
- BackpressureException(String) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.BackpressureException
-
Создаёт исключение с описанием причины backpressure.
- backpressurePolicy() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает политику обработки backpressure.
- backpressurePolicy(BackpressurePolicy) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает политику обработки backpressure.
- BackpressurePolicy - Enum Class in ru.pathcreator.pyc.rpc.core
-
Политика поведения, когда Aeron publication остается back-pressured дольше
offerTimeout. - BAD_GATEWAY - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
502 Bad Gateway / плохой gateway.
- BAD_REQUEST - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
400 Bad Request / некорректный запрос.
- beginDrain() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Enables drain mode for this channel.
- BLOCK - Enum constant in enum class ru.pathcreator.pyc.rpc.core.BackpressurePolicy
-
Ждать, пока publication снова сможет принять сообщение, или до истечения
offerTimeout. - build() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Проверяет настройки и создает неизменяемую конфигурацию канала.
- build() - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig.Builder
-
Проверяет настройки и создаёт immutable node configuration.
- build() - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry.Builder
-
Builds an immutable registry snapshot after validating the collected channel entries.
- builder() - Static method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Создает builder конфигурации канала.
- builder() - Static method in class ru.pathcreator.pyc.rpc.core.NodeConfig
-
Создаёт builder конфигурации узла.
- builder() - Static method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Creates a new registry builder.
- Builder() - Constructor for class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Создает builder с настройками по умолчанию.
- Builder() - Constructor for class ru.pathcreator.pyc.rpc.core.NodeConfig.Builder
-
Создаёт builder с настройками по умолчанию.
- BUSY_SPIN - Enum constant in enum class ru.pathcreator.pyc.rpc.core.IdleStrategyKind
-
Постоянный busy-spin без yield и park.
C
- call(int, int, Req, MessageCodec, MessageCodec) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Выполняет синхронный RPC-вызов с таймаутом и backpressure-политикой из конфигурации канала.
- call(int, int, Req, MessageCodec, MessageCodec, long, TimeUnit) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Выполняет синхронный RPC-вызов с явным таймаутом.
- call(int, int, Req, MessageCodec, MessageCodec, long, BackpressurePolicy) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Выполняет синхронный RPC-вызов с явным таймаутом в наносекундах и политикой backpressure.
- call(RpcChannel, Req) - Method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Вызывает метод через указанный канал с default timeout канала.
- call(RpcChannel, Req, long, TimeUnit) - Method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Вызывает метод через указанный канал с явным timeout.
- callsFailed() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
callsFailedrecord component. - callsStarted() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
callsStartedrecord component. - callsSucceeded() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
callsSucceededrecord component. - callsTimedOut() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
callsTimedOutrecord component. - channel(String, ChannelConfig) - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry.Builder
-
Adds a logical channel entry to the registry.
- channel(ChannelConfig) - Method in class ru.pathcreator.pyc.rpc.core.RpcNode
-
Создаёт новый канал и добавляет его в node-owned список каналов.
- ChannelConfig - Class in ru.pathcreator.pyc.rpc.core
-
Конфигурация одного RPC-канала.
- ChannelConfig.Builder - Class in ru.pathcreator.pyc.rpc.core
-
Builder для создания
ChannelConfig. - channelCount() - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Returns the number of logical channels present in the registry.
- channelDowns() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
channelDownsrecord component. - channels() - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Returns the immutable list of registered channel schema entries.
- channelUps() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
channelUpsrecord component. - close() - Method in class ru.pathcreator.pyc.rpc.core.internal.HeartbeatManager
-
Останавливает heartbeat-поток и ожидает его завершения.
- close() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Закрывает канал, завершает ожидающие вызовы и освобождает Aeron-ресурсы.
- close() - Method in class ru.pathcreator.pyc.rpc.core.RpcNode
-
Закрывает каналы, Aeron client, optional MediaDriver и shared executor.
- closeGracefully(long, TimeUnit) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Starts drain mode, waits for in-flight work to finish, and closes the channel.
- code() - Method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns the numeric status code.
- code() - Method in record class ru.pathcreator.pyc.rpc.schema.RpcValidationIssue
-
Returns the value of the
coderecord component. - completedCalls() - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
-
Возвращает суммарное число terminal local call outcome-ов.
- completedCalls() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Возвращает суммарное число terminal local call outcomes.
- completeFail(String) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Завершает вызов ошибкой и пробуждает ожидающий поток.
- completeFail(RpcException) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Завершает вызов структурированной ошибкой и пробуждает ожидающий поток.
- completeOk(DirectBuffer, int, int) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Записывает успешный результат и пробуждает ожидающий поток.
- config() - Method in class ru.pathcreator.pyc.rpc.schema.RpcChannelSchema
-
Возвращает конфигурацию канала для этой schema entry.
- CONFLICT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
409 Conflict / конфликт.
- CONTINUE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
100 Continue / продолжайте запрос.
- correlationId() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcTimeoutException
-
Возвращает correlation id запроса, который завершился по timeout.
- correlationId() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Возвращает correlation id связанного запроса.
- correlationId(DirectBuffer, int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Читает транспортный идентификатор корреляции из envelope.
- CorrelationIdGenerator - Class in ru.pathcreator.pyc.rpc.core.internal
-
Генератор монотонно возрастающих транспортных идентификаторов корреляции.
- CorrelationIdGenerator() - Constructor for class ru.pathcreator.pyc.rpc.core.internal.CorrelationIdGenerator
-
Создает генератор идентификаторов корреляции.
- CREATED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
201 Created / создано.
D
- decode(DirectBuffer, int, int) - Method in interface ru.pathcreator.pyc.rpc.core.codec.MessageCodec
-
Декодирует сообщение из диапазона buffer-а.
- DEFAULT_MAX_MESSAGE_SIZE - Static variable in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Максимальный размер одного transport message по умолчанию, 16 MiB.
- defaultTimeout() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает таймаут RPC-вызова по умолчанию.
- defaultTimeout(Duration) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает таймаут RPC-вызова по умолчанию.
- deltaSince(RpcMetricsSnapshot) - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Возвращает delta-snapshot как разницу между текущим snapshot и baseline.
- description() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает optional human-readable описание метода.
- DIRECT_EXECUTOR - Static variable in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Маркерное значение для режима "выполнять handler прямо в RX-пути".
- drainFinishes() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
drainFinishesrecord component. - drainStarts() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
drainStartsrecord component.
E
- EARLY_HINTS - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
103 Early Hints / ранние подсказки.
- embeddedDriver() - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig
-
Возвращает, должен ли узел поднять собственный embedded MediaDriver.
- embeddedDriver(boolean) - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig.Builder
-
Задаёт, нужно ли запускать embedded MediaDriver внутри этого process-а.
- encode(MutableDirectBuffer, int, int, long, int, int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Записывает envelope в указанный буфер, начиная с заданного смещения.
- encode(T, MutableDirectBuffer, int) - Method in interface ru.pathcreator.pyc.rpc.core.codec.MessageCodec
-
Кодирует сообщение в переданный buffer.
- Envelope - Class in ru.pathcreator.pyc.rpc.core.envelope
-
Фиксированный транспортный заголовок RPC-протокола.
- EnvelopeCodec - Class in ru.pathcreator.pyc.rpc.core.envelope
-
Кодек для прямого чтения и записи envelope без создания дополнительных объектов.
- equals(Object) - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class ru.pathcreator.pyc.rpc.schema.RpcValidationIssue
-
Indicates whether some other object is "equal to" this one.
- execute(int, long, UnsafeBuffer, int, Object) - Method in interface ru.pathcreator.pyc.rpc.core.internal.OffloadTask.Body
-
Выполняет обработку одного входящего запроса.
- EXPECTATION_FAILED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
417 Expectation Failed / expectation не выполнена.
- expectedResponseTypeId() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Возвращает ожидаемый response message type id.
F
- FAIL_FAST - Enum constant in enum class ru.pathcreator.pyc.rpc.core.BackpressurePolicy
-
Сразу завершиться ошибкой при первой же backpressure-неудаче.
- FAIL_FAST - Enum constant in enum class ru.pathcreator.pyc.rpc.core.ReconnectStrategy
-
Сразу завершить вызов ошибкой, если канал не connected.
- FAILED_DEPENDENCY - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
424 Failed Dependency / ошибка зависимости.
- failure() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Возвращает исключение, сохраненное для вызова.
- failureReason() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Возвращает причину ошибочного завершения.
- FLAG_IS_ERROR - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Флаг, помечающий envelope как structured remote error response.
- FLAG_IS_HEARTBEAT - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Флаг, помечающий envelope как heartbeat frame.
- FLAG_IS_REQUEST - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Флаг, помечающий envelope как RPC-запрос.
- flags(DirectBuffer, int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Читает битовые флаги из envelope.
- FORBIDDEN - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
403 Forbidden / доступ запрещен.
- forEachAndClear(Consumer) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCallRegistry
-
Применяет действие ко всем ожидающим вызовам и очищает реестр.
- FOUND - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
302 Found / временно найдено.
- fromCode(int) - Static method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Resolves a numeric code into a known status when possible.
G
- GATEWAY_TIMEOUT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
504 Gateway Timeout / таймаут gateway.
- GONE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
410 Gone / ресурс удален.
H
- handle(DirectBuffer, int, int, MutableDirectBuffer, int, int) - Method in interface ru.pathcreator.pyc.rpc.core.RawRequestHandler
-
Обрабатывает raw-запрос и пишет raw-ответ.
- handle(Req) - Method in interface ru.pathcreator.pyc.rpc.core.RequestHandler
-
Обрабатывает запрос и возвращает ответ.
- hashCode() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns a hash code value for this object.
- hashCode() - Method in record class ru.pathcreator.pyc.rpc.schema.RpcValidationIssue
-
Returns a hash code value for this object.
- heartbeatInterval() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает интервал heartbeat.
- heartbeatInterval(Duration) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает интервал heartbeat.
- HeartbeatManager - Class in ru.pathcreator.pyc.rpc.core.internal
-
Управляет heartbeat-состоянием RPC-канала.
- HeartbeatManager(String, long, int, LongConsumer, Runnable, Runnable) - Constructor for class ru.pathcreator.pyc.rpc.core.internal.HeartbeatManager
-
Создает менеджер heartbeat-состояния.
- heartbeatMissedLimit() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает допустимое число пропущенных heartbeat-интервалов.
- heartbeatMissedLimit(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает допустимое число пропущенных heartbeat-интервалов.
- HTTP_VERSION_NOT_SUPPORTED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
505 HTTP Version Not Supported / версия HTTP не поддерживается.
I
- I_AM_A_TEAPOT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
418 I'm a Teapot / шуточный HTTP статус.
- IdleStrategyKind - Enum Class in ru.pathcreator.pyc.rpc.core
-
Выбор idle-стратегии для receive и вспомогательных polling loops.
- IM_USED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
226 IM Used / использован IM.
- init(OffloadTask.Body, int, long, UnsafeBuffer, int, Object, OffloadTask.Pool) - Method in class ru.pathcreator.pyc.rpc.core.internal.OffloadTask
-
Инициализирует задачу перед передачей в executor.
- INSUFFICIENT_STORAGE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
507 Insufficient Storage / недостаточно хранилища.
- INTERNAL_SERVER_ERROR - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
500 Internal Server Error / внутренняя ошибка сервера.
- isClientError() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RemoteRpcException
-
Возвращает, относится ли remote status к built-in client-error диапазону.
- isClientError() - Method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns whether the status belongs to the 4xx client-error range.
- isCompleted() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Проверяет, был ли вызов завершен.
- isConnected() - Method in class ru.pathcreator.pyc.rpc.core.internal.HeartbeatManager
-
Проверяет, считается ли удаленная сторона подключенной.
- isConnected() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Проверяет, считается ли канал подключенным по состоянию publication и heartbeat.
- isDirectExecutor() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Проверяет, настроено ли выполнение обработчиков прямо в rx-потоке.
- isDraining() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Returns whether the channel is currently in drain mode.
- isEmpty() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Возвращает, равны ли все счетчики в snapshot нулю.
- isError(int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Checks whether the error flag is set.
- isFailed() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Проверяет, завершился ли вызов ошибкой.
- isHeartbeat(int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Проверяет, установлен ли флаг heartbeat-кадра.
- isInformational() - Method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns whether the status belongs to the 1xx informational range.
- isProtocolHandshakeComplete() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Returns whether the optional protocol handshake has already completed.
- isRedirect() - Method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns whether the status belongs to the 3xx redirection range.
- isRequest(int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Проверяет, установлен ли флаг RPC-запроса.
- isRetryable() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RemoteRpcException
-
Возвращает, считается ли remote status retryable.
- isRetryable() - Method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns whether the status is commonly retryable for transport callers.
- isServerError() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RemoteRpcException
-
Возвращает, относится ли remote status к built-in server-error диапазону.
- isServerError() - Method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns whether the status belongs to the 5xx server-error range.
- isSuccess() - Method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns whether the status belongs to the 2xx success range.
L
- LENGTH - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Размер заголовка envelope в байтах.
- LENGTH_REQUIRED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
411 Length Required / нужен Content-Length.
- limit() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.PayloadTooLargeException
-
Возвращает лимит размера payload для канала.
- listener(RpcChannelListener) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Adds an optional listener for channel events.
- listeners() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Returns the configured optional channel listeners.
- localEndpoint() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает локальный UDP endpoint канала.
- localEndpoint(String) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает локальный endpoint канала.
- LOCKED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
423 Locked / заблокировано.
- LOOP_DETECTED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
508 Loop Detected / обнаружен цикл.
M
- magic(DirectBuffer, int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Читает сигнатуру протокола из envelope.
- MAGIC - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Фиксированная сигнатура протокола в начале каждого envelope.
- maxMessageSize() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает максимальный размер сообщения.
- maxMessageSize(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает максимальный размер сообщения.
- message() - Method in record class ru.pathcreator.pyc.rpc.schema.RpcValidationIssue
-
Returns the value of the
messagerecord component. - MessageCodec<T> - Interface in ru.pathcreator.pyc.rpc.core.codec
-
Абстракция сериализации payload для RPC-ядра.
- messageTypeId(DirectBuffer, int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Читает идентификатор типа сообщения из envelope.
- method() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает underlying typed RPC method descriptor.
- method(String, RpcMethod) - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry.ChannelBuilder
-
Adds a method definition when explicit request and response Java type names are not needed.
- method(String, RpcMethod, Class, Class) - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry.ChannelBuilder
-
Adds a typed method definition with explicit request and response type names.
- method(String, RpcMethod, Class, Class, String, String) - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry.ChannelBuilder
-
Adds a typed method definition with optional version and description metadata.
- METHOD_NOT_ALLOWED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
405 Method Not Allowed / метод не поддерживается.
- methodCount() - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Returns the total number of registered methods across all channels.
- methods() - Method in class ru.pathcreator.pyc.rpc.schema.RpcChannelSchema
-
Возвращает immutable-список методов, зарегистрированных для канала.
- MISDIRECTED_REQUEST - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
421 Misdirected Request / запрос адресован не туда.
- MOVED_PERMANENTLY - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
301 Moved Permanently / постоянно перемещено.
- mtuLength() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает MTU канала.
- mtuLength(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает MTU канала.
- MULTI_STATUS - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
207 Multi-Status / множественный статус.
- MULTIPLE_CHOICES - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
300 Multiple Choices / несколько вариантов.
N
- name() - Method in class ru.pathcreator.pyc.rpc.schema.RpcChannelSchema
-
Возвращает логическое имя канала внутри registry.
- name() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает логическое имя метода в registry.
- NETWORK_AUTHENTICATION_REQUIRED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
511 Network Authentication Required / требуется сетевая авторизация.
- next() - Method in class ru.pathcreator.pyc.rpc.core.internal.CorrelationIdGenerator
-
Возвращает следующий идентификатор корреляции.
- NO_CONTENT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
204 No Content / нет тела ответа.
- NodeConfig - Class in ru.pathcreator.pyc.rpc.core
-
Конфигурация корневого
RpcNode. - NodeConfig.Builder - Class in ru.pathcreator.pyc.rpc.core
-
Builder для создания
NodeConfig. - NON_AUTHORITATIVE_INFORMATION - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
203 Non-Authoritative Information / неавторитативная информация.
- NOT_ACCEPTABLE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
406 Not Acceptable / неприемлемо.
- NOT_EXTENDED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
510 Not Extended / не продлено.
- NOT_FOUND - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
404 Not Found / не найдено.
- NOT_IMPLEMENTED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
501 Not Implemented / не реализовано.
- NOT_MODIFIED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
304 Not Modified / не изменено.
- NotConnectedException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Исключение, которое сообщает, что RPC-канал сейчас не connected к peer-у.
- NotConnectedException(String) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.NotConnectedException
-
Создаёт исключение с описанием причины отсутствия соединения.
O
- of(int, int, MessageCodec, MessageCodec) - Static method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Создаёт typed-описание одного RPC метода.
- offerTimeout() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает таймаут ожидания отправки при backpressure.
- offerTimeout(Duration) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает таймаут ожидания отправки при backpressure.
- offloadCopyBufferSize() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает размер одного буфера копирования для offload.
- offloadCopyBufferSize(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает размер одного буфера копирования для offload.
- offloadCopyPoolSize() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает размер пула буферов копирования для offload.
- offloadCopyPoolSize(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает размер пула буферов копирования для offload.
- offloadExecutor() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает executor для offload-обработчиков.
- offloadExecutor(ExecutorService) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает executor для offload-обработчиков.
- OffloadTask - Class in ru.pathcreator.pyc.rpc.core.internal
-
Переиспользуемая задача для выполнения серверных обработчиков в OFFLOAD-режиме.
- OffloadTask() - Constructor for class ru.pathcreator.pyc.rpc.core.internal.OffloadTask
-
Создает пустую offload-задачу для последующей инициализации.
- OffloadTask.Body - Interface in ru.pathcreator.pyc.rpc.core.internal
-
Callback с телом выполнения offload-задачи.
- OffloadTask.Pool - Class in ru.pathcreator.pyc.rpc.core.internal
-
Пул переиспользуемых
OffloadTaskэкземпляров. - offloadTaskPoolSize() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает размер пула offload-задач.
- offloadTaskPoolSize(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает размер пула offload-задач.
- OFFSET_CORRELATION_ID - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Смещение поля correlation id внутри envelope, в байтах.
- OFFSET_FLAGS - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Смещение поля флагов внутри envelope, в байтах.
- OFFSET_MAGIC - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Смещение поля
Envelope.MAGICвнутри envelope, в байтах. - OFFSET_MESSAGE_TYPE - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Смещение поля идентификатора типа сообщения внутри envelope, в байтах.
- OFFSET_PAYLOAD_LEN - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Смещение поля длины payload внутри envelope, в байтах.
- OFFSET_VERSION - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Смещение поля
Envelope.VERSIONвнутри envelope, в байтах. - OK - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
200 OK / успех.
- onCallFailed(RpcChannel, int, long, RpcException) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при локальном сбое client-side call.
- onCallFailed(RpcChannel, int, long, RpcException) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onCallStarted(RpcChannel, int, long) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при старте client-side call.
- onCallStarted(RpcChannel, int, long) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onCallSucceeded(RpcChannel, int, long) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при успешном завершении client-side call.
- onCallSucceeded(RpcChannel, int, long) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onCallTimedOut(RpcChannel, int, long, long) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при timeout client-side call.
- onCallTimedOut(RpcChannel, int, long, long) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onChannelDown(RpcChannel) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается, когда канал считается down.
- onChannelDown(RpcChannel) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onChannelUp(RpcChannel) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается, когда канал считается поднятым.
- onChannelUp(RpcChannel) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onDrainFinished(RpcChannel) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается по завершении drain mode.
- onDrainFinished(RpcChannel) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onDrainStarted(RpcChannel) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при старте drain mode.
- onDrainStarted(RpcChannel) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onHeartbeatReceived() - Method in class ru.pathcreator.pyc.rpc.core.internal.HeartbeatManager
-
Отмечает получение heartbeat-кадра от удаленной стороны.
- onProtocolHandshakeFailed(RpcChannel, RpcException) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при провале protocol handshake.
- onProtocolHandshakeFailed(RpcChannel, RpcException) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onProtocolHandshakeStarted(RpcChannel) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при старте protocol handshake.
- onProtocolHandshakeStarted(RpcChannel) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onProtocolHandshakeSucceeded(RpcChannel, int, long) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при успешном protocol handshake.
- onProtocolHandshakeSucceeded(RpcChannel, int, long) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onRaw(int, int, RawRequestHandler) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Регистрирует raw-обработчик для указанного типа запроса.
- onReconnectAttempt(RpcChannel, ReconnectStrategy) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при попытке reconnect/recovery.
- onReconnectAttempt(RpcChannel, ReconnectStrategy) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onReconnectFailed(RpcChannel, ReconnectStrategy, Throwable) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при неуспешном reconnect/recovery.
- onReconnectFailed(RpcChannel, ReconnectStrategy, Throwable) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onReconnectSucceeded(RpcChannel, ReconnectStrategy) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при успешном reconnect/recovery.
- onReconnectSucceeded(RpcChannel, ReconnectStrategy) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onRemoteError(RpcChannel, int, long, RpcException) - Method in interface ru.pathcreator.pyc.rpc.core.RpcChannelListener
-
Вызывается при structured remote error от другой стороны.
- onRemoteError(RpcChannel, int, long, RpcException) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
- onRequest(int, int, MessageCodec, MessageCodec, RequestHandler) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Регистрирует high-level обработчик с кодеками запроса и ответа.
P
- PARTIAL_CONTENT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
206 Partial Content / частичное содержимое.
- PAYLOAD_TOO_LARGE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
413 Payload Too Large / payload слишком большой.
- payloadLength(DirectBuffer, int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Читает длину полезной нагрузки из envelope.
- PayloadTooLargeException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Исключение, которое сигнализирует, что payload превышает лимит канала.
- PayloadTooLargeException(int, int) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.PayloadTooLargeException
-
Создаёт исключение с фактическим размером payload и лимитом.
- PAYMENT_REQUIRED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
402 Payment Required / требуется оплата.
- PendingCall - Class in ru.pathcreator.pyc.rpc.core.internal
-
Слот состояния для одного ожидающего синхронного RPC-вызова.
- PendingCall() - Constructor for class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Создает пустой slot ожидающего RPC-вызова.
- PendingCallPool - Class in ru.pathcreator.pyc.rpc.core.internal
-
Пул переиспользуемых
PendingCallобъектов. - PendingCallPool(int) - Constructor for class ru.pathcreator.pyc.rpc.core.internal.PendingCallPool
-
Создает пул с заранее выделенными слотами.
- PendingCallRegistry - Class in ru.pathcreator.pyc.rpc.core.internal
-
Реестр ожидающих RPC-вызовов по correlation id.
- PendingCallRegistry(int) - Constructor for class ru.pathcreator.pyc.rpc.core.internal.PendingCallRegistry
-
Создает реестр ожидающих вызовов.
- pendingPoolCapacity() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает емкость пула ожидающих вызовов.
- pendingPoolCapacity(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает емкость пула ожидающих вызовов.
- PERMANENT_REDIRECT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
308 Permanent Redirect / постоянный редирект.
- Pool(int) - Constructor for class ru.pathcreator.pyc.rpc.core.internal.OffloadTask.Pool
-
Создает пул с заранее выделенными задачами.
- PRECONDITION_FAILED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
412 Precondition Failed / precondition не выполнена.
- PRECONDITION_REQUIRED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
428 Precondition Required / требуется precondition.
- prepare(Thread, long) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Подготавливает слот перед регистрацией в реестре ожидающих вызовов.
- prepare(Thread, long, int) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Подготавливает слот перед регистрацией в реестре ожидающих вызовов.
- PROCESSING - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
102 Processing / запрос обрабатывается.
- protocolCapabilities() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Returns the local capability bitmask advertised by this channel.
- protocolCapabilities(long) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Sets the local capability bitmask advertised by this channel.
- protocolHandshakeEnabled() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Returns whether the optional protocol compatibility handshake is enabled.
- protocolHandshakeEnabled(boolean) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Enables or disables the optional protocol compatibility handshake.
- protocolHandshakeFailures() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
protocolHandshakeFailuresrecord component. - protocolHandshakeStarts() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
protocolHandshakeStartsrecord component. - protocolHandshakeSuccesses() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
protocolHandshakeSuccessesrecord component. - protocolHandshakeTimeout() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Returns the timeout used by the optional protocol handshake.
- protocolHandshakeTimeout(Duration) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Sets the timeout used by the optional protocol handshake.
- ProtocolMismatchException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Исключение, которое сигнализирует о несовместимости peers на этапе optional protocol handshake.
- ProtocolMismatchException(String) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.ProtocolMismatchException
-
Создаёт исключение с описанием несовместимости.
- protocolVersion() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Returns the local protocol version advertised by this channel.
- protocolVersion(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Sets the local protocol version advertised by this channel.
- PROXY_AUTHENTICATION_REQUIRED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
407 Proxy Authentication Required / нужна proxy-авторизация.
R
- RANGE_NOT_SATISFIABLE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
416 Range Not Satisfiable / range невозможно удовлетворить.
- RawRequestHandler - Interface in ru.pathcreator.pyc.rpc.core
-
Низкоуровневый zero-allocation handler для сырых request/response байтов.
- reconnectAttempts() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
reconnectAttemptsrecord component. - reconnectFailures() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
reconnectFailuresrecord component. - reconnectNow(long, TimeUnit) - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Explicitly triggers reconnect handling according to the configured
ReconnectStrategy. - reconnectStrategy() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Returns the reconnect behavior used when a call starts or a publish attempt happens while the channel is temporarily disconnected.
- reconnectStrategy(ReconnectStrategy) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Sets how the channel should behave when a call begins or a publish attempt occurs while the underlying transport is not connected.
- ReconnectStrategy - Enum Class in ru.pathcreator.pyc.rpc.core
-
Стратегия поведения, когда вызов стартует при временно disconnected канале.
- reconnectSuccesses() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
reconnectSuccessesrecord component. - RECREATE_ON_DISCONNECT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.ReconnectStrategy
-
Пересоздать локальную пару publication/subscription при disconnect, а затем ждать, пока пересозданный путь станет connected.
- register(long, PendingCall) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCallRegistry
-
Регистрирует ожидающий вызов по correlation id.
- register(RpcChannel, RequestHandler) - Method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Регистрирует handler этого метода на указанном канале.
- registryInitialCapacity() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает начальную емкость реестра ожидающих вызовов.
- registryInitialCapacity(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает начальную емкость реестра ожидающих вызовов.
- release(OffloadTask) - Method in class ru.pathcreator.pyc.rpc.core.internal.OffloadTask.Pool
-
Возвращает задачу в пул.
- release(PendingCall) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCallPool
-
Сбрасывает слот и возвращает его в пул.
- remoteEndpoint() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает удаленный UDP endpoint канала.
- remoteEndpoint(String) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает удаленный endpoint канала.
- remoteErrors() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns the value of the
remoteErrorsrecord component. - remoteProtocolCapabilities() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Returns the negotiated remote capability bitmask, or
0when the optional handshake has not completed yet. - remoteProtocolVersion() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Returns the negotiated remote protocol version, or
0when the optional handshake has not completed yet. - RemoteRpcException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Исключение, которое наблюдает caller, когда другая сторона вернула structured remote error.
- RemoteRpcException(int, String) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RemoteRpcException
-
Создаёт remote-исключение с кодом статуса и текстом ошибки.
- remove(long) - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCallRegistry
-
Удаляет и возвращает ожидающий вызов по correlation id.
- renderJsonReport() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Рендерит snapshot как compact JSON document.
- renderJsonReport() - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Renders the registry as a compact JSON document suitable for logging, diagnostics, or writing to a file.
- renderTextReport() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Рендерит snapshot как читаемый multi-line report.
- renderTextReport() - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Renders a readable multi-line report for logs, startup diagnostics, or deployment review.
- REQUEST_HEADER_FIELDS_TOO_LARGE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
431 Request Header Fields Too Large / заголовки слишком большие.
- REQUEST_TIMEOUT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
408 Request Timeout / таймаут запроса.
- requestCodec() - Method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Возвращает codec запроса.
- RequestHandler<Req,
Resp> - Interface in ru.pathcreator.pyc.rpc.core -
High-level handler, который получает уже декодированный запрос и возвращает объект ответа.
- requestMessageTypeId() - Method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Возвращает messageTypeId запроса.
- requestMessageTypeId() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает request message type id.
- requestTypeName() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает имя Java-типа запроса, если оно было передано в registry.
- requiredRemoteCapabilities() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Returns the required remote capability bits when the optional handshake is enabled.
- requiredRemoteCapabilities(long) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Sets the capability bitmask that must be present on the remote side when the optional protocol handshake is enabled.
- RESERVED_HEARTBEAT - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Зарезервированный тип сообщения для heartbeat frame-ов.
- RESERVED_PROTOCOL_HANDSHAKE - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Зарезервированный тип сообщения для optional protocol handshake frame-ов.
- reset() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Сбрасывает слот перед возвратом в пул.
- reset() - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
-
Сбрасывает все счётчики в ноль.
- RESET_CONTENT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
205 Reset Content / сброс содержимого.
- responseBuffer() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Возвращает буфер с payload ответа.
- responseCodec() - Method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Возвращает codec ответа.
- responseLength() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCall
-
Возвращает длину payload ответа.
- responseMessageTypeId() - Method in class ru.pathcreator.pyc.rpc.core.RpcMethod
-
Возвращает messageTypeId ответа.
- responseMessageTypeId() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает response message type id.
- responseTypeName() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает имя Java-типа ответа, если оно было передано в registry.
- RpcApplicationException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Исключение, которое server-side application code может выбросить, чтобы вернуть caller-у structured remote error.
- RpcApplicationException(int, String) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcApplicationException
-
Создаёт application exception с custom application code.
- RpcApplicationException(int, String, Throwable) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcApplicationException
-
Создаёт application exception с custom application code и cause.
- RpcApplicationException(RpcStatus, String) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcApplicationException
-
Создаёт application exception с predefined status.
- RpcApplicationException(RpcStatus, String, Throwable) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcApplicationException
-
Создаёт application exception с predefined status и cause.
- RpcChannel - Class in ru.pathcreator.pyc.rpc.core
-
Один двунаправленный RPC-канал поверх Aeron. / One bidirectional RPC channel over Aeron.
- RpcChannel(ChannelConfig, Aeron, ExecutorService) - Constructor for class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Создаёт RPC-канал поверх указанного Aeron-клиента.
- RpcChannelListener - Interface in ru.pathcreator.pyc.rpc.core
-
Опциональный listener для событий жизненного цикла, ошибок и recovery канала.
- RpcChannelSchema - Class in ru.pathcreator.pyc.rpc.schema
-
Immutable channel-level schema snapshot, используемый в
RpcServiceRegistry. - RpcException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Базовое unchecked-исключение для ошибок RPC-слоя.
- RpcException(String) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcException
-
Создаёт исключение с текстовым описанием ошибки.
- RpcException(String, Throwable) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcException
-
Создаёт исключение с текстовым описанием ошибки и исходной причиной.
- RpcMethod<Req,
Resp> - Class in ru.pathcreator.pyc.rpc.core -
Опциональная typed-обёртка над низкоуровневым API
RpcChannel. - RpcMethodSchema - Class in ru.pathcreator.pyc.rpc.schema
-
Startup-time metadata одного метода, используемая в
RpcServiceRegistry. - RpcMetricsListener - Class in ru.pathcreator.pyc.rpc.metrics
-
Готовый listener-backed collector простых метрик для
rpc-core. - RpcMetricsListener() - Constructor for class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
-
Создаёт пустой metrics listener с нулевыми счётчиками.
- RpcMetricsSnapshot - Record Class in ru.pathcreator.pyc.rpc.metrics
-
Immutable snapshot listener-based RPC метрик.
- RpcMetricsSnapshot(long, long, long, long, long, long, long, long, long, long, long, long, long, long, long) - Constructor for record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Creates an instance of a
RpcMetricsSnapshotrecord class. - RpcNode - Class in ru.pathcreator.pyc.rpc.core
-
Корневой RPC-объект на один процесс.
- RpcServiceRegistry - Class in ru.pathcreator.pyc.rpc.schema
-
Optional startup-time registry for channel and method definitions.
- RpcServiceRegistry.Builder - Class in ru.pathcreator.pyc.rpc.schema
-
Builder для сборки immutable registry снимка до старта сервиса.
- RpcServiceRegistry.ChannelBuilder - Class in ru.pathcreator.pyc.rpc.schema
-
Builder одной logical channel entry внутри registry.
- RpcStatus - Enum Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Встроенные RPC status code-ы для transport-слоя и общих service-level ошибок.
- RpcTimeoutException - Exception Class in ru.pathcreator.pyc.rpc.core.exceptions
-
Исключение, которое сообщает, что RPC-вызов не завершился в пределах timeout.
- RpcTimeoutException(long, long) - Constructor for exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcTimeoutException
-
Создаёт timeout-исключение для конкретного correlation id.
- RpcValidationIssue - Record Class in ru.pathcreator.pyc.rpc.schema
-
Non-fatal startup-time validation issue, обнаруженная optional schema-layer.
- RpcValidationIssue(String, String) - Constructor for record class ru.pathcreator.pyc.rpc.schema.RpcValidationIssue
-
Creates an instance of a
RpcValidationIssuerecord class. - ru.pathcreator.pyc.rpc.core - package ru.pathcreator.pyc.rpc.core
- ru.pathcreator.pyc.rpc.core.codec - package ru.pathcreator.pyc.rpc.core.codec
- ru.pathcreator.pyc.rpc.core.envelope - package ru.pathcreator.pyc.rpc.core.envelope
- ru.pathcreator.pyc.rpc.core.exceptions - package ru.pathcreator.pyc.rpc.core.exceptions
- ru.pathcreator.pyc.rpc.core.internal - package ru.pathcreator.pyc.rpc.core.internal
- ru.pathcreator.pyc.rpc.metrics - package ru.pathcreator.pyc.rpc.metrics
- ru.pathcreator.pyc.rpc.schema - package ru.pathcreator.pyc.rpc.schema
- run() - Method in class ru.pathcreator.pyc.rpc.core.internal.OffloadTask
-
Выполняет задачу и возвращает ее в пул после завершения.
- rxIdleStrategy() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает idle-стратегию rx-потока.
- rxIdleStrategy(IdleStrategyKind) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает idle-стратегию rx-потока.
S
- SEE_OTHER - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
303 See Other / смотри другое.
- SERVICE_UNAVAILABLE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
503 Service Unavailable / сервис недоступен.
- sessionId() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает Aeron session id.
- sessionId(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает Aeron session id.
- sharedReceivePoller() - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig
-
Возвращает, должны ли каналы этого узла использовать shared receive poller вместо отдельного RX thread на каждый канал.
- sharedReceivePoller(boolean) - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig.Builder
-
Включает или отключает shared receive poller для каналов, созданных этим узлом.
- sharedReceivePollerFragmentLimit() - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig
-
Возвращает fragment limit, который использует каждый shared poller lane за один проход polling loop-а.
- sharedReceivePollerFragmentLimit(int) - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig.Builder
-
Задаёт fragment limit, который использует каждый shared poller lane на каждой итерации polling loop-а.
- sharedReceivePollerThreads() - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig
-
Возвращает число shared receive-poller lanes, создаваемых на каждый
IdleStrategyKind. - sharedReceivePollerThreads(int) - Method in class ru.pathcreator.pyc.rpc.core.NodeConfig.Builder
-
Задаёт число shared receive-poller lanes на каждый
IdleStrategyKind. - size() - Method in class ru.pathcreator.pyc.rpc.core.internal.PendingCallRegistry
-
Возвращает текущее количество ожидающих вызовов.
- snapshot() - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
-
Возвращает стабильную snapshot-копию текущих счётчиков.
- snapshotAndReset() - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
-
Возвращает текущий snapshot и сразу сбрасывает все счётчики.
- socketRcvBuf() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает размер socket receive buffer.
- socketRcvBuf(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает размер socket receive buffer.
- socketSndBuf() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает размер socket send buffer.
- socketSndBuf(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает размер socket send buffer.
- start() - Method in class ru.pathcreator.pyc.rpc.core.internal.HeartbeatManager
-
Запускает фоновый heartbeat-поток.
- start() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
-
Запускает receive path канала и heartbeat.
- start(NodeConfig) - Static method in class ru.pathcreator.pyc.rpc.core.RpcNode
-
Запускает RPC node с заданной конфигурацией.
- status() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RemoteRpcException
-
Возвращает известный built-in статус для этого кода, если он есть.
- statusCode() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RemoteRpcException
-
Возвращает числовой remote status code.
- statusCode() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcApplicationException
-
Возвращает числовой status code, который должен уйти remote-side.
- streamId() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает Aeron stream id.
- streamId(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает Aeron stream id.
- SWITCHING_PROTOCOLS - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
101 Switching Protocols / переключение протокола.
- SyncWaiter - Class in ru.pathcreator.pyc.rpc.core.internal
-
Ожидатель завершения
PendingCallс таймаутом. - SyncWaiter() - Constructor for class ru.pathcreator.pyc.rpc.core.internal.SyncWaiter
-
Профиль по умолчанию для hot RPC на localhost или low-latency LAN.
- SyncWaiter(int, int, long) - Constructor for class ru.pathcreator.pyc.rpc.core.internal.SyncWaiter
-
Создает ожидатель с явными лимитами spin/yield/park фаз.
T
- TEMPORARY_REDIRECT - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
307 Temporary Redirect / временный редирект.
- termLength() - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig
-
Возвращает длину term buffer.
- termLength(int) - Method in class ru.pathcreator.pyc.rpc.core.ChannelConfig.Builder
-
Задает длину term buffer.
- timeoutNs() - Method in exception class ru.pathcreator.pyc.rpc.core.exceptions.RpcTimeoutException
-
Возвращает timeout ожидания в наносекундах.
- TOO_EARLY - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
425 Too Early / слишком рано.
- TOO_MANY_REQUESTS - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
429 Too Many Requests / слишком много запросов.
- toString() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
-
Returns a string representation of this record class.
- toString() - Method in record class ru.pathcreator.pyc.rpc.schema.RpcValidationIssue
-
Returns a string representation of this record class.
U
- UNAUTHORIZED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
401 Unauthorized / не авторизовано.
- UNAVAILABLE_FOR_LEGAL_REASONS - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
451 Unavailable For Legal Reasons / недоступно по юридическим причинам.
- UNPROCESSABLE_ENTITY - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
422 Unprocessable Entity / невозможно обработать сущность.
- UNSUPPORTED_MEDIA_TYPE - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
415 Unsupported Media Type / неподдерживаемый media type.
- UPGRADE_REQUIRED - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
426 Upgrade Required / требуется upgrade.
- URI_TOO_LONG - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
414 URI Too Long / URI слишком длинный.
- USE_PROXY - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
305 Use Proxy / используй proxy.
V
- valueOf(String) - Static method in enum class ru.pathcreator.pyc.rpc.core.BackpressurePolicy
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class ru.pathcreator.pyc.rpc.core.IdleStrategyKind
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class ru.pathcreator.pyc.rpc.core.ReconnectStrategy
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class ru.pathcreator.pyc.rpc.core.BackpressurePolicy
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class ru.pathcreator.pyc.rpc.core.IdleStrategyKind
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class ru.pathcreator.pyc.rpc.core.ReconnectStrategy
-
Returns an array containing the constants of this enum class, in the order they are declared.
- VARIANT_ALSO_NEGOTIATES - Enum constant in enum class ru.pathcreator.pyc.rpc.core.exceptions.RpcStatus
-
506 Variant Also Negotiates / variant некорректно negotiates.
- version() - Method in class ru.pathcreator.pyc.rpc.schema.RpcMethodSchema
-
Возвращает optional logical version метода.
- version(DirectBuffer, int) - Static method in class ru.pathcreator.pyc.rpc.core.envelope.EnvelopeCodec
-
Читает версию формата из envelope.
- VERSION - Static variable in class ru.pathcreator.pyc.rpc.core.envelope.Envelope
-
Текущая версия формата envelope.
W
- WAIT_FOR_CONNECTION - Enum constant in enum class ru.pathcreator.pyc.rpc.core.ReconnectStrategy
-
Ждать, пока текущие Aeron publication и heartbeat снова станут connected.
- writeJsonReport(Path) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
-
Пишет текущий JSON report в указанный файл.
- writeJsonReport(Path) - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Writes the JSON report to the provided file path, creating parent directories when needed.
- writeTextReport(Path) - Method in class ru.pathcreator.pyc.rpc.metrics.RpcMetricsListener
-
Пишет текущий text report в указанный файл.
- writeTextReport(Path) - Method in class ru.pathcreator.pyc.rpc.schema.RpcServiceRegistry
-
Writes the text report to the provided file path, creating parent directories when needed.
Y
- YIELDING - Enum constant in enum class ru.pathcreator.pyc.rpc.core.IdleStrategyKind
-
Вызывает
Thread.yield()во время простоя без park.
А
- Архитектура / Architecture - Section in class ru.pathcreator.pyc.rpc.core.RpcChannel
К
- Ключевые свойства / Key properties - Section in class ru.pathcreator.pyc.rpc.core.RpcChannel
О
- Основные группы настроек / Main setting groups - Section in class ru.pathcreator.pyc.rpc.core.ChannelConfig
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form