org.graylog2.rest.resources.streams

Class StreamResource

java.lang.Object

org.graylog2.rest.resources.RestResource

org.graylog2.rest.resources.streams.StreamResource

@Path(value="/streams")
public class StreamResource
extends RestResource

Author:

Lennart Koopmann

Field Summary

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

objectMapper, serverStatus, userService

Constructor Summary

Constructors

Constructor and Description
StreamResource(StreamService streamService, StreamRuleService streamRuleService, ThroughputStats throughputStats, StreamRouter streamRouter)

Method Summary

Methods

Modifier and Type	Method and Description
javax.ws.rs.core.Response	cloneStream(String streamId, CreateRequest cr)
javax.ws.rs.core.Response	create(CreateRequest cr)
javax.ws.rs.core.Response	delete(String streamId)
protected Stream	fetchStream(String streamId)
StreamListResponse	get()
Stream	get(String streamId)
String	getEnabled()
javax.ws.rs.core.Response	oneStreamThroughput(String streamId)
javax.ws.rs.core.Response	pause(String streamId)
javax.ws.rs.core.Response	resume(String streamId)
javax.ws.rs.core.Response	streamThroughput()
String	testMatch(String streamId, String body)
javax.ws.rs.core.Response	update(String body, String streamId)

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

buildHistogramMap, buildMeterMap, buildTimerMap, bytesToValueMap, checkPermission, checkPermission, getCurrentUser, getSubject, guessContentType, isPermitted, isPermitted, json, loadObjectId, page, restrictToMaster, setPrettyPrint

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamResource

@Inject
public StreamResource(StreamService streamService,
                     StreamRuleService streamRuleService,
                     ThroughputStats throughputStats,
                     StreamRouter streamRouter)

Method Detail

create

@POST
@Consumes(value="application/json")
@Produces(value="application/json")
public javax.ws.rs.core.Response create(CreateRequest cr)
                                 throws ValidationException

Throws:

ValidationException

get

@GET
@Produces(value="application/json")
public StreamListResponse get()

getEnabled

@GET
@Path(value="/enabled")
@Produces(value="application/json")
public String getEnabled()
                  throws NotFoundException

Throws:

NotFoundException

get

@GET
@Path(value="/{streamId}")
@Produces(value="application/json")
public Stream get(@PathParam(value="streamId")
                           String streamId)
           throws NotFoundException

Throws:

NotFoundException

update

@PUT
@Path(value="/{streamId}")
@Consumes(value="application/json")
@Produces(value="application/json")
public javax.ws.rs.core.Response update(String body,
                                                          @PathParam(value="streamId")
                                                          String streamId)

delete

@DELETE
@Path(value="/{streamId}")
public javax.ws.rs.core.Response delete(@PathParam(value="streamId")
                                           String streamId)

pause

@POST
@Path(value="/{streamId}/pause")
public javax.ws.rs.core.Response pause(@PathParam(value="streamId")
                                        String streamId)

resume

@POST
@Path(value="/{streamId}/resume")
public javax.ws.rs.core.Response resume(@PathParam(value="streamId")
                                         String streamId)

testMatch

@POST
@Path(value="/{streamId}/testMatch")
public String testMatch(@PathParam(value="streamId")
                         String streamId,
                         String body)

cloneStream

@POST
@Path(value="/{streamId}/clone")
@Consumes(value="application/json")
@Produces(value="application/json")
public javax.ws.rs.core.Response cloneStream(@PathParam(value="streamId")
                                                                String streamId,
                                                                CreateRequest cr)

oneStreamThroughput

@GET
@Path(value="/{streamId}/throughput")
@Produces(value="application/json")
public javax.ws.rs.core.Response oneStreamThroughput(@PathParam(value="streamId")
                                                              String streamId)

streamThroughput

@GET
@Path(value="/throughput")
@Produces(value="application/json")
public javax.ws.rs.core.Response streamThroughput()

fetchStream

protected Stream fetchStream(String streamId)