Package org.graylog.integrations.aws.resources

Class AWSResource

java.lang.Object

org.graylog2.shared.rest.resources.RestResource

org.graylog2.rest.resources.system.inputs.AbstractInputsResource

org.graylog.integrations.aws.resources.AWSResource

All Implemented Interfaces:

PluginRestResource

@Path("/aws")
@RequiresAuthentication
@Produces("application/json")
@Consumes("application/json")
public class AWSResource
extends AbstractInputsResource
implements PluginRestResource

Field Summary

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

configuration, userService

Constructor Summary

Constructors

Constructor	Description
AWSResource(AWSService awsService, KinesisService kinesisService, CloudWatchService cloudWatchService, MessageInputFactory messageInputFactory)

Method Summary

Modifier and Type	Method	Description
jakarta.ws.rs.core.Response	create(@Valid @NotNull AWSInputCreateRequest saveRequest)
RegionsResponse	getAwsRegions()
StreamsResponse	getKinesisStreams(@Valid @NotNull AWSRequestImpl request)
LogGroupsResponse	getLogGroupNames(@Valid @NotNull AWSRequestImpl request)
jakarta.ws.rs.core.Response	kinesisHealthCheck(@Valid @NotNull KinesisHealthCheckRequest heathCheckRequest)

Methods inherited from class org.graylog2.rest.resources.system.inputs.AbstractInputsResource

getInputSummary, maskPasswordsInConfiguration

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

AWSResource

@Inject
public AWSResource(AWSService awsService,
 KinesisService kinesisService,
 CloudWatchService cloudWatchService,
 MessageInputFactory messageInputFactory)

Method Details

getAwsRegions

@GET
@Timed
@Path("/regions")
@RequiresPermissions("aws:read")
public RegionsResponse getAwsRegions()

getLogGroupNames

@POST
@Timed
@Path("/cloudwatch/log_groups")
@RequiresPermissions("aws:read")
public LogGroupsResponse getLogGroupNames(@Valid @NotNull
 @Valid @NotNull AWSRequestImpl request)

getKinesisStreams

@POST
@Timed
@Path("/kinesis/streams")
@RequiresPermissions("aws:read")
public StreamsResponse getKinesisStreams(@Valid @NotNull
 @Valid @NotNull AWSRequestImpl request)
                                  throws ExecutionException

Throws:

ExecutionException

kinesisHealthCheck

@POST
@Timed
@Path("/kinesis/health_check")
@RequiresPermissions("aws:read")
public jakarta.ws.rs.core.Response kinesisHealthCheck(@Valid @NotNull
 @Valid @NotNull KinesisHealthCheckRequest heathCheckRequest)
                                               throws ExecutionException,
IOException

Throws:

ExecutionException

IOException

create

@POST
@Timed
@Path("/inputs")
@RequiresPermissions("inputs:create")
public jakarta.ws.rs.core.Response create(@Valid @NotNull
 @Valid @NotNull AWSInputCreateRequest saveRequest)
                                   throws Exception

Throws:

Exception