/[projects]/CircuitBreaker/src/dk/thoerup/circuitbreaker/web/ViewCircuitBreaker.java
ViewVC logotype

Contents of /CircuitBreaker/src/dk/thoerup/circuitbreaker/web/ViewCircuitBreaker.java

Parent Directory Parent Directory | Revision Log Revision Log

Revision 1287 - (show annotations) (download)
Mon Apr 11 07:58:57 2011 UTC (13 years, 1 month ago) by torben
File size: 5620 byte(s) 
better format of logview
1 package dk.thoerup.circuitbreaker.web;
2
3 import java.util.Date;
4 import java.util.LinkedList;
5
6 import javax.servlet.http.HttpServletRequest;
7 import javax.servlet.http.HttpServletResponse;
8
9 import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
10 import dk.thoerup.circuitbreaker.LoggingCircuitBreaker;
11 import dk.thoerup.circuitbreaker.CircuitBreaker;
12 import dk.thoerup.circuitbreaker.CircuitBreakerManager;
13
14 public class ViewCircuitBreaker implements Command {
15
16 private boolean readOnly;
17
18 public ViewCircuitBreaker(boolean readOnly) {
19 this.readOnly = readOnly;
20 }
21
22 private String actionBuilder(String uri, String action, String breaker) {
23 StringBuilder sb = new StringBuilder();
24 sb.append("<form action=\"").append(uri).append("\" method=\"post\">");
25 sb.append("<input type=\"hidden\" name=\"command\" value=\"action\">\n");
26 sb.append("<input type=\"hidden\" name=\"breaker\" value=\"").append(breaker).append("\">\n");
27 sb.append("<input type=\"hidden\" name=\"action\" value=\"").append(action).append("\">\n");
28 sb.append("<input type=\"submit\" value=\"").append(action).append("\">\n");
29 sb.append("</form>");
30
31 return sb.toString();
32 }
33
34 public String getStateBar(CircuitBreaker breaker) {
35 StringBuilder sb = new StringBuilder();
36 sb.append( breaker.getStateName() );
37 sb.append(": <span style=\"background-color: ");
38 if ( breaker.isOpen() ) {
39 sb.append("red");
40 } else if ( breaker.isClosed() ) {
41 sb.append("green");
42 } else {
43 sb.append("yellow");
44 }
45 sb.append("\">&nbsp;&nbsp;&nbsp;<span>");
46
47 return sb.toString();
48 }
49
50 public String formatDate(long date) {
51 if (date == 0L) {
52 return "-";
53 } else {
54 return new Date(date).toString();
55 }
56 }
57
58 public String execute(HttpServletRequest req, HttpServletResponse resp) {
59 CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker( req.getParameter("breaker"));
60 String uri = req.getRequestURI();
61
62 if (breaker == null)
63 return "<html><body><h2>No breaker named '" + req.getParameter("breaker") + "'</h2></body></html>";
64
65 StringBuilder sb = new StringBuilder();
66
67 sb.append("<html><head><title>View Circuitbreaker</title></head><body>");
68 sb.append("<<== <a href=\"").append(req.getRequestURI()).append("\">Back to overview</a><br><br>");
69 sb.append("<h2>CircuitBreaker</h2>\n");
70
71
72 sb.append("<b>Attributes:</b>\n");
73 sb.append("<table border=\"1\" cellspacing=0>");
74 sb.append("<tr><td>Name </td><td>").append(breaker.getName()).append("</td></tr>\n");
75 sb.append("<tr><td>State </td><td><b>").append( getStateBar(breaker) ).append("</b></td></tr>\n");
76 sb.append("<tr><td>Type </td><td>").append(breaker.getClass().getSimpleName() ).append("</td></tr>\n");
77 sb.append("<tr><td>Notifier </td><td>").append(breaker.getNotifierName()).append("</td></tr>\n");
78 sb.append("<tr><td>Failure count </td><td>").append(breaker.getFailureCount()).append("</td></tr>\n");
79 sb.append("<tr><td>Failure threshold </td><td>").append(breaker.getThreshold()).append("</td></tr>\n");
80 sb.append("<tr><td>Timeout, elapsed</td><td>").append( breaker.getElapsed() ).append("</td></tr>\n");
81 sb.append("<tr><td>Timeout, limit</td><td>").append( breaker.getTimeout() ).append("</td></tr>\n");
82
83 if (breaker instanceof AccountingCircuitBreaker) {
84 AccountingCircuitBreaker acb = (AccountingCircuitBreaker) breaker;
85 sb.append("<tr><th colspan=\"2\">Accounting</th></tr>\n");
86 sb.append("<tr><td>Trip count</td><td>").append( acb.getTripCount() ).append("</td></tr>\n");
87 sb.append("<tr><td>Re-trip count</td><td>").append( acb.getRetripCount() ).append("</td></tr>\n");
88 sb.append("<tr><td>Block count</td><td>").append( acb.getBlockCount() ).append("</td></tr>\n");
89 sb.append("<tr><td>Total failure count</td><td>").append( acb.getTotalFailureCount() ).append("</td></tr>\n");
90 sb.append("<tr><td>Total Call count</td><td>").append( acb.getTotalCallCount() ).append("</td></tr>\n");
91 sb.append("<tr><td>Last failure</td><td>").append( formatDate(acb.getLastFailure()) ).append("</td></tr>\n");
92 sb.append("<tr><td>Last trip</td><td>").append( formatDate(acb.getLastTrip()) ).append("</td></tr>\n");
93 sb.append("<tr><td>Last re-trip</td><td>").append( formatDate(acb.getLastRetrip()) ).append("</td></tr>\n");
94 sb.append("<tr><td>Last reset</td><td>").append( formatDate(acb.getLastReset()) ).append("</td></tr>\n");
95
96 sb.append("<tr><td>Last resetCounters</td><td>").append( formatDate(acb.getLastResetCounters()) ).append("</td></tr>\n");
97 }
98
99 if (breaker instanceof LoggingCircuitBreaker) {
100 LoggingCircuitBreaker lcb = (LoggingCircuitBreaker) breaker;
101
102 LinkedList<LoggingCircuitBreaker.LogEntry> list = lcb.getLog();
103
104 sb.append("<tr><th colspan=\"2\">Logging</th></tr>\n");
105 for(LoggingCircuitBreaker.LogEntry entry : list) {
106 sb.append("<tr><td colspan=\"2\">");
107 sb.append( formatDate(entry.time) ).append(" : ").append(entry.event);
108 sb.append("</td></tr>");
109 }
110 }
111
112 sb.append("</table>\n");
113 sb.append("Current time: ").append( new Date().toString() ).append("<br><br>\n");
114
115 sb.append("<b>Operations:</b>\n");
116 if ( !readOnly ) {
117 sb.append( actionBuilder(uri, "reset", breaker.getName())).append("<br>\n");
118 sb.append( actionBuilder(uri, "tripBreaker", breaker.getName())).append("<br>\n");
119 if (breaker instanceof AccountingCircuitBreaker ) {
120 sb.append( actionBuilder(uri, "resetCounters", breaker.getName())).append("<br>\n");
121 }
122 } else {
123 sb.append("<i>the CircuitBreakers can only be viewed</i>");
124 }
125
126 sb.append("</body></html>");
127
128 return sb.toString();
129 }
130
131 }
  ViewVC Help
Powered by ViewVC 1.1.20