Package org.graylog2.rest.resources.datanodes

Class DatanodeRestApiProxy

java.lang.Object

org.graylog2.rest.resources.datanodes.DatanodeRestApiProxy

All Implemented Interfaces:

ProxyRequestAdapter

@Singleton
public class DatanodeRestApiProxy
extends Object
implements ProxyRequestAdapter

Nested Class Summary

Nested classes/interfaces inherited from interface org.graylog2.indexer.datanode.ProxyRequestAdapter

ProxyRequestAdapter.ProxyRequest, ProxyRequestAdapter.ProxyResponse

Constructor Summary

Constructors

Constructor	Description
DatanodeRestApiProxy(IndexerJwtAuthTokenProvider authTokenProvider, NodeService<DataNodeDto> nodeService, com.fasterxml.jackson.databind.ObjectMapper objectMapper, DatanodeResolver datanodeResolver, okhttp3.OkHttpClient okHttpClient, com.github.joschi.jadconfig.util.Duration defaultProxyTimeout)

Method Summary

Modifier and Type	Method	Description
<RemoteInterfaceType, RemoteResponseType> Map<String,RemoteResponseType>	remoteInterface(String nodeSelector, Class<RemoteInterfaceType> interfaceClass, Function<RemoteInterfaceType,retrofit2.Call<RemoteResponseType>> function)
ProxyRequestAdapter.ProxyResponse	request(ProxyRequestAdapter.ProxyRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

DatanodeRestApiProxy

@Inject
public DatanodeRestApiProxy(IndexerJwtAuthTokenProvider authTokenProvider,
 NodeService<DataNodeDto> nodeService,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 DatanodeResolver datanodeResolver,
 okhttp3.OkHttpClient okHttpClient,
 @Named("proxied_requests_default_call_timeout")
 com.github.joschi.jadconfig.util.Duration defaultProxyTimeout)

Method Details

request

public ProxyRequestAdapter.ProxyResponse request(ProxyRequestAdapter.ProxyRequest request)
                                          throws IOException

Specified by:

request in interface ProxyRequestAdapter

Throws:

IOException

remoteInterface

public <RemoteInterfaceType,
RemoteResponseType>
Map<String,RemoteResponseType> remoteInterface(String nodeSelector,
 Class<RemoteInterfaceType> interfaceClass,
 Function<RemoteInterfaceType,retrofit2.Call<RemoteResponseType>> function)