新增MQ系统 (bnb-chain#24)

* mq * mq
swlfigo · May 4, 2023 · c90dfd6 · c90dfd6
1 parent f854043
commit c90dfd6
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 0 deletions.
diff --git a/eth/protocols/eth/peer_manager.go b/eth/protocols/eth/peer_manager.go
@@ -292,3 +292,10 @@ func (manager *PeerManager) FetchLastRecordBlockCounterTimeStr() string {
 	}
 	return Global.GetStringTime(manager.blockInfoRecordLastTime)
 }
+
+func (manager *PeerManager) FetchLastRecordBlockCounterTime() time.Time {
+	if manager.blockInfoRecordLastTime.IsZero() {
+		return time.Time{}
+	}
+	return manager.blockInfoRecordLastTime
+}
diff --git a/go.mod b/go.mod
@@ -123,6 +123,7 @@ require (
 	github.com/prometheus/procfs v0.9.0 // indirect
 	github.com/rcrowley/go-metrics v0.0.0-20190826022208-cac0b30c2563 // indirect
 	github.com/robfig/cron/v3 v3.0.1 // indirect
+	github.com/streadway/amqp v1.0.0 // indirect
 	github.com/tklauser/go-sysconf v0.3.5 // indirect
 	github.com/tklauser/numcpus v0.2.2 // indirect
 	github.com/yusufpapurcu/wmi v1.2.2 // indirect

diff --git a/go.sum b/go.sum
@@ -457,6 +457,8 @@ github.com/spf13/cobra v0.0.3/go.mod h1:1l0Ry5zgKvJasoi3XT1TypsSe7PqH0Sj9dhYf7v3
 github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
 github.com/status-im/keycard-go v0.2.0 h1:QDLFswOQu1r5jsycloeQh3bVU8n/NatHHaZobtDnDzA=
 github.com/status-im/keycard-go v0.2.0/go.mod h1:wlp8ZLbsmrF6g6WjugPAx+IzoLrkdf9+mHxBEeo3Hbg=
+github.com/streadway/amqp v1.0.0 h1:kuuDrUJFZL1QYL9hUNuCxNObNzB0bV/ZG5jV3RWAQgo=
+github.com/streadway/amqp v1.0.0/go.mod h1:AZpEONHx3DKn8O/DFsRAY58/XVQiIPMTMB1SddzLXVw=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=