circuitbreaker/statistics/AccountingStatistics.java

package dk.thoerup.circuitbreaker.statistics;

import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;

import dk.thoerup.circuitbreaker.Event;

public class AccountingStatistics implements Statistics {
        

        private AtomicInteger tripCount = new AtomicInteger(0); // how many times ahs the CB tripped  
        private AtomicInteger retripCount = new AtomicInteger(0);   
        private AtomicInteger blockCount = new AtomicInteger(0); //how many times has this CB blocked a call that would otherwise go to the backend
        private AtomicInteger totalFailureCount = new AtomicInteger(0); //how many times has the backend thrown an exception
        private AtomicInteger totalCallCount = new AtomicInteger(0);
        
        private AtomicLong lastTrip = new AtomicLong(0);
        private AtomicLong lastRetrip = new AtomicLong(0);
        private AtomicLong lastFailure = new AtomicLong(0);
        private AtomicLong lastReset = new AtomicLong(0);
        
        private long lastResetCounters = 0;
        

        @Override
        public void addStatistics(Event event) {
                switch(event) {
                case BreakerAttemptReset:
                        break;
                case BreakerReset:
                        lastReset.set( System.currentTimeMillis());
                        break;
                case BreakerRetripped:
                        retripCount.incrementAndGet();
                        lastRetrip.set( System.currentTimeMillis() );                   
                        break;
                case BreakerTripped:
                        tripCount.incrementAndGet();
                        lastTrip.set( System.currentTimeMillis() );
                        break;
                case InvocationBlocked:
                        blockCount.incrementAndGet();
                        break;
                case InvocationFailure:
                        totalFailureCount.incrementAndGet();
                        lastFailure.set( System.currentTimeMillis() );                  
                        break;
                case Invocation:
                        totalCallCount.incrementAndGet();
                        break;          
                }
        }
        
        public void resetCounters() {
                tripCount.set(0);
                retripCount.set(0);
                blockCount.set(0);
                totalFailureCount.set(0);
                totalCallCount.set(0);
                lastTrip.set(0);
                lastRetrip.set(0);
                lastReset.set(0);
                lastFailure.set(0);
                
                lastResetCounters = System.currentTimeMillis();
        }
        
        public int getTripCount() {
                return tripCount.get();
        }
        
        public int getRetripCount() {
                return retripCount.get();
        }

        public int getBlockCount() {
                return blockCount.get();        
        }
        
        public int getTotalFailureCount() {
                return totalFailureCount.get();
        }
        
        public long getLastResetCounters() {
                return lastResetCounters;
        }
        
        public long getLastTrip() {
                return lastTrip.get();
        }
        
        public long getLastRetrip() {
                return lastRetrip.get();
        }

        public long getLastFailure() {
                return lastFailure.get();
        }
        
        public long getLastReset() {
                return lastReset.get();
        }
        
        public int getTotalCallCount() {
                return totalCallCount.get();
        }
        

}
1	torben	2569	package dk.thoerup.circuitbreaker.statistics;
2
3			import java.util.concurrent.atomic.AtomicInteger;
4			import java.util.concurrent.atomic.AtomicLong;
5
6			import dk.thoerup.circuitbreaker.Event;
7
8			public class AccountingStatistics implements Statistics {
9
10
11			private AtomicInteger tripCount = new AtomicInteger(0); // how many times ahs the CB tripped
12			private AtomicInteger retripCount = new AtomicInteger(0);
13			private AtomicInteger blockCount = new AtomicInteger(0); //how many times has this CB blocked a call that would otherwise go to the backend
14			private AtomicInteger totalFailureCount = new AtomicInteger(0); //how many times has the backend thrown an exception
15			private AtomicInteger totalCallCount = new AtomicInteger(0);
16
17			private AtomicLong lastTrip = new AtomicLong(0);
18			private AtomicLong lastRetrip = new AtomicLong(0);
19			private AtomicLong lastFailure = new AtomicLong(0);
20			private AtomicLong lastReset = new AtomicLong(0);
21
22			private long lastResetCounters = 0;
23
24
25			@Override
26			public void addStatistics(Event event) {
27			switch(event) {
28			case BreakerAttemptReset:
29			break;
30			case BreakerReset:
31			lastReset.set( System.currentTimeMillis());
32			break;
33			case BreakerRetripped:
34			retripCount.incrementAndGet();
35			lastRetrip.set( System.currentTimeMillis() );
36			break;
37			case BreakerTripped:
38			tripCount.incrementAndGet();
39			lastTrip.set( System.currentTimeMillis() );
40			break;
41			case InvocationBlocked:
42			blockCount.incrementAndGet();
43			break;
44			case InvocationFailure:
45			totalFailureCount.incrementAndGet();
46			lastFailure.set( System.currentTimeMillis() );
47			break;
48			case Invocation:
49			totalCallCount.incrementAndGet();
50			break;
51			}
52			}
53
54			public void resetCounters() {
55			tripCount.set(0);
56			retripCount.set(0);
57			blockCount.set(0);
58			totalFailureCount.set(0);
59			totalCallCount.set(0);
60			lastTrip.set(0);
61			lastRetrip.set(0);
62			lastReset.set(0);
63			lastFailure.set(0);
64
65			lastResetCounters = System.currentTimeMillis();
66			}
67
68			public int getTripCount() {
69			return tripCount.get();
70			}
71
72			public int getRetripCount() {
73			return retripCount.get();
74			}
75
76			public int getBlockCount() {
77			return blockCount.get();
78			}
79
80			public int getTotalFailureCount() {
81			return totalFailureCount.get();
82			}
83
84			public long getLastResetCounters() {
85			return lastResetCounters;
86			}
87
88			public long getLastTrip() {
89			return lastTrip.get();
90			}
91
92			public long getLastRetrip() {
93			return lastRetrip.get();
94			}
95
96			public long getLastFailure() {
97			return lastFailure.get();
98			}
99
100			public long getLastReset() {
101			return lastReset.get();
102			}
103
104			public int getTotalCallCount() {
105			return totalCallCount.get();
106			}
107
108
109			}