org.graylog2.shared.rest.resources

Class ProxiedResource

java.lang.Object

org.graylog2.shared.rest.resources.RestResource

org.graylog2.shared.rest.resources.ProxiedResource

Direct Known Subclasses:

ClusterDeflectorResource, ClusterInputStatesResource, ClusterJournalResource, ClusterLoadBalancerStatusResource, ClusterLoggersResource, ClusterMetricsResource, ClusterNodeMetricsResource, ClusterProcessingStatusResource, ClusterSystemJobResource, ClusterSystemPluginResource, ClusterSystemProcessingResource, ClusterSystemResource, ClusterSystemShutdownResource

public abstract class ProxiedResource
extends RestResource

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ProxiedResource.MasterResponse<ResponseType>

Field Summary

Fields

Modifier and Type	Field and Description
protected String	authenticationToken
protected NodeService	nodeService
protected RemoteInterfaceProvider	remoteInterfaceProvider

Fields inherited from class org.graylog2.shared.rest.resources.RestResource

userService

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ProxiedResource(javax.ws.rs.core.HttpHeaders httpHeaders, NodeService nodeService, RemoteInterfaceProvider remoteInterfaceProvider, ExecutorService executorService)

Method Summary

Modifier and Type	Method and Description
protected <RemoteInterfaceType> Function<String,Optional<RemoteInterfaceType>>	createRemoteInterfaceProvider(Class<RemoteInterfaceType> interfaceClass)
protected <RemoteInterfaceType,RemoteCallResponseType> Map<String,Optional<RemoteCallResponseType>>	getForAllNodes(Function<RemoteInterfaceType,retrofit2.Call<RemoteCallResponseType>> fn, Function<String,Optional<RemoteInterfaceType>> interfaceProvider)
protected <RemoteInterfaceType,FinalResponseType,RemoteCallResponseType> Map<String,Optional<FinalResponseType>>	getForAllNodes(Function<RemoteInterfaceType,retrofit2.Call<RemoteCallResponseType>> fn, Function<String,Optional<RemoteInterfaceType>> interfaceProvider, Function<RemoteCallResponseType,FinalResponseType> transformer)
protected <RemoteInterfaceType,RemoteCallResponseType> ProxiedResource.MasterResponse<RemoteCallResponseType>	requestOnMaster(Function<RemoteInterfaceType,retrofit2.Call<RemoteCallResponseType>> remoteInterfaceFunction, Function<String,Optional<RemoteInterfaceType>> remoteInterfaceProvider) Execute the given remote interface function on the master node.

Methods inherited from class org.graylog2.shared.rest.resources.RestResource

checkAnyPermission, checkPermission, checkPermission, getCurrentUser, getIndexSet, getSubject, getUriBuilderToSelf, isAnyPermitted, isAnyPermitted, isPermitted, isPermitted, setPrettyPrint

Methods inherited from class java.lang.Object

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

Field Detail

authenticationToken

protected final String authenticationToken

nodeService

protected final NodeService nodeService

remoteInterfaceProvider

protected final RemoteInterfaceProvider remoteInterfaceProvider

Constructor Detail

ProxiedResource

protected ProxiedResource(@Context
                          javax.ws.rs.core.HttpHeaders httpHeaders,
                          NodeService nodeService,
                          RemoteInterfaceProvider remoteInterfaceProvider,
                          ExecutorService executorService)

Method Detail

getForAllNodes

protected <RemoteInterfaceType,RemoteCallResponseType> Map<String,Optional<RemoteCallResponseType>> getForAllNodes(Function<RemoteInterfaceType,retrofit2.Call<RemoteCallResponseType>> fn,
                                                                                                                   Function<String,Optional<RemoteInterfaceType>> interfaceProvider)

getForAllNodes

protected <RemoteInterfaceType,FinalResponseType,RemoteCallResponseType> Map<String,Optional<FinalResponseType>> getForAllNodes(Function<RemoteInterfaceType,retrofit2.Call<RemoteCallResponseType>> fn,
                                                                                                                                Function<String,Optional<RemoteInterfaceType>> interfaceProvider,
                                                                                                                                Function<RemoteCallResponseType,FinalResponseType> transformer)

createRemoteInterfaceProvider

protected <RemoteInterfaceType> Function<String,Optional<RemoteInterfaceType>> createRemoteInterfaceProvider(Class<RemoteInterfaceType> interfaceClass)

requestOnMaster

protected <RemoteInterfaceType,RemoteCallResponseType> ProxiedResource.MasterResponse<RemoteCallResponseType> requestOnMaster(Function<RemoteInterfaceType,retrofit2.Call<RemoteCallResponseType>> remoteInterfaceFunction,
                                                                                                                              Function<String,Optional<RemoteInterfaceType>> remoteInterfaceProvider)
                                                                                                                       throws IOException

Execute the given remote interface function on the master node.

This is used to forward an API request to the master node. It is useful in situations where an API call can only be executed on the master node.

The returned ProxiedResource.MasterResponse object is constructed from the remote response's status code and body.

Throws:

IOException