forked from nathanmarz/storm
/
DenyAuthorizer.java
40 lines (34 loc) · 1.39 KB
/
DenyAuthorizer.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
package backtype.storm.security.auth.authorizer;
import java.util.Map;
import backtype.storm.Config;
import backtype.storm.security.auth.IAuthorizer;
import backtype.storm.security.auth.ReqContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* An authorization implementation that denies everything, for testing purposes
*/
public class DenyAuthorizer implements IAuthorizer {
private static final Logger LOG = LoggerFactory.getLogger(DenyAuthorizer.class);
/**
* Invoked once immediately after construction
* @param conf Storm configuration
*/
public void prepare(Map conf) {
}
/**
* permit() method is invoked for each incoming Thrift request
* @param contrext request context
* @param operation operation name
* @param topology_storm configuration of targeted topology
* @return true if the request is authorized, false if reject
*/
public boolean permit(ReqContext context, String operation, Map topology_conf) {
LOG.info("[req "+ context.requestID()+ "] Access "
+ " from: " + (context.remoteAddress() == null? "null" : context.remoteAddress().toString())
+ " principal:"+ (context.principal() == null? "null" : context.principal())
+" op:"+operation
+ " topoology:"+topology_conf.get(Config.TOPOLOGY_NAME));
return false;
}
}