CJDBCversion1.0.4: src/org/objectweb/cjdbc/common/monitor/DataCollectionNames.java ソースファイル

00001 00025 package org.objectweb.cjdbc.common.monitor; 00026 00027 import org.objectweb.cjdbc.common.i18n.Translate; 00028 00033 public class DataCollectionNames implements DataCollection 00034 { 00035 00042 public static String get(int dataType) 00043 { 00044 switch (dataType) 00045 { 00046 /* 00047 * Controller Collectors 00048 */ 00049 case CONTROLLER_TOTAL_MEMORY : 00050 return Translate.get("monitoring.controller.total.memory"); 00051 case CONTROLLER_USED_MEMORY : 00052 return Translate.get("monitoring.controller.used.memory"); 00053 case CONTROLLER_WORKER_PENDING_QUEUE : 00054 return Translate.get("monitoring.controller.pending.queue"); 00055 case CONTROLLER_THREADS_NUMBER : 00056 return Translate.get("monitoring.controller.threads.number"); 00057 case CONTROLLER_IDLE_WORKER_THREADS : 00058 return Translate.get("monitoring.controller.idle.worker.threads"); 00059 /* 00060 * Backend collectors 00061 */ 00062 case BACKEND_ACTIVE_TRANSACTION : 00063 return Translate.get("monitoring.backend.active.transactions"); 00064 case BACKEND_PENDING_REQUESTS : 00065 return Translate.get("monitoring.backend.pending.requests"); 00066 case BACKEND_TOTAL_ACTIVE_CONNECTIONS : 00067 return Translate.get("monitoring.backend.active.connections"); 00068 case BACKEND_TOTAL_REQUEST : 00069 return Translate.get("monitoring.backend.total.requests"); 00070 case BACKEND_TOTAL_READ_REQUEST : 00071 return Translate.get("monitoring.backend.total.read.requests"); 00072 case BACKEND_TOTAL_WRITE_REQUEST : 00073 return Translate.get("monitoring.backend.total.write.requests"); 00074 case BACKEND_TOTAL_TRANSACTIONS : 00075 return Translate.get("monitoring.backend.total.transactions"); 00076 /* 00077 * VirtualDatabase collectors 00078 */ 00079 case DATABASES_ACTIVE_THREADS : 00080 return Translate.get("monitoring.virtualdatabase.active.threads"); 00081 case DATABASES_PENDING_CONNECTIONS : 00082 return Translate.get("monitoring.virtualdatabase.pending.connections"); 00083 case DATABASES_NUMBER_OF_THREADS : 00084 return Translate.get("monitoring.virtualdatabase.threads.count"); 00085 /* 00086 * Cache stats collectors 00087 */ 00088 case CACHE_STATS_COUNT_HITS : 00089 return Translate.get("monitoring.cache.count.hits"); 00090 case CACHE_STATS_COUNT_INSERT : 00091 return Translate.get("monitoring.cache.count.insert"); 00092 case CACHE_STATS_COUNT_SELECT : 00093 return Translate.get("monitoring.cache.count.select"); 00094 case CACHE_STATS_HITS_PERCENTAGE : 00095 return Translate.get("monitoring.cache.hits.ratio"); 00096 case CACHE_STATS_NUMBER_ENTRIES : 00097 return Translate.get("monitoring.cache.number.entries"); 00098 /* 00099 * Scheduler collectors 00100 */ 00101 case SCHEDULER_NUMBER_READ : 00102 return Translate.get("monitoring.scheduler.number.read"); 00103 case SCHEDULER_NUMBER_REQUESTS : 00104 return Translate.get("monitoring.scheduler.number.requests"); 00105 case SCHEDULER_NUMBER_WRITES : 00106 return Translate.get("monitoring.scheduler.number.writes"); 00107 case SCHEDULER_PENDING_TRANSACTIONS : 00108 return Translate.get("monitoring.scheduler.pending.transactions"); 00109 case SCHEDULER_PENDING_WRITES : 00110 return Translate.get("monitoring.scheduler.pending.writes"); 00111 /* 00112 * Client collectors 00113 */ 00114 case CLIENT_BYTES_READ : 00115 return Translate.get("monitoring.client.bytes.read"); 00116 case CLIENT_BYTES_WRITTEN : 00117 return Translate.get("monitoring.client.bytes.written"); 00118 case CLIENT_TIME_ACTIVE : 00119 return Translate.get("monitoring.client.time.active"); 00120 case CLIENT_READING_SPEED : 00121 return Translate.get("monitoring.client.reading.speed"); 00122 case CLIENT_WRITING_SPEED : 00123 return Translate.get("monitoring.client.writing.speed"); 00124 /* 00125 * Unknown collector 00126 */ 00127 default : 00128 return ""; 00129 } 00130 } 00131 00138 public static int getTypeFromCommand(String command) 00139 { 00140 command = command.replace('_', ' '); 00141 /* 00142 * Controller Collectors 00143 */ 00144 if (command.equalsIgnoreCase(Translate 00145 .get("monitoring.controller.total.memory"))) 00146 return CONTROLLER_TOTAL_MEMORY; 00147 else if (command.equalsIgnoreCase(Translate 00148 .get("monitoring.controller.used.memory"))) 00149 return CONTROLLER_USED_MEMORY; 00150 else if (command.equalsIgnoreCase(Translate 00151 .get("monitoring.controller.pending.queue"))) 00152 return CONTROLLER_WORKER_PENDING_QUEUE; 00153 else if (command.equalsIgnoreCase(Translate 00154 .get("monitoring.controller.threads.number"))) 00155 return CONTROLLER_THREADS_NUMBER; 00156 else if (command.equalsIgnoreCase(Translate 00157 .get("monitoring.controller.idle.worker.threads"))) 00158 return CONTROLLER_IDLE_WORKER_THREADS; 00159 00160 /* 00161 * Backend collectors 00162 */ 00163 else if (command.equalsIgnoreCase(Translate 00164 .get("monitoring.backend.active.transactions"))) 00165 return BACKEND_ACTIVE_TRANSACTION; 00166 else if (command.equalsIgnoreCase(Translate 00167 .get("monitoring.backend.pending.requests"))) 00168 return BACKEND_PENDING_REQUESTS; 00169 else if (command.equalsIgnoreCase(Translate 00170 .get("monitoring.backend.active.connections"))) 00171 return BACKEND_TOTAL_ACTIVE_CONNECTIONS; 00172 else if (command.equalsIgnoreCase(Translate 00173 .get("monitoring.backend.total.read.requests"))) 00174 return BACKEND_TOTAL_READ_REQUEST; 00175 else if (command.equalsIgnoreCase(Translate 00176 .get("monitoring.backend.total.write.requests"))) 00177 return BACKEND_TOTAL_WRITE_REQUEST; 00178 else if (command.equalsIgnoreCase(Translate 00179 .get("monitoring.backend.total.requests"))) 00180 return BACKEND_TOTAL_REQUEST; 00181 else if (command.equalsIgnoreCase(Translate 00182 .get("monitoring.backend.total.transactions"))) 00183 return BACKEND_TOTAL_TRANSACTIONS; 00184 00185 /* 00186 * VirtualDatabase collectors 00187 */ 00188 else if (command.equalsIgnoreCase(Translate 00189 .get("monitoring.virtualdatabase.active.threads"))) 00190 return DATABASES_ACTIVE_THREADS; 00191 else if (command.equalsIgnoreCase(Translate 00192 .get("monitoring.virtualdatabase.pending.connections"))) 00193 return DATABASES_PENDING_CONNECTIONS; 00194 else if (command.equalsIgnoreCase(Translate 00195 .get("monitoring.virtualdatabase.threads.count"))) 00196 return DATABASES_NUMBER_OF_THREADS; 00197 00198 /* 00199 * Cache stats collectors 00200 */ 00201 else if (command.equalsIgnoreCase(Translate 00202 .get("monitoring.cache.count.hits"))) 00203 return CACHE_STATS_COUNT_HITS; 00204 else if (command.equalsIgnoreCase(Translate 00205 .get("monitoring.cache.count.insert"))) 00206 return CACHE_STATS_COUNT_INSERT; 00207 else if (command.equalsIgnoreCase(Translate 00208 .get("monitoring.cache.count.select"))) 00209 return CACHE_STATS_COUNT_SELECT; 00210 else if (command.equalsIgnoreCase(Translate 00211 .get("monitoring.cache.hits.ratio"))) 00212 return CACHE_STATS_HITS_PERCENTAGE; 00213 else if (command.equalsIgnoreCase(Translate 00214 .get("monitoring.cache.number.entries"))) 00215 return CACHE_STATS_NUMBER_ENTRIES; 00216 00217 /* 00218 * Scheduler collectors 00219 */ 00220 else if (command.equalsIgnoreCase(Translate 00221 .get("monitoring.scheduler.number.read"))) 00222 return SCHEDULER_NUMBER_READ; 00223 else if (command.equalsIgnoreCase(Translate 00224 .get("monitoring.scheduler.number.requests"))) 00225 return SCHEDULER_NUMBER_REQUESTS; 00226 else if (command.equalsIgnoreCase(Translate 00227 .get("monitoring.scheduler.number.writes"))) 00228 return SCHEDULER_NUMBER_WRITES; 00229 else if (command.equalsIgnoreCase(Translate 00230 .get("monitoring.scheduler.pending.transactions"))) 00231 return SCHEDULER_PENDING_TRANSACTIONS; 00232 else if (command.equalsIgnoreCase(Translate 00233 .get("monitoring.scheduler.pending.writes"))) 00234 return SCHEDULER_PENDING_WRITES; 00235 00236 /* 00237 * Client collectors 00238 */ 00239 else if (command.equalsIgnoreCase(Translate 00240 .get("monitoring.client.bytes.read"))) 00241 return CLIENT_BYTES_READ; 00242 else if (command.equalsIgnoreCase(Translate 00243 .get("monitoring.client.bytes.written"))) 00244 return CLIENT_BYTES_WRITTEN; 00245 else if (command.equalsIgnoreCase(Translate 00246 .get("monitoring.client.time.active"))) 00247 return CLIENT_TIME_ACTIVE; 00248 else if (command.equalsIgnoreCase(Translate 00249 .get("monitoring.client.reading.speed"))) 00250 return CLIENT_READING_SPEED; 00251 else if (command.equalsIgnoreCase(Translate 00252 .get("monitoring.client.writing.speed"))) 00253 return CLIENT_WRITING_SPEED; 00254 00255 else 00256 return 0; 00257 } 00258 }