public interface IAuthorizer
Nimbus could be configured with an authorization plugin. If not specified, all requests are authorized.
You could specify the authorization plugin via storm parameter. For example:
storm -c nimbus.authorization.class=org.apache.storm.security.auth.NoopAuthorizer ...
You could also specify it via storm.yaml:
yaml nimbus.authorization.class: org.apache.storm.security.auth.NoopAuthorizer
Modifier and Type | Method and Description |
---|---|
boolean |
permit(ReqContext context,
String operation,
Map<String,Object> topoConf)
permit() method is invoked for each incoming Thrift request.
|
void |
prepare(Map<String,Object> conf)
Invoked once immediately after construction.
|
void prepare(Map<String,Object> conf)
Invoked once immediately after construction.
conf
- Storm cluster configurationboolean permit(ReqContext context, String operation, Map<String,Object> topoConf)
permit() method is invoked for each incoming Thrift request.
context
- request context includes info aboutoperation
- operation nametopoConf
- configuration of targeted topologyCopyright © 2022 The Apache Software Foundation. All rights reserved.