code-craft

0

聊聊rocketmq-client-go的localFileOffsetStore

• codecraft   今天 10:17 发布
• 收藏

序 本文主要研究一下rocketmq-client-go的localFileOffsetStore OffsetStore rocketmq-client-go-v2.0.0/consumer/offset_store.go {代码...} OffsetStore定义了persist、remove、read、update方法 localFileOffs...

0

聊聊rocketmq-client-go的pushConsumer

• codecraft   7月10日发布
• 收藏

pushConsumer定义了queueFlowControlTimes、queueMaxSpanFlowControlTimes、consumeFunc、submitToConsume、subscribedTopic、interceptor、queueLock、done、closeOnce属性

0

聊聊rocketmq-client-go的PullConsumer

• codecraft   7月9日发布
• 收藏

PullConsumer定义了Start、Shutdown、Pull、UpdateOffset、PersistOffset、CurrentOffset方法

0

聊聊rocketmq-client-go的ACLInterceptor

• codecraft   7月8日发布
• 收藏

序 本文主要研究一下rocketmq-client-go的ACLInterceptor ACLInterceptor rocketmq-client-go-v2.0.0/internal/remote/interceptor.go {代码...} ACLInterceptor方法会调用calculateSignature计算签名，然后执行n...

0

聊聊rocketmq-client-go的TraceInterceptor

• codecraft   7月7日发布
• 收藏

序 本文主要研究一下rocketmq-client-go的TraceInterceptor TraceInterceptor rocketmq-client-go-v2.0.0/producer/interceptor.go {代码...} WithTrace方法在options.Interceptors后追加TraceInterceptor newTra...

0

聊聊rocketmq-client-go的transactionProducer

• codecraft   7月6日发布
• 收藏

序 本文主要研究一下rocketmq-client-go的transactionProducer transactionProducer rocketmq-client-go-v2.0.0/producer/producer.go {代码...} transactionProducer定义了producer及listener属性 NewTransactio...

0

聊聊rocketmq-client-go的defaultProducer

• codecraft   7月5日发布
• 收藏

defaultProducer定义了group、client、state、options、publishInfo、callbackCh、interceptor

0

聊聊rocketmq-client-go的api.go

• codecraft   7月4日发布
• 收藏

Producer定义了Start、Shutdown、SendSync、SendAsync、SendOneWay方法；NewProducer方法通过producer.NewDefaultProducer创建Producer

0

聊聊rocketmq-client-go的QueueSelector

• codecraft   7月4日发布
• 收藏

序 本文主要研究一下rocketmq-client-go的QueueSelector QueueSelector rocketmq-client-go-v2.0.0/producer/selector.go {代码...} QueueSelector接口，定义了Select方法 manualQueueSelector rocketmq-client-g...

0

聊聊canal-go的position

• codecraft   7月2日发布
• 收藏

序 本文主要研究一下canal-go的position Position canal-go-v1.0.7/protocol/Position/Position.go {代码...} Position.go定义了一个Position接口 MetaqPosition canal-go-v1.0.7/protocol/Position/metaq_positi...

0

聊聊canal-go的SimpleCanalConnector

• codecraft   7月1日发布
• 收藏

SimpleCanalConnector定义了Address、Port、UserName、PassWord、SoTime、IdleTimeOut、ClientIdentity、Connected、Running、Filter、RollbackOnConnect、LazyParseEntry属性

0

聊聊nacos-sdk-go的ConfigProxy

• codecraft   6月30日发布
• 收藏

序 本文主要研究一下nacos-sdk-go的ConfigProxy ConfigProxy nacos-sdk-go-v0.3.2/clients/config_client/config_proxy.go {代码...} ConfigProxy定义了nacosServer、clientConfig属性 NewConfigProxy nacos-sdk-...

0

聊聊nacos-sdk-go的PushReceiver

• codecraft   6月29日发布
• 收藏

序 本文主要研究一下nacos-sdk-go的PushReceiver PushReceiver nacos-sdk-go-v0.3.2/clients/naming_client/push_receiver.go {代码...} PushReceiver定义了port、host、hostReactor属性 NewPushRecevier nacos-s...

0

聊聊nacos-sdk-go的NacosServer

• codecraft   6月28日发布
• 收藏

NacosServer定义了securityLogin、serverList、httpAgent、timeoutMs、endpoint、lastSrvRefTime、vipSrvRefInterMills属性

0

聊聊nacos-sdk-go的NamingProxy

• codecraft   6月27日发布
• 收藏

序 本文主要研究一下nacos-sdk-go的NamingProxy NamingProxy nacos-sdk-go-v0.3.2/clients/naming_client/naming_proxy.go {代码...} NamingProxy定义了clientConfig、nacosServer属性 NewNamingProxy nacos-sdk-...

0

聊聊nacos-sdk-go的BeatReactor

• codecraft   6月26日发布
• 收藏

BeatReactor定义了beatMap、serviceProxy、clientBeatInterval、beatThreadCount、beatThreadSemaphore、beatRecordMap属性

0

聊聊nacos-sdk-go的HostReactor

• codecraft   6月25日发布
• 收藏

HostReactor定义了serviceInfoMap、cacheDir、updateThreadNum、serviceProxy、pushReceiver、subCallback、updateTimeMap、updateCacheWhenEmpty属性

0

聊聊nacos-sdk-go的NamingClient

• codecraft   6月24日发布
• 收藏

NamingClient定义了hostReactor、serviceProxy、subCallback、beatReactor、indexMap属性

1

聊聊kingbus的resp.go

• codecraft   6月23日发布
• 1 收藏

序 本文主要研究一下kingbus的resp.go writeOK kingbus/mysql/resp.go {代码...} writeOK方法写入gomysql.OK_HEADER writeError kingbus/mysql/resp.go {代码...} writeError方法写入gomysql.ERR_HEADER writeEOF...

0

聊聊kingbus的binlog_progress.go

• codecraft   6月22日发布
• 收藏

BinlogProgress定义了currentGtid、lastSaveGtid、lastBinlogFile、lastFilePosition、executedGtidSetStr、trxBoundaryParser、persistentTime、persistentAppliedIndex、executedGtidSet、store属性