聊聊debezium的Heartbeat
Heartbeatdebezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/heartbeat/Heartbeat.javapublic interface Heartbeat { public static final String HEARTBEAT_INTERVAL_PROPERTY_NAME = "heartbeat.interval.ms"; @FunctionalInterface public static i...
2024-01-10
聊聊dubbogo的TokenFilter
序本文主要研究一下dubbo-go的TokenFilterTokenFilterdubbo-go-v1.4.2/filter/filter_impl/token_filter.goconst ( // TOKEN ... TOKEN = "token")func init() { extension.SetFilter(TOKEN, GetTokenFilter)}// TokenFilter ...type TokenFilter struct{}TokenFilter的init方法设置了GetToken...
2024-01-10
聊聊dubbogo的RPCInvocation
序本文主要研究一下dubbo-go的RPCInvocationInvocationdubbo-go-v1.4.2/protocol/invocation.go// Invocation ...type Invocation interface { MethodName() string ParameterTypes() []reflect.Type ParameterValues() []reflect.Value Arguments() []interface{} Reply() interface{} ...
2024-01-10
聊聊canal的MysqlConnection
序本文主要研究一下canal的MysqlConnectionErosaConnectioncanal-1.1.4/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/ErosaConnection.javapublic interface ErosaConnection { public void connect() throws IOException; public void reconnect() throws IOExcep...
2024-01-10
聊聊dubbogo的metricsFilter
序本文主要研究一下dubbo-go的metricsFiltermetricsFilterdubbo-go-v1.4.2/filter/filter_impl/metrics_filter.goconst ( metricFilterName = "metrics")var ( metricFilterInstance filter.Filter)// must initialized before using the filter and after loading configurationfunc in...
2024-01-10
聊聊carrera的BrokerMonitor
序本文主要研究一下carrera的BrokerMonitorBrokerMonitorDDMQ/carrera-monitor/src/main/java/com/xiaojukeji/carrera/monitor/broker/BrokerMonitor.javapublic class BrokerMonitor extends BaseConfigMonitor { private final static Logger LOGGER = LoggerFactory.getLogger(Bro...
2024-01-10
聊聊skywalking的jedispulgin
skywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/jedis-2.x-plugin/src/main/resources/skywalking-plugin.defjedis-2.x=org.apache.skywalking.apm.plugin.jedis.v2.define.JedisClusterInstrumentationjedis-2.x=org.apache.skywalking.apm.plugin.jedis...
2024-01-10
聊聊nacossdkgo的ConfigProxy
ConfigProxynacos-sdk-go-v0.3.2/clients/config_client/config_proxy.gotype ConfigProxy struct { nacosServer nacos_server.NacosServer clientConfig constant.ClientConfig}ConfigProxy定义了nacosServer、clientConfig属性NewConfigProxynacos-sdk-go-v0.3.2/clients/config_...
2024-01-10
聊聊canal的DirectLogFetcher
序本文主要研究一下canal的DirectLogFetcherDirectLogFetchercanal-1.1.4/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/DirectLogFetcher.javapublic final class DirectLogFetcher extends LogFetcher { protected static final Log logger = LogF...
2024-01-10
聊聊nacossdkgo的NamingProxy
序本文主要研究一下nacos-sdk-go的NamingProxyNamingProxynacos-sdk-go-v0.3.2/clients/naming_client/naming_proxy.gotype NamingProxy struct { clientConfig constant.ClientConfig nacosServer nacos_server.NacosServer}NamingProxy定义了clientConfig、nacosServer属性NewNamingProxyna...
2024-01-10
聊聊dubbogo的forkingCluster
序本文主要研究一下dubbo-go的forkingClusterforkingClusterdubbo-go-v1.4.2/cluster/cluster_impl/forking_cluster.gotype forkingCluster struct{}const forking = "forking"func init() { extension.SetCluster(forking, NewForkingCluster)}// NewForkingCluster ...func NewForking...
2024-01-10
聊聊nacossdkgo的HostReactor
序本文主要研究一下nacos-sdk-go的HostReactorHostReactornacos-sdk-go-v0.3.2/clients/naming_client/host_reator.gotype HostReactor struct { serviceInfoMap cache.ConcurrentMap cacheDir string updateThreadNum int serviceProxy NamingProxy pus...
2024-01-10
聊聊artemis的FederatedQueue
FederatedQueueactivemq-artemis-2.11.0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/federation/queue/FederatedQueue.javapublic class FederatedQueue extends FederatedAbstract implements ActiveMQServerConsumerPlugin, Serializable { p...
2024-01-10
聊聊rocketmq的consumeTimeout
序本文主要研究一下rocketmq的consumeTimeoutconsumeTimeoutrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.javapublic class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer { private final InternalLogg...
2024-01-10
聊聊debezium的BlockingReader
Readerdebezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/Reader.javapublic interface Reader { public static enum State { /** * The reader is stopped and static. */ STOPPED, /** ...
2024-01-10
聊聊rocketmq的enableMsgTrace
序本文主要研究一下rocketmq的enableMsgTraceenableMsgTracerocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/producer/DefaultMQProducer.javapublic class DefaultMQProducer extends ClientConfig implements MQProducer { private final InternalLogger log = Cli...
2024-01-10
聊聊artemis的BaseInterceptor
序本文主要研究一下artemis的BaseInterceptorBaseInterceptoractivemq-artemis-master/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/BaseInterceptor.javapublic interface BaseInterceptor<P> { /** * Intercepts a packet which is received before ...
2024-01-10
聊聊rocketmq的sendMsgTimeout
序本文主要研究一下rocketmq的sendMsgTimeoutDefaultMQProducerrocketmq-client-4.5.2-sources.jar!/org/apache/rocketmq/client/producer/DefaultMQProducer.javapublic class DefaultMQProducer extends ClientConfig implements MQProducer { private final InternalLogger log = ...
2024-01-10
聊聊dubbogo的failfastCluster
序本文主要研究一下dubbo-go的failfastClusterfailfastClusterdubbo-go-v1.4.2/cluster/cluster_impl/failfast_cluster.gotype failfastCluster struct{}const failfast = "failfast"func init() { extension.SetCluster(failfast, NewFailFastCluster)}// NewFailFastCluster ...func N...
2024-01-10
聊聊puma的DefaultTaskExecutor
序本文主要研究一下puma的DefaultTaskExecutorTaskExecutorpuma/puma/src/main/java/com/dianping/puma/taskexecutor/TaskExecutor.javapublic interface TaskExecutor extends LifeCycle { boolean isStop(); boolean isMerging(); void stopUntil(long timestamp); void c...
2024-01-10
聊聊skywalking的HTTPAccessLog
HTTPAccessLogskywalking-6.6.0/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/HTTPAccessLog.java@ScopeDeclaration(id = HTTP_ACCESS_LOG, name = "HTTPAccessLog")public class HTTPAccessLog extends AbstractLog { @Override p...
2024-01-10
聊聊canal的CanalAdapterService
CanalAdapterServicecanal-1.1.4/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterService.java@Component@RefreshScopepublic class CanalAdapterService { private static final Logger logger = LoggerFactory.ge...
2024-01-10
聊聊debezium的ChangeEventQueue
ChangeEventQueueMetricsdebezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueueMetrics.javapublic interface ChangeEventQueueMetrics { int totalCapacity(); int remainingCapacity();}ChangeEventQueueMetrics接口定义了total...
2024-01-10
聊聊SpinalTap的MysqlEventFilter
序本文主要研究一下SpinalTap的MysqlEventFilterMysqlEventFilterSpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/filter/MysqlEventFilter.javapublic abstract class MysqlEventFilter implements Filter<BinlogEvent> { public static Filter<BinlogEven...
2024-01-10
聊聊skywalking的dubbo2.7.xplugin
skywalking-plugin.defskywalking-6.6.0/apm-sniffer/apm-sdk-plugin/dubbo-2.7.x-plugin/src/main/resources/skywalking-plugin.defdubbo=org.apache.skywalking.apm.plugin.asf.dubbo.DubboInstrumentationskywalking的dubbo-plugin提供了DubboInstrumentation增强DubboInstrument...
2024-01-10
