Uses of Interface
com.ultikits.ultitools.websocket.CloudChannel

Packages that use CloudChannel

Package	Description
com.ultikits.ultitools.manager
com.ultikits.ultitools.utils
com.ultikits.ultitools.websocket	UltiPanel WebSocket client internals, and the three stable extension points modules use.

Uses of CloudChannel in com.ultikits.ultitools.manager

Fields in com.ultikits.ultitools.manager declared as CloudChannel

Modifier and Type	Field	Description
private CloudChannel	AgentOutboundFeeds.live	The live channel between a welcome and its close, or null.

Methods in com.ultikits.ultitools.manager with parameters of type CloudChannel

Modifier and Type	Method	Description
void	AgentOutboundFeeds.closed(CloudChannel channel)	A connection closed: nothing is sent until the next welcome, and the lines not yet sent are dropped (D-14).
private void	RemoteFileOperations.delete(CloudRequest request, CloudChannel channel)	Answers files.delete: removes one file, or one symbolic link as the link itself.
private boolean	AgentTelemetry.enabled(CloudChannel channel)
private static void	RemoteFileOperations.error(CloudChannel channel, String replyTo, String type, String code, String message)	Sends a correlated error for one result type.
private static void	RemotePropertiesHandler.error(CloudChannel channel, String replyTo, String type, String code, String message)	Sends a correlated error for one result type, capped at the contract's 500 code points.
void	AgentOutboundFeeds.established(CloudChannel channel, Executor agentThread, boolean logsAccepted)	A connection was established: its channel becomes the live one, the telemetry sends its opening snapshots, and the log capture is attached when the logs switch is on (again, if a logout detached it).
(package private) void	AgentLogBatcher.flush(CloudChannel channel)	Sends the buffered lines as one log.lines frame, if the channel can take it.
private void	RemotePropertiesHandler.get(CloudRequest request, CloudChannel channel)	Answers properties.get.
void	AgentTelemetry.handle(CloudRequest request, CloudChannel channel)	Handles snapshot.request: pushes the requested snapshots in request order and then answers snapshot.request.result with what was sent (SEMANTICS item 4, checker B-W3).
void	RemoteFileOperations.handle(CloudRequest request, CloudChannel channel)
void	RemotePropertiesHandler.handle(CloudRequest request, CloudChannel channel)
private void	RemoteFileOperations.list(CloudRequest request, CloudChannel channel)	Answers files.list: one directory's entries, with the size and modification time of files (null for directories), or — for the empty path — the configured editable roots, which is what the contract means by the server root: the panel may browse no further up than the operator's grant.
(package private) void	AgentTelemetry.onWelcome(CloudChannel channel)	Sends the four snapshots a fresh connection starts from: status, players.snapshot, plugins.snapshot and worlds.snapshot, in that order.
private void	RemoteFileOperations.read(CloudRequest request, CloudChannel channel)	Answers files.read: the file's content decoded as strict UTF-8, its size in bytes and the SHA-256 of exactly those bytes — the version a later files.write must send back as its baseVersion.
private void	RemoteFileOperations.refuseDelete(CloudChannel channel, String replyTo, String path, String code, String message)	Answers a refused files.delete and records it, as RemoteFileOperations.refuseWrite(com.ultikits.ultitools.websocket.CloudChannel, java.lang.String, java.lang.String, java.lang.String, java.lang.String) does.
private void	RemotePropertiesHandler.refuseGet(CloudChannel channel, String replyTo, String code, String message)	Answers a refused properties.get and records the same text, as RemotePropertiesHandler.refuseUpdate(com.ultikits.ultitools.websocket.CloudChannel, java.lang.String, java.lang.String, java.lang.String, java.lang.String) does.
private void	RemoteFileOperations.refuseList(CloudChannel channel, String replyTo, String path, String code, String message)	Answers a refused files.list and records it, as RemoteFileOperations.refuseRead(com.ultikits.ultitools.websocket.CloudChannel, java.lang.String, java.lang.String, java.lang.String, java.lang.String) does.
private void	RemoteFileOperations.refuseRead(CloudChannel channel, String replyTo, String path, String code, String message)	Answers a refused files.read and records it, as RemoteFileOperations.refuseWrite(com.ultikits.ultitools.websocket.CloudChannel, java.lang.String, java.lang.String, java.lang.String, java.lang.String) does.
private void	RemotePropertiesHandler.refuseUpdate(CloudChannel channel, String replyTo, String target, String code, String message)	Answers a refused properties.update and records the same text in the action log, so the log says what the operator was told.
private void	RemoteFileOperations.refuseWrite(CloudChannel channel, String replyTo, String path, String code, String message)	Answers a refused files.write and records the same text in the action log, so the log says what the operator was told.
private static boolean	AgentTelemetry.send(CloudChannel channel, String type, com.google.gson.JsonObject payload)
private static void	AgentTelemetry.sendChanged(CloudChannel channel, String type, Supplier<com.google.gson.JsonObject> payload, AgentTelemetry.Tracked track, long now)	Sends one snapshot when its mapped payload differs from the last one sent and at least 10000L ms have passed since that send.
private void	AgentOutboundFeeds.sendErrorReports(CloudChannel channel)	Sends what the collector grouped since the last second, while the errors switch is on.
private static boolean	AgentTelemetry.sendForced(CloudChannel channel, String type, Supplier<com.google.gson.JsonObject> payload, AgentTelemetry.Tracked track, long now)	Sends one snapshot regardless of the coalescing window, because the panel asked for it, and restarts that snapshot's window from now.
private void	AgentTelemetry.sendRequested(String replyTo, List<String> targets, CloudChannel channel)	Takes a fresh main-thread sample, then pushes the requested snapshots whether or not their content changed -- the panel asked for them -- and restarts each one's coalescing window from now, then answers the request.
private void	AgentTelemetry.sendWelcome(CloudChannel channel)
(package private) void	AgentTelemetry.tick(CloudChannel channel)	Advances the cadence; the session wiring calls this about once a second.
private void	RemotePropertiesHandler.update(CloudRequest request, CloudChannel channel)	Answers properties.update.
private void	RemoteFileOperations.write(CloudRequest request, CloudChannel channel)	Answers files.write: replaces an existing file's content when, and only when, the panel's baseVersion still equals the SHA-256 of the bytes on disk.

