Index

A B C D E F G H I L M N O P R S T U V W Y А К О 
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 callsFailed record component.
callsStarted() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
Returns the value of the callsStarted record component.
callsSucceeded() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
Returns the value of the callsSucceeded record component.
callsTimedOut() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
Returns the value of the callsTimedOut record 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 channelDowns record 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 channelUps record 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 code record 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 drainFinishes record component.
drainStarts() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
Returns the value of the drainStarts record 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 message record 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 protocolHandshakeFailures record component.
protocolHandshakeStarts() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
Returns the value of the protocolHandshakeStarts record component.
protocolHandshakeSuccesses() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
Returns the value of the protocolHandshakeSuccesses record 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 reconnectAttempts record component.
reconnectFailures() - Method in record class ru.pathcreator.pyc.rpc.metrics.RpcMetricsSnapshot
Returns the value of the reconnectFailures record 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 reconnectSuccesses record 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 remoteErrors record component.
remoteProtocolCapabilities() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
Returns the negotiated remote capability bitmask, or 0 when the optional handshake has not completed yet.
remoteProtocolVersion() - Method in class ru.pathcreator.pyc.rpc.core.RpcChannel
Returns the negotiated remote protocol version, or 0 when 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 RpcMetricsSnapshot record 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 RpcValidationIssue record 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
 
A B C D E F G H I L M N O P R S T U V W Y А К О 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form