Package org.graylog2.rest.resources.datanodes

Class DataNodeManagementResource

java.lang.Object

org.graylog2.shared.rest.resources.RestResource

org.graylog2.rest.resources.datanodes.DataNodeManagementResource

@RequiresAuthentication
@Path("/datanode/")
@Produces("application/json")
public class DataNodeManagementResource
extends RestResource

Field Summary

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

configuration, userService

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DataNodeManagementResource(DataNodeCommandService dataNodeCommandService, NodeService<DataNodeDto> nodeService, CertRenewalService certRenewalService, Boolean runsWithDataNode, AuditEventSender auditEventSender, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
jakarta.ws.rs.core.Response	bulkRemove(BulkOperationRequest bulkOperationRequest, UserContext userContext)
jakarta.ws.rs.core.Response	bulkStart(BulkOperationRequest bulkOperationRequest, UserContext userContext)
jakarta.ws.rs.core.Response	bulkStop(BulkOperationRequest bulkOperationRequest, UserContext userContext)
DataNodeDto	getDataNode(String nodeId)
DataNodeDto	removeNode(String nodeId, UserContext userContext)
DataNodeDto	resetNode(String nodeId)
Boolean	runsWithDataNode()
DataNodeDto	startNode(String nodeId, UserContext userContext)
DataNodeDto	stopNode(String nodeId, UserContext userContext)

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

Constructor Details

DataNodeManagementResource

@Inject
protected DataNodeManagementResource(DataNodeCommandService dataNodeCommandService,
 NodeService<DataNodeDto> nodeService,
 CertRenewalService certRenewalService,
 Boolean runsWithDataNode,
 AuditEventSender auditEventSender,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

runsWithDataNode

@GET
@Path("configured")
@RequiresPermissions("datanode:read")
public Boolean runsWithDataNode()

getDataNode

@GET
@Path("{nodeId}")
@RequiresPermissions("datanode:read")
public DataNodeDto getDataNode(@PathParam("nodeId")
 String nodeId)

removeNode

@DELETE
@Path("{nodeId}")
@RequiresPermissions("datanode:remove")
public DataNodeDto removeNode(@PathParam("nodeId")
 String nodeId,
 @Context
 UserContext userContext)

bulkRemove

@POST
@Path("/bulk_remove")
@Consumes("application/json")
@Timed
public jakarta.ws.rs.core.Response bulkRemove(BulkOperationRequest bulkOperationRequest,
 @Context
 UserContext userContext)

resetNode

@POST
@Path("{nodeId}/reset")
@RequiresPermissions("datanode:reset")
public DataNodeDto resetNode(@PathParam("nodeId")
 String nodeId)

stopNode

@POST
@Path("{nodeId}/stop")
@RequiresPermissions("datanode:stop")
public DataNodeDto stopNode(@PathParam("nodeId")
 String nodeId,
 @Context
 UserContext userContext)

bulkStop

@POST
@Path("/bulk_stop")
@Consumes("application/json")
@Timed
public jakarta.ws.rs.core.Response bulkStop(BulkOperationRequest bulkOperationRequest,
 @Context
 UserContext userContext)

startNode

@POST
@Path("{nodeId}/start")
@RequiresPermissions("datanode:start")
public DataNodeDto startNode(@PathParam("nodeId")
 String nodeId,
 @Context
 UserContext userContext)

bulkStart

@POST
@Path("/bulk_start")
@Consumes("application/json")
@Timed
public jakarta.ws.rs.core.Response bulkStart(BulkOperationRequest bulkOperationRequest,
 @Context
 UserContext userContext)