Package org.graylog.integrations.aws.resources

Class KinesisSetupResource

java.lang.Object

org.graylog2.shared.rest.resources.RestResource

org.graylog.integrations.aws.resources.KinesisSetupResource

All Implemented Interfaces:

PluginRestResource

@Path("/aws/kinesis/auto_setup")
@RequiresAuthentication
@Produces("application/json")
@Consumes("application/json")
public class KinesisSetupResource
extends RestResource
implements PluginRestResource

Web endpoints for the Kinesis auto-setup.

Field Summary

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

configuration, userService

Constructor Summary

Constructors

Constructor	Description
KinesisSetupResource(CloudWatchService cloudWatchService, KinesisService kinesisService)

Method Summary

Modifier and Type	Method	Description
CreateRolePermissionResponse	autoKinesisPermissions(@Valid @NotNull CreateRolePermissionRequest request)
KinesisNewStreamResponse	createNewKinesisStream(@Valid @NotNull KinesisNewStreamRequest request)
CreateLogSubscriptionResponse	createSubscription(@Valid @NotNull CreateLogSubscriptionRequest request)

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

KinesisSetupResource

@Inject
public KinesisSetupResource(CloudWatchService cloudWatchService,
 KinesisService kinesisService)

Method Details

createNewKinesisStream

@POST
@Timed
@Path("/create_stream")
@RequiresPermissions("aws:read")
public KinesisNewStreamResponse createNewKinesisStream(@Valid @NotNull
 @Valid @NotNull KinesisNewStreamRequest request)

autoKinesisPermissions

@POST
@Timed
@Path("/create_subscription_policy")
@RequiresPermissions("aws:read")
public CreateRolePermissionResponse autoKinesisPermissions(@Valid @NotNull
 @Valid @NotNull CreateRolePermissionRequest request)

createSubscription

@POST
@Timed
@Path("/create_subscription")
@RequiresPermissions("aws:read")
public CreateLogSubscriptionResponse createSubscription(@Valid @NotNull
 @Valid @NotNull CreateLogSubscriptionRequest request)