@Test public void testLogMonitorMethodInstance() throws ClassNotFoundException, NoSuchMethodException { SingerSettings.getLogMonitorStaticInstanceMethod(DefaultLogMonitor.class.getName()); }
public static Method getLogMonitorStaticInstanceMethod(String monitorClassName) throws ClassNotFoundException, NoSuchMethodException { Class<?> monitorClass = Class.forName(monitorClassName); Method getInstance = monitorClass.getMethod("getInstance", int.class, SingerConfig.class); return getInstance; }
SingerSettings { public static Method getLogMonitorStaticInstanceMethod(String monitorClassName) throws ClassNotFoundException, NoSuchMethodException { Class<?> monitorClass = Class.forName(monitorClassName); Method getInstance = monitorClass.getMethod("getInstance", int.class, SingerConfig.class); return getInstance; } }
SingerSettings { public static Method getLogMonitorStaticInstanceMethod(String monitorClassName) throws ClassNotFoundException, NoSuchMethodException { Class<?> monitorClass = Class.forName(monitorClassName); Method getInstance = monitorClass.getMethod("getInstance", int.class, SingerConfig.class); return getInstance; } private  SingerSettings(); }
SingerSettings { public static Method getLogMonitorStaticInstanceMethod(String monitorClassName) throws ClassNotFoundException, NoSuchMethodException { Class<?> monitorClass = Class.forName(monitorClassName); Method getInstance = monitorClass.getMethod("getInstance", int.class, SingerConfig.class); return getInstance; } private  SingerSettings(); static void initialize(SingerConfig config); static Method getLogMonitorStaticInstanceMethod(String monitorClassName); static SortedMap<String, Collection<SingerLogConfig>> loadLogConfigMap(SingerConfig config); static synchronized FileSystemMonitor getOrCreateFileSystemMonitor(String podUid); static Map<String, FileSystemMonitor> getFsMonitorMap(); static LogMonitor getLogMonitor(); static Map<String, ExecutorService> getLogWritingExecutors(); static SingerConfig getSingerConfig(); static void setSingerConfig(SingerConfig singerConfig); static void reset(); static SortedMap<String, Collection<SingerLogConfig>> getLogConfigMap(); static ScheduledExecutorService getBackgroundTaskExecutor(); static void setBackgroundTaskExecutor(ScheduledExecutorService backgroundTaskExecutor); static ScheduledExecutorService getLogProcessorExecutor(); static void initializeConfigMap(SingerConfig config); static Environment getEnvironment(); @VisibleForTesting static void setEnvironment(Environment environment); static LoggingAuditClient getLoggingAuditClient(); static void setLoggingAuditClient(LoggingAuditClient loggingAuditClient); static Thread getKafkaProducerMonitorThread(); }
SingerSettings { public static Method getLogMonitorStaticInstanceMethod(String monitorClassName) throws ClassNotFoundException, NoSuchMethodException { Class<?> monitorClass = Class.forName(monitorClassName); Method getInstance = monitorClass.getMethod("getInstance", int.class, SingerConfig.class); return getInstance; } private  SingerSettings(); static void initialize(SingerConfig config); static Method getLogMonitorStaticInstanceMethod(String monitorClassName); static SortedMap<String, Collection<SingerLogConfig>> loadLogConfigMap(SingerConfig config); static synchronized FileSystemMonitor getOrCreateFileSystemMonitor(String podUid); static Map<String, FileSystemMonitor> getFsMonitorMap(); static LogMonitor getLogMonitor(); static Map<String, ExecutorService> getLogWritingExecutors(); static SingerConfig getSingerConfig(); static void setSingerConfig(SingerConfig singerConfig); static void reset(); static SortedMap<String, Collection<SingerLogConfig>> getLogConfigMap(); static ScheduledExecutorService getBackgroundTaskExecutor(); static void setBackgroundTaskExecutor(ScheduledExecutorService backgroundTaskExecutor); static ScheduledExecutorService getLogProcessorExecutor(); static void initializeConfigMap(SingerConfig config); static Environment getEnvironment(); @VisibleForTesting static void setEnvironment(Environment environment); static LoggingAuditClient getLoggingAuditClient(); static void setLoggingAuditClient(LoggingAuditClient loggingAuditClient); static Thread getKafkaProducerMonitorThread(); static SingerDirectoryWatcher directoryWatcher; static HeartbeatGenerator heartbeatGenerator; }