提交 50faf615 编写于 作者: wu-sheng's avatar wu-sheng 提交者: GitHub

Merge pull request #539 from OpenSkywalking/feature/rename

To change the name of the author from pengys5 to Peng-yongsheng.
......@@ -49,7 +49,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class JVMMetricsServiceHandler extends JVMMetricsServiceGrpc.JVMMetricsServiceImplBase implements GRPCHandler {
......
......@@ -32,7 +32,7 @@ import org.skywalking.apm.collector.stream.worker.selector.RollingSelector;
import org.skywalking.apm.collector.stream.worker.selector.WorkerSelector;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class CpuMetricPersistenceWorker extends PersistenceWorker {
......
......@@ -31,7 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class CpuMetricEsDAO extends EsDAO implements ICpuMetricDAO, IPersistenceDAO<IndexRequestBuilder, UpdateRequestBuilder> {
......
......@@ -32,7 +32,7 @@ import java.util.HashMap;
import java.util.Map;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class CpuMetricH2DAO extends H2DAO implements ICpuMetricDAO, IPersistenceDAO<H2SqlEntity, H2SqlEntity> {
private final Logger logger = LoggerFactory.getLogger(CpuMetricH2DAO.class);
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentjvm.worker.cpu.dao;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface ICpuMetricDAO {
}
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchCo
import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchTableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class CpuMetricEsTableDefine extends ElasticSearchTableDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2ColumnDefine;
import org.skywalking.apm.collector.storage.h2.define.H2TableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class CpuMetricH2TableDefine extends H2TableDefine {
......
......@@ -32,7 +32,7 @@ import org.skywalking.apm.collector.stream.worker.selector.RollingSelector;
import org.skywalking.apm.collector.stream.worker.selector.WorkerSelector;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class GCMetricPersistenceWorker extends PersistenceWorker {
......
......@@ -29,7 +29,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.dao.EsDAO;
import org.skywalking.apm.collector.stream.worker.impl.dao.IPersistenceDAO;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class GCMetricEsDAO extends EsDAO implements IGCMetricDAO, IPersistenceDAO<IndexRequestBuilder, UpdateRequestBuilder> {
......
......@@ -30,7 +30,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2SqlEntity;
import org.skywalking.apm.collector.stream.worker.impl.dao.IPersistenceDAO;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class GCMetricH2DAO extends H2DAO implements IGCMetricDAO, IPersistenceDAO<H2SqlEntity, H2SqlEntity> {
@Override public Data get(String id, DataDefine dataDefine) {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentjvm.worker.gc.dao;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface IGCMetricDAO {
}
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchCo
import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchTableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class GCMetricEsTableDefine extends ElasticSearchTableDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2ColumnDefine;
import org.skywalking.apm.collector.storage.h2.define.H2TableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class GCMetricH2TableDefine extends H2TableDefine {
......
......@@ -32,7 +32,7 @@ import org.skywalking.apm.collector.stream.worker.selector.RollingSelector;
import org.skywalking.apm.collector.stream.worker.selector.WorkerSelector;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstHeartBeatPersistenceWorker extends PersistenceWorker {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentjvm.worker.heartbeat.dao;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface IInstanceHeartBeatDAO {
}
\ No newline at end of file
......@@ -33,7 +33,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceHeartBeatEsDAO extends EsDAO implements IInstanceHeartBeatDAO, IPersistenceDAO<IndexRequestBuilder, UpdateRequestBuilder> {
......
......@@ -39,7 +39,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class InstanceHeartBeatH2DAO extends H2DAO implements IInstanceHeartBeatDAO, IPersistenceDAO<H2SqlEntity, H2SqlEntity> {
private final Logger logger = LoggerFactory.getLogger(InstanceHeartBeatEsDAO.class);
......
......@@ -29,7 +29,7 @@ import org.skywalking.apm.collector.storage.define.DataDefine;
import org.skywalking.apm.collector.storage.define.register.InstanceTable;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceHeartBeatDataDefine extends DataDefine {
......
......@@ -32,7 +32,7 @@ import org.skywalking.apm.collector.stream.worker.selector.RollingSelector;
import org.skywalking.apm.collector.stream.worker.selector.WorkerSelector;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryMetricPersistenceWorker extends PersistenceWorker {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentjvm.worker.memory.dao;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface IMemoryMetricDAO {
}
......@@ -29,7 +29,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.dao.EsDAO;
import org.skywalking.apm.collector.stream.worker.impl.dao.IPersistenceDAO;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryMetricEsDAO extends EsDAO implements IMemoryMetricDAO, IPersistenceDAO<IndexRequestBuilder, UpdateRequestBuilder> {
......
......@@ -30,7 +30,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2SqlEntity;
import org.skywalking.apm.collector.stream.worker.impl.dao.IPersistenceDAO;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class MemoryMetricH2DAO extends H2DAO implements IMemoryMetricDAO, IPersistenceDAO<H2SqlEntity, H2SqlEntity> {
@Override public Data get(String id, DataDefine dataDefine) {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchCo
import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchTableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryMetricEsTableDefine extends ElasticSearchTableDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2ColumnDefine;
import org.skywalking.apm.collector.storage.h2.define.H2TableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryMetricH2TableDefine extends H2TableDefine {
......
......@@ -32,7 +32,7 @@ import org.skywalking.apm.collector.stream.worker.selector.RollingSelector;
import org.skywalking.apm.collector.stream.worker.selector.WorkerSelector;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryPoolMetricPersistenceWorker extends PersistenceWorker {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentjvm.worker.memorypool.dao;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface IMemoryPoolMetricDAO {
}
......@@ -29,7 +29,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.dao.EsDAO;
import org.skywalking.apm.collector.stream.worker.impl.dao.IPersistenceDAO;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryPoolMetricEsDAO extends EsDAO implements IMemoryPoolMetricDAO, IPersistenceDAO<IndexRequestBuilder, UpdateRequestBuilder> {
......
......@@ -30,7 +30,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2SqlEntity;
import org.skywalking.apm.collector.stream.worker.impl.dao.IPersistenceDAO;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class MemoryPoolMetricH2DAO extends H2DAO implements IMemoryPoolMetricDAO, IPersistenceDAO<H2SqlEntity, H2SqlEntity> {
@Override public Data get(String id, DataDefine dataDefine) {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchCo
import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchTableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryPoolMetricEsTableDefine extends ElasticSearchTableDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2ColumnDefine;
import org.skywalking.apm.collector.storage.h2.define.H2TableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class MemoryPoolMetricH2TableDefine extends H2TableDefine {
......
......@@ -35,7 +35,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class JVMMetricsServiceHandlerTestCase {
......
......@@ -30,7 +30,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationIDService {
......
......@@ -30,7 +30,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationRegisterServiceHandler extends ApplicationRegisterServiceGrpc.ApplicationRegisterServiceImplBase implements GRPCHandler {
......
......@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceDiscoveryServiceHandler extends InstanceDiscoveryServiceGrpc.InstanceDiscoveryServiceImplBase implements GRPCHandler {
......
......@@ -31,7 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameDiscoveryServiceHandler extends ServiceNameDiscoveryServiceGrpc.ServiceNameDiscoveryServiceImplBase implements GRPCHandler {
......
......@@ -31,7 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceIDService {
......
......@@ -31,7 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationRegisterServletHandler extends JettyHandler {
......
......@@ -30,7 +30,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceDiscoveryServletHandler extends JettyHandler {
......
......@@ -31,7 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameDiscoveryServiceHandler extends JettyHandler {
......
......@@ -31,7 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameService {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentregister.worker;
/**
* @author pengys5
* @author peng-yongsheng
*/
public enum IdAutoIncrement {
INSTANCE;
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchCo
import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchTableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationEsTableDefine extends ElasticSearchTableDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2ColumnDefine;
import org.skywalking.apm.collector.storage.h2.define.H2TableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationH2TableDefine extends H2TableDefine {
......
......@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationRegisterRemoteWorker extends AbstractRemoteWorker {
......
......@@ -37,7 +37,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationRegisterSerialWorker extends AbstractLocalAsyncWorker {
......
......@@ -30,7 +30,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationEsDAO extends EsDAO implements IApplicationDAO {
......
......@@ -28,7 +28,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class ApplicationH2DAO extends H2DAO implements IApplicationDAO {
private final Logger logger = LoggerFactory.getLogger(ApplicationH2DAO.class);
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentregister.worker.application.dao;
import org.skywalking.apm.collector.storage.define.register.ApplicationDataDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface IApplicationDAO {
int getMaxApplicationId();
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchCo
import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchTableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceEsTableDefine extends ElasticSearchTableDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2ColumnDefine;
import org.skywalking.apm.collector.storage.h2.define.H2TableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceH2TableDefine extends H2TableDefine {
......
......@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceRegisterRemoteWorker extends AbstractRemoteWorker {
......
......@@ -35,7 +35,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceRegisterSerialWorker extends AbstractLocalAsyncWorker {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentregister.worker.instance.dao;
import org.skywalking.apm.collector.storage.define.register.InstanceDataDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface IInstanceDAO {
int getInstanceId(int applicationId, String agentUUID);
......
......@@ -37,7 +37,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class InstanceEsDAO extends EsDAO implements IInstanceDAO {
......
......@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class InstanceH2DAO extends H2DAO implements IInstanceDAO {
private final Logger logger = LoggerFactory.getLogger(InstanceH2DAO.class);
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchCo
import org.skywalking.apm.collector.storage.elasticsearch.define.ElasticSearchTableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameEsTableDefine extends ElasticSearchTableDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.storage.h2.define.H2ColumnDefine;
import org.skywalking.apm.collector.storage.h2.define.H2TableDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameH2TableDefine extends H2TableDefine {
......
......@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameRegisterRemoteWorker extends AbstractRemoteWorker {
......
......@@ -37,7 +37,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameRegisterSerialWorker extends AbstractLocalAsyncWorker {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentregister.worker.servicename.dao;
import org.skywalking.apm.collector.storage.define.register.ServiceNameDataDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public interface IServiceNameDAO {
int getMaxServiceId();
......
......@@ -30,7 +30,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ServiceNameEsDAO extends EsDAO implements IServiceNameDAO {
......
......@@ -30,7 +30,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5, clevertension
* @author peng-yongsheng, clevertension
*/
public class ServiceNameH2DAO extends H2DAO implements IServiceNameDAO {
private final Logger logger = LoggerFactory.getLogger(ServiceNameH2DAO.class);
......
......@@ -27,7 +27,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ApplicationRegisterServiceHandlerTestCase {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentserver;
import org.skywalking.apm.collector.core.framework.Context;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerModuleContext extends Context {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.core.cluster.ClusterDataListenerDefine;
import org.skywalking.apm.collector.core.module.ModuleDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public abstract class AgentServerModuleDefine extends ModuleDefine implements ClusterDataListenerDefine {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentserver;
import org.skywalking.apm.collector.core.module.ModuleException;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerModuleException extends ModuleException {
......
......@@ -24,7 +24,7 @@ import org.skywalking.apm.collector.core.module.ModuleGroupDefine;
import org.skywalking.apm.collector.core.module.ModuleInstaller;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerModuleGroupDefine implements ModuleGroupDefine {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.core.framework.Context;
import org.skywalking.apm.collector.core.module.MultipleModuleInstaller;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerModuleInstaller extends MultipleModuleInstaller {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentserver.jetty;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerJettyConfig {
public static String HOST;
......
......@@ -25,7 +25,7 @@ import org.skywalking.apm.collector.core.util.ObjectUtils;
import org.skywalking.apm.collector.core.util.StringUtils;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerJettyConfigParser implements ModuleConfigParser {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.cluster.ClusterModuleDefine;
import org.skywalking.apm.collector.core.cluster.ClusterDataListener;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerJettyDataListener extends ClusterDataListener {
......
......@@ -33,7 +33,7 @@ import org.skywalking.apm.collector.core.server.Server;
import org.skywalking.apm.collector.server.jetty.JettyServer;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerJettyModuleDefine extends AgentServerModuleDefine {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentserver.jetty;
import org.skywalking.apm.collector.core.module.ModuleRegistration;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentServerJettyModuleRegistration extends ModuleRegistration {
......
......@@ -29,7 +29,7 @@ import org.skywalking.apm.collector.server.jetty.ArgumentsParseException;
import org.skywalking.apm.collector.server.jetty.JettyHandler;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamGRPCServerHandler extends JettyHandler {
......
......@@ -29,7 +29,7 @@ import org.skywalking.apm.collector.server.jetty.ArgumentsParseException;
import org.skywalking.apm.collector.server.jetty.JettyHandler;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamJettyServerHandler extends JettyHandler {
......
......@@ -29,7 +29,7 @@ import org.skywalking.apm.collector.server.jetty.JettyHandler;
import org.skywalking.apm.collector.ui.jetty.UIJettyDataListener;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class UIJettyServerHandler extends JettyHandler {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentstream;
import org.skywalking.apm.collector.core.framework.Context;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamModuleContext extends Context {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.core.cluster.ClusterDataListenerDefine;
import org.skywalking.apm.collector.core.module.ModuleDefine;
/**
* @author pengys5
* @author peng-yongsheng
*/
public abstract class AgentStreamModuleDefine extends ModuleDefine implements ClusterDataListenerDefine {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentstream;
import org.skywalking.apm.collector.core.module.ModuleException;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamModuleException extends ModuleException {
public AgentStreamModuleException(String message) {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.agentstream.config.BufferFileConfig;
import org.skywalking.apm.collector.core.config.GroupConfigParser;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamModuleGroupConfigParser implements GroupConfigParser {
......
......@@ -24,7 +24,7 @@ import org.skywalking.apm.collector.core.module.ModuleGroupDefine;
import org.skywalking.apm.collector.core.module.ModuleInstaller;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamModuleGroupDefine implements ModuleGroupDefine {
......
......@@ -28,7 +28,7 @@ import org.skywalking.apm.collector.core.module.MultipleModuleInstaller;
import org.skywalking.apm.collector.core.server.ServerException;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamModuleInstaller extends MultipleModuleInstaller {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentstream.config;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class BufferFileConfig {
public static int BUFFER_OFFSET_MAX_FILE_SIZE = 10 * 1024 * 1024;
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentstream.grpc;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamGRPCConfig {
public static String HOST;
......
......@@ -25,7 +25,7 @@ import org.skywalking.apm.collector.core.util.ObjectUtils;
import org.skywalking.apm.collector.core.util.StringUtils;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamGRPCConfigParser implements ModuleConfigParser {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.cluster.ClusterModuleDefine;
import org.skywalking.apm.collector.core.cluster.ClusterDataListener;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamGRPCDataListener extends ClusterDataListener {
......
......@@ -35,7 +35,7 @@ import org.skywalking.apm.collector.core.server.Server;
import org.skywalking.apm.collector.server.grpc.GRPCServer;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamGRPCModuleDefine extends AgentStreamModuleDefine {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentstream.grpc;
import org.skywalking.apm.collector.core.module.ModuleRegistration;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamGRPCModuleRegistration extends ModuleRegistration {
......
......@@ -28,7 +28,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class TraceSegmentServiceHandler extends TraceSegmentServiceGrpc.TraceSegmentServiceImplBase implements GRPCHandler {
......
......@@ -19,7 +19,7 @@
package org.skywalking.apm.collector.agentstream.jetty;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamJettyConfig {
public static String HOST;
......
......@@ -25,7 +25,7 @@ import org.skywalking.apm.collector.core.util.ObjectUtils;
import org.skywalking.apm.collector.core.util.StringUtils;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamJettyConfigParser implements ModuleConfigParser {
......
......@@ -23,7 +23,7 @@ import org.skywalking.apm.collector.cluster.ClusterModuleDefine;
import org.skywalking.apm.collector.core.cluster.ClusterDataListener;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamJettyDataListener extends ClusterDataListener {
......
......@@ -34,7 +34,7 @@ import org.skywalking.apm.collector.core.server.Server;
import org.skywalking.apm.collector.server.jetty.JettyServer;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamJettyModuleDefine extends AgentStreamModuleDefine {
......
......@@ -21,7 +21,7 @@ package org.skywalking.apm.collector.agentstream.jetty;
import org.skywalking.apm.collector.core.module.ModuleRegistration;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class AgentStreamJettyModuleRegistration extends ModuleRegistration {
......
......@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class TraceSegmentServletHandler extends JettyHandler {
......
......@@ -23,7 +23,7 @@ import java.io.IOException;
import org.skywalking.apm.network.proto.KeyWithStringValue;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class KeyWithStringValueJsonReader implements StreamJsonReader<KeyWithStringValue> {
......
......@@ -23,7 +23,7 @@ import java.io.IOException;
import org.skywalking.apm.network.proto.LogMessage;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class LogJsonReader implements StreamJsonReader<LogMessage> {
......
......@@ -23,7 +23,7 @@ import java.io.IOException;
import org.skywalking.apm.network.proto.TraceSegmentReference;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class ReferenceJsonReader implements StreamJsonReader<TraceSegmentReference> {
......
......@@ -25,7 +25,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class SegmentJsonReader implements StreamJsonReader<TraceSegmentObject.Builder> {
......
......@@ -23,7 +23,7 @@ import java.io.IOException;
import org.skywalking.apm.network.proto.SpanObject;
/**
* @author pengys5
* @author peng-yongsheng
*/
public class SpanJsonReader implements StreamJsonReader<SpanObject> {
......
此差异已折叠。
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册