shared/ru.hytalemodding.lineage.shared.command/ProxyCommandRegistryProtocol

ProxyCommandRegistryProtocol

object ProxyCommandRegistryProtocol

Properties

DEFAULT_TTL_MILLIS

const val DEFAULT_TTL_MILLIS: Long

MAX_PACKET_BYTES

const val MAX_PACKET_BYTES: Int

REGISTRY_CHANNEL_ID

const val REGISTRY_CHANNEL_ID: String

REQUEST_CHANNEL_ID

const val REQUEST_CHANNEL_ID: String

const val VERSION: Byte = 2

Functions

fun decodeRequest(payload: ByteArray): ProxyCommandRegistryRequest?

fun decodeSnapshot(payload: ByteArray): ProxyCommandRegistrySnapshot?

fun encodeRequest(senderId: String = "backend", issuedAtMillis: Long = System.currentTimeMillis(), ttlMillis: Long = DEFAULT_TTL_MILLIS): ByteArray

fun encodeSnapshot(commands: List<ProxyCommandDescriptor>, senderId: String = "proxy", issuedAtMillis: Long = System.currentTimeMillis(), ttlMillis: Long = DEFAULT_TTL_MILLIS): ByteArray

hasSupportedVersion

fun hasSupportedVersion(payload: ByteArray): Boolean

fun peekVersion(payload: ByteArray): Int?