Uses of CloudChannel in com.ultikits.ultitools.utils

Classes in com.ultikits.ultitools.utils that implement CloudChannel

Modifier and Type	Class	Description
private final class	AgentProtocol.LiveChannel	The live channel: the framed channel, with the outbound capability gate in front.
(package private) final class	FramedChannel	Frames protocol replies over a socket handoff, enforcing correlation and UTF-8 frame limits.

Fields in com.ultikits.ultitools.utils declared as CloudChannel

Modifier and Type	Field	Description
private final CloudChannel	AgentProtocol.channel
private final CloudChannel	PlayerLinkChannel.Held.channel

Fields in com.ultikits.ultitools.utils with type parameters of type CloudChannel

Modifier and Type	Field	Description
private final Supplier<CloudChannel>	PlayerLinkChannel.channel

Methods in com.ultikits.ultitools.utils that return CloudChannel

Modifier and Type	Method	Description
(package private) CloudChannel	AgentProtocol.channel()
private CloudChannel	CloudFeatures.liveChannel()

Methods in com.ultikits.ultitools.utils with parameters of type CloudChannel

Modifier and Type	Method	Description
private void	PlayerLinkChannel.answer(CloudChannel connection, String id, com.google.gson.JsonObject result)
private boolean	PlayerLinkChannel.callHandler(CloudPlayerLinks.LinkEventHandler target, CloudPlayerLinks.LinkCompletion completion, CloudChannel connection, String id, Runnable exit)
private void	PlayerActionHandler.completeTeleport(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, Boolean completed, Throwable error)	Answers the teleport once its future completes.
private void	PlayerLinkChannel.deliver(CloudPlayerLinks.LinkCompletion completion, CloudChannel connection)	Delivers one completion to the module's handler, or answers it when no handler is set.
private void	PlayerActionHandler.deny(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, String code, String message)
private org.bukkit.Location	PlayerActionHandler.destination(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject)	Resolves the destination, answering player_not_online or world_not_found and returning null when the target cannot be resolved.
private void	AgentMessageRouter.dispatch(Envelope envelope, CloudChannel channel)
void	AgentMessageRouter.dispatch(String text, CloudChannel channel)	Parses and dispatches one frame, applying the capability gate before the handler.
private void	AgentMessageRouter.dispatchAdmitted(Envelope envelope, CloudChannel channel)
private void	RemoteConfigHandler.entries(CloudChannel channel, String replyTo, String path)
private void	AgentMessageRouter.error(CloudChannel channel, String id, String code, String message, com.google.gson.JsonObject details)
private void	AgentMessageRouter.error(CloudChannel channel, String id, String code, String message, com.google.gson.JsonObject details, String diagnostic)
default void	AgentProtocol.Listener.established(CloudChannel channel)
private void	PowerActionHandler.execute(CloudRequest request, CloudChannel channel, String action)	Runs once per newly recorded id: the operator switch, then (for a restart) the restart pre-check, then the result, the pre-shutdown hook and the scheduled power action in that order.
private void	PlayerActionHandler.fail(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, Throwable error)	Maps a throwing call to the contract's internal_error with one fixed message: the exception class and stack stay in the local log and never reach the wire, as in the agent router (22-08).
private void	RemoteConfigHandler.failed(CloudChannel channel, String replyTo, String type, RuntimeException failure)
(package private) static void	AckFirstGate.handle(CloudRequest request, CloudChannel channel, DedupeLedger ledger, Runnable execute)	Records and persists a new id under the shared ledger monitor, then releases the monitor before acknowledging and executing.
void	CredentialRotationHandler.handle(CloudRequest request, CloudChannel channel)
void	ModuleRequestHandler.handle(CloudRequest request, CloudChannel channel)	Validates one module.request and hands it to its owning module's responder.
void	PlayerActionHandler.handle(CloudRequest request, CloudChannel channel)	Validates the payload on the dispatching thread, then performs the action on the main thread.
void	PowerActionHandler.handle(CloudRequest request, CloudChannel channel)	Validates the action, then runs persist-acknowledge-execute.
void	RemoteCommandHandler.handle(CloudRequest request, CloudChannel channel)
private static void	SerialRequestWorker.handle(CloudRequestHandler handler, CloudRequest request, CloudChannel channel)
private void	RemoteConfigHandler.handleEntries(CloudRequest request, CloudChannel channel)	Answers one file's typed entries and the SHA-256 of its current bytes.
private void	RemoteConfigHandler.handleTree(CloudRequest request, CloudChannel channel)	Answers the configuration file tree: each loaded module with the files it registered.
private void	SerialRequestWorker.handleUnlessShuttingDown(CloudRequestHandler handler, CloudRequest request, CloudChannel channel)
private void	RemoteConfigHandler.handleUpdate(CloudRequest request, CloudChannel channel)	Writes exactly the keys a panel edit names, and only while the file still holds the bytes it read.
private static void	RemoteCommandHandler.internalError(CloudRequest request, CloudChannel channel, RuntimeException failure)
private void	PlayerLinkChannel.invokeHandler(CloudPlayerLinks.LinkEventHandler target, CloudPlayerLinks.LinkCompletion completion, CloudChannel connection, String id, Runnable exit)
private void	PlayerLinkChannel.onCompleted(CloudRequest request, CloudChannel connection)
private void	RemoteConfigHandler.onConfigThread(CloudChannel channel, String replyTo, String type, Runnable work)
private void	PlayerLinkChannel.onCreated(CloudRequest request, CloudChannel connection)
private void	PlayerLinkChannel.onExpired(CloudRequest request, CloudChannel connection)
private void	PlayerActionHandler.perform(CloudRequest request, CloudChannel channel, PlayerActionHandler.Action action)	Runs once per accepted request, on the main thread: resolve the subject, then act.
private void	AgentMessageRouter.refuse(CloudChannel channel, String id, String capability, String message)
(package private) void	ShutdownGate.refuse(CloudRequest request, CloudChannel channel)	Answers a covered request that was not let in.
private static void	RemoteConfigHandler.refuseUpdate(CloudChannel channel, String replyTo, RemoteConfigHandler.UpdateAudit audit, String code, String message)	Answers a refused config.update and records the same text as its one DENIED action-log entry, so the log says what the operator was told.
(package private) void	CloudFeatures.register(AgentMessageRouter router, CloudChannel channel, AgentProtocol protocol, CredentialRotationHandler.CredentialPersister rotation, ScheduledExecutorService agent)	Registers the inbound handlers on one connection's router and points the lifetime objects at that connection.
private static void	ModuleRequestHandler.reply(CloudChannel channel, String replyTo, com.google.gson.JsonElement result, Throwable failure)	Produces the request's single reply from the registry's outcome.
private void	CloudFeatures.reportSettingsIfChanged(CloudChannel channel)	The comparison and the mark happen under one monitor, with the hello's own mark, so a reload racing a hello can neither repeat a value nor lose one.
private void	PlayerActionHandler.runGameMode(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject)	Applies the requested game mode and reports it as done only when the player's mode now equals the requested one: another plugin may cancel the PlayerGameModeChangeEvent, and the platform discards that answer.
private void	PlayerActionHandler.runKick(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject)	Kicks with the reason as one plain-text component, or with the server's own default message when the panel sent no reason.
private void	PlayerActionHandler.runTeleport(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject)	Starts the asynchronous teleport and answers when its future completes.
private void	RemoteCommandHandler.runUnlessDisabling(Runnable action, CloudRequest request, CloudChannel channel)	Runs one step of the acknowledged request unless the plugin is disabling.
private static void	ModuleRequestHandler.sendInternalError(CloudChannel channel, String replyTo)	Answers internal_error once, and gives up quietly if the channel refuses that too.
private void	PlayerLinkChannel.sendResult(CloudChannel connection, String id, com.google.gson.JsonObject result)
private void	SerialRequestWorker.submit(CloudRequestHandler handler, CloudRequest request, CloudChannel channel)
private void	PlayerActionHandler.succeed(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action)
private void	RemoteConfigHandler.update(CloudChannel channel, String replyTo, String path, String baseVersion, List<RemoteConfigHandler.Change> changes, RemoteConfigHandler.UpdateAudit audit)
private void	RemoteConfigHandler.write(CloudChannel channel, String replyTo, RemoteConfigHandler.Registered registered, ConfigLoadResult loaded, List<RemoteConfigHandler.Change> changes, RemoteConfigHandler.UpdateAudit audit)

Constructors in com.ultikits.ultitools.utils with parameters of type CloudChannel

Modifier	Constructor	Description
private	Held(CloudPlayerLinks.LinkCompletion completion, CloudChannel channel)

Constructor parameters in com.ultikits.ultitools.utils with type arguments of type CloudChannel

Modifier	Constructor	Description
(package private)	PlayerLinkChannel(Supplier<CloudChannel> channel, DedupeLedger ledger, BooleanSupplier onlineMode, LongSupplier gatewayClockOffsetMillis, ScheduledExecutorService timers, Executor handlerThread)	Binds the channel to one connection's suppliers and to the shared session ledger.
(package private)	PlayerLinkChannel(Supplier<CloudChannel> channel, DedupeLedger ledger, BooleanSupplier onlineMode, LongSupplier gatewayClockOffsetMillis, ScheduledExecutorService timers, Executor handlerThread, ShutdownGate.Signal shutdown)

Uses of CloudChannel in com.ultikits.ultitools.websocket

Methods in com.ultikits.ultitools.websocket with parameters of type CloudChannel

Modifier and Type	Method	Description
void	CloudRequestHandler.handle(CloudRequest request, CloudChannel channel)	Validates the payload and handles it on the dispatching thread.