Package de.kentoj.scrowlib.servermanager

Class CrownServerManager

java.lang.Object

de.kentoj.scrowlib.servermanager.CrownServerManager

All Implemented Interfaces:

ServerManager

public class CrownServerManager
extends Object
implements ServerManager

Constructor Summary

Constructors

Constructor	Description
CrownServerManager(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>	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

CrownServerManager

public CrownServerManager(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