序本文主要研究一下storagetapper的cachecachestoragetapper/pipe/cache.go {代码...} cache是一个cacheEntry的map，cacheEntry定义了Pipe和config.PipeConfigCacheGetstoragetapper/pipe/cache.go {代码...} CacheGet方法加锁操作cache，首先通过sha256来对pipeType及db来作为cache的key，然后取出cacheEntry，若存在则...

序本文主要研究一下storagetapper的poolThreadstoragetapper/pool/pool.go {代码...} Thread接口定义了Start、Adjust、Terminate、NumProcs方法poolstoragetapper/pool/pool.go {代码...} poolImpl定义了mutex、numProcs、maxNumProcs、fn属性；它实现了Thread接口，其Start方法设置了fn，同时执行Adjust方法；Adjust方...

序本文主要研究一下storagetapper的pipePipestoragetapper/pipe/pipe.go {代码...} Pipe接口定义了NewConsumer、NewProducer、Type、Config、Close方法Consumerstoragetapper/pipe/pipe.go {代码...} Consumer接口定义了Close、CloseOnFailure、Message、Error、FetchNext、SaveOffset、SetFormat方法Producerstoragetap...

序本文主要研究一下storagetapper的LockLockstoragetapper/lock/lock.go {代码...} Lock接口定义了TryLock、TryLockShared、Lock、Refresh、Unlock、Close方法myLockstoragetapper/lock/lock.go {代码...} myLock定义了conn、connID、name、db.Addr、n、mu、isLocked属性，它使用db实现了Lock接口；其Lock、TryLock、Try...

storagetapper的server提供了StartHTTPServer、Shutdown方法；其init方法注册了/health，/schema，/cluster，/table，/config，/这几个url

序本文主要研究一下nacos-coredns-plugin的UDPServerUDPServernacos-coredns-plugin/nacos/udp_server.go {代码...} UDPServer定义了port、host、vipClient属性StartServernacos-coredns-plugin/nacos/udp_server.go {代码...} StartServer方法循环3次执行tryListen()，若都没有成功则exit；若成功则for循环执行handleCl...

ServerManager定义了serverList、lastRefreshTime、cursor属性；它提供了RefreshServerListIfNeed、NextServer、SetServers、GetServerList方法；其中NextServer会先执行RefreshServerListIfNeed在返回随机的server；RefreshServerListIfNeed方法会根据lastRefreshTime来判断是否需要refresh，若要refresh则重新通过os.G...

Domain定义了Name、Clusters、CacheMillis、LastRefMillis、Instances、Env、TTL属性；它提供了getInstances、String、SrvInstances方法；其中SrvInstances方法根据instance的权重来返回对应个数的instance

序本文主要研究一下gost的DeltaCompareDeltaComparegost/math/compare.go {代码...} DeltaCompareFloat64及DeltaCompareFloat32对比两个float类型的差值是否小于等于指定的delta实例gost/math/compare_test.go {代码...} 小结gost的提供了DeltaCompareFloat32、DeltaCompareFloat64方法用于对比两个float类型的差值是否...

HashSet定义了Items属性；NewSet根据values来创建HashSet；它提供了Add、Remove、Contains、Empty、Size、Clear、Values、String方法

CountWatch定义了start属性，它提供了Start、Reset、Count方法；其中Start方法判断start为初始值的时候设置为time.Now；Reset设置start为time.Now；Count计算当前时间距离start的纳秒数

GenericTaskPool接口定义了AddTask、AddTaskAlways、AddTaskBalance、Close、IsClosed接口

ObjectPool定义了New及sync.Pool属性，它提供了Get、Put方法，同时还有NewObjectPool工程方法；New是一个func，返回PoolObject；PoolObject接口定义了Reset方法

Pager接口定义了GetOffset、GetPageSize、GetTotalPages、GetData、GetDataSize、HasNext、HasData方法

GoUnterminated方法提供handle、WaitGroup、ignoreRecover、period参数，其内部使用的是GoSafely，只是catchFunc是内置的；catchFunc对于period大于0的会sleep一下，之后还是执行GoUnterminated，这样子在handle出错(panic)的时候会一直递归循环下去

