Searched refs:monitoringStore (Results 1 - 16 of 16) sorted by relevance

/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/monitoring/session/
H A DStatelessSessionsImpl.java28 private final SessionMonitoringStore monitoringStore; field in class:StatelessSessionsImpl
30 public StatelessSessionsImpl(final SnmpMib mib, final SessionMonitoringStore monitoringStore) { argument
32 this.monitoringStore = monitoringStore;
40 return monitoringStore.getAverageSetPropertyTime(SessionMonitorType.STATELESS);
48 return monitoringStore.getAverageDestroyTime(SessionMonitorType.STATELESS);
56 return monitoringStore.getAverageLogoutTime(SessionMonitorType.STATELESS);
64 return monitoringStore.getAverageRefreshTime(SessionMonitorType.STATELESS);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/monitoring/session/
H A DStatelessSessionsImpl.java28 private final SessionMonitoringStore monitoringStore; field in class:StatelessSessionsImpl
30 public StatelessSessionsImpl(final SnmpMib mib, final SessionMonitoringStore monitoringStore) { argument
32 this.monitoringStore = monitoringStore;
40 return monitoringStore.getAverageSetPropertyTime(SessionMonitorType.STATELESS);
48 return monitoringStore.getAverageDestroyTime(SessionMonitorType.STATELESS);
56 return monitoringStore.getAverageLogoutTime(SessionMonitorType.STATELESS);
64 return monitoringStore.getAverageRefreshTime(SessionMonitorType.STATELESS);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/monitoring/cts/
H A DCtsConnectionFailureRateImpl.java32 private final CTSConnectionMonitoringStore monitoringStore; field in class:CtsConnectionFailureRateImpl
41 this.monitoringStore = InjectorHolder.getInstance(CTSConnectionMonitoringStore.class);
48 return Math.round(monitoringStore.getMaximumOperationsPerPeriod(false));
55 return Math.round(monitoringStore.getMinimumOperationsPerPeriod(false));
62 return Math.round(monitoringStore.getAverageConnectionsPerPeriod(false));
69 return Math.round(monitoringStore.getConnectionsCumulativeCount(false));
H A DCtsConnectionSuccessRateImpl.java32 private final CTSConnectionMonitoringStore monitoringStore; field in class:CtsConnectionSuccessRateImpl
41 this.monitoringStore = InjectorHolder.getInstance(CTSConnectionMonitoringStore.class);
48 return Math.round(monitoringStore.getMaximumOperationsPerPeriod(true));
55 return Math.round(monitoringStore.getMinimumOperationsPerPeriod(true));
62 return Math.round(monitoringStore.getAverageConnectionsPerPeriod(true));
69 return Math.round(monitoringStore.getConnectionsCumulativeCount(true));
H A DCtsCRUDOperationsEntryImpl.java37 private final CTSOperationsMonitoringStore monitoringStore; field in class:CtsCRUDOperationsEntryImpl
50 this.monitoringStore = InjectorHolder.getInstance(CTSOperationsMonitoringStore.class);
86 return monitoringStore.getMaximumOperationsPerPeriod(null, getCTSOperation());
96 return monitoringStore.getMaximumOperationFailuresPerPeriod(getCTSOperation());
106 return monitoringStore.getMinimumOperationsPerPeriod(null, getCTSOperation());
116 return monitoringStore.getMinimumOperationFailuresPerPeriod(getCTSOperation());
126 return (long) monitoringStore.getAverageOperationsPerPeriod(null, getCTSOperation());
136 return (long) monitoringStore.getAverageOperationFailuresPerPeriod(getCTSOperation());
152 return monitoringStore.getOperationsCumulativeCount(null, getCTSOperation());
168 return monitoringStore
[all...]
H A DCtsCRUDOperationsPerTokenTypeEntryImpl.java41 private final CTSOperationsMonitoringStore monitoringStore; field in class:CtsCRUDOperationsPerTokenTypeEntryImpl
54 this.monitoringStore = InjectorHolder.getInstance(CTSOperationsMonitoringStore.class);
121 return monitoringStore.getMaximumOperationsPerPeriod(getTokenType(), getCTSOperation());
138 return monitoringStore.getMinimumOperationsPerPeriod(getTokenType(), getCTSOperation());
155 return (long) monitoringStore.getAverageOperationsPerPeriod(getTokenType(), getCTSOperation());
172 return monitoringStore.getOperationsCumulativeCount(getTokenType(), getCTSOperation());
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/monitoring/cts/
H A DCtsConnectionFailureRateImpl.java32 private final CTSConnectionMonitoringStore monitoringStore; field in class:CtsConnectionFailureRateImpl
41 this.monitoringStore = InjectorHolder.getInstance(CTSConnectionMonitoringStore.class);
48 return Math.round(monitoringStore.getMaximumOperationsPerPeriod(false));
55 return Math.round(monitoringStore.getMinimumOperationsPerPeriod(false));
63 return (int) (monitoringStore.getAverageConnectionsPerPeriod(false) * 100);
70 return Math.round(monitoringStore.getConnectionsCumulativeCount(false));
H A DCtsConnectionSuccessRateImpl.java32 private final CTSConnectionMonitoringStore monitoringStore; field in class:CtsConnectionSuccessRateImpl
41 this.monitoringStore = InjectorHolder.getInstance(CTSConnectionMonitoringStore.class);
48 return Math.round(monitoringStore.getMaximumOperationsPerPeriod(true));
55 return Math.round(monitoringStore.getMinimumOperationsPerPeriod(true));
63 return (int) (monitoringStore.getAverageConnectionsPerPeriod(true) * 100);
70 return Math.round(monitoringStore.getConnectionsCumulativeCount(true));
H A DCtsCRUDOperationsEntryImpl.java37 private final CTSOperationsMonitoringStore monitoringStore; field in class:CtsCRUDOperationsEntryImpl
50 this.monitoringStore = InjectorHolder.getInstance(CTSOperationsMonitoringStore.class);
86 return monitoringStore.getMaximumOperationsPerPeriod(null, getCTSOperation());
96 return monitoringStore.getMaximumOperationFailuresPerPeriod(getCTSOperation());
106 return monitoringStore.getMinimumOperationsPerPeriod(null, getCTSOperation());
116 return monitoringStore.getMinimumOperationFailuresPerPeriod(getCTSOperation());
127 return (int) (monitoringStore.getAverageOperationsPerPeriod(null, getCTSOperation()) * 100);
138 return (int) (monitoringStore.getAverageOperationFailuresPerPeriod(getCTSOperation()) * 100);
154 return monitoringStore.getOperationsCumulativeCount(null, getCTSOperation());
170 return monitoringStore
[all...]
H A DCtsCRUDOperationsPerTokenTypeEntryImpl.java40 private final CTSOperationsMonitoringStore monitoringStore; field in class:CtsCRUDOperationsPerTokenTypeEntryImpl
53 this.monitoringStore = InjectorHolder.getInstance(CTSOperationsMonitoringStore.class);
120 return monitoringStore.getMaximumOperationsPerPeriod(getTokenType(), getCTSOperation());
137 return monitoringStore.getMinimumOperationsPerPeriod(getTokenType(), getCTSOperation());
155 return (int) (monitoringStore.getAverageOperationsPerPeriod(getTokenType(), getCTSOperation()) * 100);
172 return monitoringStore.getOperationsCumulativeCount(getTokenType(), getCTSOperation());
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/connections/
H A DMonitoredCTSConnectionFactoryTest.java34 private CTSConnectionMonitoringStore monitoringStore; field in class:MonitoredCTSConnectionFactoryTest
43 monitoringStore = mock(CTSConnectionMonitoringStore.class);
45 monitoredConnectionFactory = new MonitoredCTSConnectionFactory(connectionFactory, monitoringStore);
63 verify(monitoringStore).addConnection(false);
76 verify(monitoringStore).addConnection(success);
90 verifyZeroInteractions(monitoringStore);
92 verify(monitoringStore).addConnection(false);
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/connections/
H A DMonitoredCTSConnectionFactoryTest.java34 private CTSConnectionMonitoringStore monitoringStore; field in class:MonitoredCTSConnectionFactoryTest
43 monitoringStore = mock(CTSConnectionMonitoringStore.class);
45 monitoredConnectionFactory = new MonitoredCTSConnectionFactory(connectionFactory, monitoringStore);
63 verify(monitoringStore).addConnection(false);
76 verify(monitoringStore).addConnection(success);
90 verifyZeroInteractions(monitoringStore);
92 verify(monitoringStore).addConnection(false);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/reaper/
H A DCTSReaper.java59 private final CTSReaperMonitoringStore monitoringStore; field in class:CTSReaper
67 * @param monitoringStore Required for monitoring reaper runs.
72 final CTSReaperMonitoringStore monitoringStore,
76 this.monitoringStore = monitoringStore;
131 monitoringStore.addReaperRun(query.getStartTime(), query.getTime() + waiting.getTime(), total);
71 CTSReaper(final ReaperQueryFactory queryFactory, final TokenDeletion tokenDeletion, final CTSReaperMonitoringStore monitoringStore, @Named(CoreTokenConstants.CTS_REAPER_DEBUG) final Debug debug) argument
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/worker/process/
H A DCTSWorkerDeleteProcess.java47 private CTSReaperMonitoringStore monitoringStore; field in class:CTSWorkerDeleteProcess
55 * @param monitoringStore Utility to record monitoring information.
60 CTSReaperMonitoringStore monitoringStore,
63 this.monitoringStore = monitoringStore;
74 monitoringStore.addReaperRun(queryStopWatch.getStartTime(),
59 CTSWorkerDeleteProcess(TokenDeletion tokenDeletion, CTSReaperMonitoringStore monitoringStore, @Named(CoreTokenConstants.CTS_DEBUG) Debug debug) argument
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/worker/process/
H A DCTSWorkerDeleteProcessTest.java44 private CTSReaperMonitoringStore monitoringStore; field in class:CTSWorkerDeleteProcessTest
51 monitoringStore = mock(CTSReaperMonitoringStore.class);
54 process = new CTSWorkerDeleteProcess(mockTokenDeletion, monitoringStore, mock(Debug.class));
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/reaper/
H A DCTSReaperTest.java41 private CTSReaperMonitoringStore monitoringStore; field in class:CTSReaperTest
48 monitoringStore = mock(CTSReaperMonitoringStore.class);
54 reaper = new CTSReaper(mockQueryFactory, mockTokenDeletion, monitoringStore, mock(Debug.class));

Completed in 36 milliseconds