Package de.kentoj.scrowlib.servermanager

Class ServerManagerImpl

java.lang.Object

de.kentoj.scrowlib.servermanager.ServerManagerImpl

All Implemented Interfaces:

ServerManager

public class ServerManagerImpl
extends Object
implements ServerManager

Constructor Summary

Constructors

Constructor	Description
ServerManagerImpl(io.nats.client.Connection nats)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<@NotNull ServerInstance>	deployServer(String template)
reactor.core.publisher.Mono<@NotNull Void>	destroyServer(String handle)	Attempts a clean shutdown, if that doesn't succeed, kills the server.
reactor.core.publisher.Mono<@NotNull ServerInstance>	getInfo(String handle)
reactor.core.publisher.Flux<@NotNull ServerInstance>	getRunningServers()
reactor.core.publisher.Mono<@NotNull Void>	sendPlayer(UUID playerId, String serverHandle)
reactor.core.publisher.Mono<@NotNull Void>	setState(String handle, String state)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ServerManagerImpl

public ServerManagerImpl(io.nats.client.Connection nats)

Method Details

deployServer

public reactor.core.publisher.Mono<@NotNull ServerInstance> deployServer(String template)

Specified by:

deployServer in interface ServerManager

Returns:

Mono with handle of deployed server

getRunningServers

public reactor.core.publisher.Flux<@NotNull ServerInstance> getRunningServers()

Specified by:

getRunningServers in interface ServerManager

Returns:

Flux with handles of running servers

destroyServer

public reactor.core.publisher.Mono<@NotNull Void> destroyServer(String handle)

Description copied from interface: ServerManager

Attempts a clean shutdown, if that doesn't succeed, kills the server.

Specified by:

destroyServer in interface ServerManager

getInfo

public reactor.core.publisher.Mono<@NotNull ServerInstance> getInfo(String handle)

Specified by:

getInfo in interface ServerManager

setState

public reactor.core.publisher.Mono<@NotNull Void> setState(String handle,
 String state)

Specified by:

setState in interface ServerManager

sendPlayer

public reactor.core.publisher.Mono<@NotNull Void> sendPlayer(UUID playerId,
 String serverHandle)

Specified by:

sendPlayer in interface ServerManager