GoSafely接收WaitGroup、ignoreRecover、handler、catchFunc参数，其大致的模板是，首先对WaitGroup进行add(1)，然后一步执行带defer的handler

序本文主要研究一下dubbo-go-proxy的ZookeeperRegistryLoadLoaderdubbo-go-proxy/pkg/registry/load.go {代码...} Loader接口定义了LoadAllServices、GetCluster方法ZookeeperRegistryLoaddubbo-go-proxy/pkg/registry/zookeeper.go {代码...} ZookeeperRegistryLoad定义了zkName、client、Address、cluster属性；newZoo...

序本文主要研究一下dubbo-go-proxy的ConsulRegistryLoadLoaderdubbo-go-proxy/pkg/registry/load.go {代码...} Loader接口定义了LoadAllServices、GetCluster方法ConsulRegistryLoaddubbo-go-proxy/pkg/registry/consul.go {代码...} ConsulRegistryLoad定义了Address、client、cluster属性；newConsulRegistryLoad方法...

序本文主要研究一下dubbo-go-proxy的RouteRoutedubbo-go-proxy/pkg/router/route.go {代码...} Route定义了lock、tree、wildcardTree属性，其NewRoute方法用于创建RoutePutAPIdubbo-go-proxy/pkg/router/route.go {代码...} PutAPI方法根据lowerCasePath去查找node，若没有找到则加锁创建Node，然后放到tree中，若是path...

discovery_service.go定义了四种DiscoveryService接口，分别是APIDiscoveryService、ListenerDiscoveryService、RouteDiscoveryService、ClusterDiscoveryService、EndpointDiscoveryService

序本文主要研究一下dubbo-go-proxy的apiFilterapiFilterdubbo-go-proxy/pkg/filter/api/api.go {代码...} Init方法往extension设置了名为dgp.filters.http.api的apiFilterFuncapiFilterFuncdubbo-go-proxy/pkg/filter/api/api.go {代码...} apiFilterFunc首先通过api.EmptyApi.FindApi(url)来查找对应的api，找不到则返...

序本文主要研究一下dubbo-go-proxy的jtypesJTypeMapperdubbo-go-proxy/pkg/common/constant/jtypes.go {代码...} JTypeMapper定义了个map，key为java类型，value为golang的reflect.TypemapTypesdubbo-go-proxy/pkg/client/dubbo/mapper.go {代码...} mapTypes方法先根据jType从JTypeMapper取出对应的golang的reflect.Typ...

dubbo-go-proxy-filter@v0.1.0-rc1.0.20210120132524-c63f4eb13725/pkg/api/config/api_config.go

序本文主要研究一下dubbo-go-proxy的hostFilterhostFilterdubbo-go-proxy/pkg/filter/host/host.go {代码...} hostFilter的New根据host创建hostFilterDodubbo-go-proxy/pkg/filter/host/host.go {代码...} Do方法执行doHostFilter方法，该方法将f.host设置给c.Request.Host，然后执行c.Next()httpFilterdubbo-go-proxy/p...

replacePathFilter定义了path属性；它实现了Filter的Do方法，该方法执行的是doReplacePathFilter方法，它会往header写入名为ReplacedPathHeader，若req.URL.RawPath为空则取req.URL.Path；之后将req.URL.RawPath更新为f.path，再通过url.PathUnescape(req.URL.RawPath)计算req.URL.Path，最后将req.URL.RequestURI()赋值...

clientFilter往extension注册了名为dgp.filters.remote_call的filter func；该func执行的是Do方法

timeoutFilter往extension设置了名为`dgp.filters.timeout的timeoutFilterFunc，默认的timeout为1s；timeoutFilterFunc执行的是timeoutFilter的Do方法

recoveryFilter往extension注册名为dgp.filters.recovery的recoveryFilterFunc；该func执行的是recoveryFilter的Do方法

authorityFilter往extension设置了名为dgp.filters.http.authority_filter的authorityFilterFunc；该func执行的是authorityFilter.Do方法

loggerFilter的Init方法往extension设置了loggerFilterFunc，该context.FilterFunc执行loggerFilter的Do方法