Package | Description |
---|---|
com.suse.salt.netapi.calls | |
com.suse.salt.netapi.client | |
com.suse.salt.netapi.parser | |
com.suse.salt.netapi.results |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletionStage<java.util.Optional<java.util.Map<java.lang.String,java.util.concurrent.CompletionStage<Result<R>>>>> |
LocalCall.callAsync(java.util.function.Function<LocalCall<R>,java.util.concurrent.CompletionStage<java.util.Optional<LocalAsyncResult<R>>>> localAsync,
java.util.function.Function<RunnerCall<java.util.Map<java.lang.String,R>>,java.util.concurrent.CompletionStage<RunnerAsyncResult<java.util.Map<java.lang.String,R>>>> runnerAsync,
EventStream events,
java.util.concurrent.CompletionStage<GenericError> cancel)
Calls this salt call via the async client and returns the results
as they come in via the event stream.
|
java.util.concurrent.CompletionStage<java.util.Optional<java.util.Map<java.lang.String,java.util.concurrent.CompletionStage<Result<R>>>>> |
LocalCall.callAsync(SaltClient client,
Target<?> target,
AuthMethod auth,
EventStream events,
java.util.concurrent.CompletionStage<GenericError> cancel,
Batch batch)
Calls this salt call via the async client and returns the results
as they come in via the event stream.
|
java.util.concurrent.CompletionStage<java.util.Optional<java.util.Map<java.lang.String,java.util.concurrent.CompletionStage<Result<R>>>>> |
LocalCall.callAsync(SaltClient client,
Target<?> target,
AuthMethod auth,
EventStream events,
java.util.concurrent.CompletionStage<GenericError> cancel,
java.util.Optional<Batch> batch)
Calls this salt call via the async client and returns the results
as they come in via the event stream.
|
java.util.concurrent.CompletionStage<WheelResult<Result<R>>> |
WheelCall.callSync(SaltClient client,
AuthMethod auth)
Calls a wheel module function on the master and synchronously
waits for the result.
|
java.util.concurrent.CompletionStage<Result<R>> |
RunnerCall.callSync(SaltClient client,
AuthMethod auth)
Calls a runner module function on the master and synchronously
waits for the result.
|
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,Result<R>>> |
LocalCall.callSync(SaltClient client,
Target<?> target,
AuthMethod auth)
Calls a execution module function on the given target and synchronously
waits for the result.
|
java.util.concurrent.CompletionStage<java.util.List<java.util.Map<java.lang.String,Result<R>>>> |
LocalCall.callSync(SaltClient client,
Target<?> target,
AuthMethod auth,
Batch batch)
Calls a execution module function on the given target with batching and
synchronously waits for the result.
|
java.util.concurrent.CompletionStage<java.util.List<java.util.Map<java.lang.String,Result<R>>>> |
LocalCall.callSync(SaltClient client,
Target<?> target,
AuthMethod auth,
java.util.Optional<Batch> batch)
Calls a execution module function on the given target with batching and
synchronously waits for the result.
|
private java.util.concurrent.CompletionStage<java.util.List<java.util.Map<java.lang.String,Result<R>>>> |
LocalCall.callSyncHelperNonBlock(SaltClient client,
Target<?> target,
AuthMethod auth,
java.util.Optional<Batch> batch)
Helper to call an execution module function on the given target for batched or
unbatched while also providing an option to use the given credentials or to use a
prior created token.
|
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,Result<SSHResult<R>>>> |
LocalCall.callSyncSSH(SaltClient client,
SSHTarget<?> target,
SaltSSHConfig cfg,
AuthMethod auth)
Call an execution module function on the given target via salt-ssh and synchronously
wait for the result.
|
private java.util.List<java.util.Map<java.lang.String,Result<R>>> |
LocalCall.handleRetcodeBatchingHack(java.util.List<java.util.Map<java.lang.String,Result<R>>> list,
java.lang.reflect.Type xor) |
Modifier and Type | Method and Description |
---|---|
private java.util.List<java.util.Map<java.lang.String,Result<R>>> |
LocalCall.handleRetcodeBatchingHack(java.util.List<java.util.Map<java.lang.String,Result<R>>> list,
java.lang.reflect.Type xor) |
private static <R> void |
LocalCall.onJobReturn(java.lang.String jid,
JobReturnEvent jre,
com.google.gson.reflect.TypeToken<Result<R>> tt,
java.util.Map<java.lang.String,java.util.concurrent.CompletableFuture<Result<R>>> targets) |
private static <R> void |
LocalCall.onJobReturn(java.lang.String jid,
JobReturnEvent jre,
com.google.gson.reflect.TypeToken<Result<R>> tt,
java.util.Map<java.lang.String,java.util.concurrent.CompletableFuture<Result<R>>> targets) |
private static <R> void |
LocalCall.onRunnerReturn(java.lang.String jid,
RunnerReturnEvent rre,
com.google.gson.reflect.TypeToken<Result<R>> tt,
java.util.Map<java.lang.String,java.util.concurrent.CompletableFuture<Result<R>>> targets) |
private static <R> void |
LocalCall.onRunnerReturn(java.lang.String jid,
RunnerReturnEvent rre,
com.google.gson.reflect.TypeToken<Result<R>> tt,
java.util.Map<java.lang.String,java.util.concurrent.CompletableFuture<Result<R>>> targets) |
Modifier and Type | Method and Description |
---|---|
<T> java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,Result<SSHRawResult>>> |
SaltClient.runRawSSHCommand(java.lang.String command,
Target<T> target,
SaltSSHConfig cfg)
Calls salt-ssh with a command in raw shell mode (commands bypass Salt and
gets executed as shell commands).
|
Modifier and Type | Field and Description |
---|---|
static JsonParser<Return<java.util.List<java.util.Map<java.lang.String,Result<SSHRawResult>>>>> |
JsonParser.RUNSSHRAW_RESULTS |
Modifier and Type | Method and Description |
---|---|
private <R> com.google.gson.TypeAdapter<Result<SSHResult<R>>> |
ResultSSHResultTypeAdapterFactory.resultAdapter(com.google.gson.TypeAdapter<SSHResult<R>> innerAdapter) |
private com.google.gson.TypeAdapter<Result> |
ResultTypeAdapterFactory.wrap(com.google.gson.TypeAdapter<Xor> xorTypeAdapter) |
Modifier and Type | Method and Description |
---|---|
static <T> Result<T> |
Result.error(SaltError e) |
<T> Result<T> |
Result.flatMap(java.util.function.Function<? super R,Result<T>> mapper) |
<T> Result<T> |
Result.map(java.util.function.Function<? super R,? extends T> mapper) |
static <T> Result<T> |
Result.success(T r) |
Modifier and Type | Method and Description |
---|---|
<T> Result<T> |
Result.flatMap(java.util.function.Function<? super R,Result<T>> mapper) |