Package com.smeup.kokos.sdk.caller

Class MicroExecutorHTTPClient

java.lang.Object

com.smeup.kokos.sdk.caller.MicroExecutorHTTPClient

All Implemented Interfaces:

AutoCloseable

public class MicroExecutorHTTPClient
extends Object
implements AutoCloseable

Author:

mattia.bonardi

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXECUTE_FUN

Method Summary

Modifier and Type	Method	Description
void	close()
HttpResponse<InputStream>	executeFun(Fun fun, ExecutionContext context, boolean coreResponse)
HttpResponse<InputStream>	executeFunAsync(Fun fun, ExecutionContext context, boolean coreResponse)
static MicroExecutorHTTPClient	newClient()
MicroExecutorHTTPClient	withInterceptor(Consumer<HttpRequest.Builder> interceptor)	Intercept the request builder to allow customization of FUN request to another microexecutor.
MicroExecutorHTTPClient	withTimeout(Integer timeout)

Methods inherited from class java.lang.Object

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

Field Details

EXECUTE_FUN

public static final String EXECUTE_FUN

See Also:

• Constant Field Values

Method Details

newClient

public static MicroExecutorHTTPClient newClient()

withTimeout

public MicroExecutorHTTPClient withTimeout(Integer timeout)

withInterceptor

public MicroExecutorHTTPClient withInterceptor(Consumer<HttpRequest.Builder> interceptor)

Intercept the request builder to allow customization of FUN request to another microexecutor. This can be useful, for example, to attach authorization token for external services that can handle FUNs.

Parameters:

interceptor -

Returns:

executeFun

public HttpResponse<InputStream> executeFun(Fun fun,
 ExecutionContext context,
 boolean coreResponse)
                                     throws KokosServiceException

Throws:

KokosServiceException

executeFunAsync

public HttpResponse<InputStream> executeFunAsync(Fun fun,
 ExecutionContext context,
 boolean coreResponse)
                                          throws KokosServiceException

Throws:

KokosServiceException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception