Commit d5a89cc8 authored by harrylee's avatar harrylee

update broker

parent e78a46ce
Pipeline #8155 failed with stages
in 0 seconds
...@@ -290,6 +290,10 @@ func getOutterMeta(statedb dbm.KV) (*brokertypes.Meta, error) { ...@@ -290,6 +290,10 @@ func getOutterMeta(statedb dbm.KV) (*brokertypes.Meta, error) {
return getMeta(statedb, calOutterMetaKey()) return getMeta(statedb, calOutterMetaKey())
} }
//获取callBackMeta
func getCallBackMeta(statedb dbm.KV) (*brokertypes.Meta, error) {
return getMeta(statedb, calCallBackMetaKey())
}
//获取innerMeta //获取innerMeta
func getInnerMeta(statedb dbm.KV) (*brokertypes.Meta, error) { func getInnerMeta(statedb dbm.KV) (*brokertypes.Meta, error) {
return getMeta(statedb, calInnerMetaKey()) return getMeta(statedb, calInnerMetaKey())
......
...@@ -14,6 +14,11 @@ func (b *broker) Query_QueryOutterMeta(query *brokertypes.QueryOutterMeta) (*bro ...@@ -14,6 +14,11 @@ func (b *broker) Query_QueryOutterMeta(query *brokertypes.QueryOutterMeta) (*bro
return getOutterMeta(b.GetStateDB()) return getOutterMeta(b.GetStateDB())
} }
//获取callBackMeta
func (b *broker) Query_QueryCallBackMeta(query *brokertypes.QueryNilParam) (*brokertypes.Meta, error) {
return getCallBackMeta(b.GetStateDB())
}
//获取inMessage //获取inMessage
func (b *broker) Query_QueryInMessage(query *brokertypes.QueryInMessage) (*brokertypes.Response, error) { func (b *broker) Query_QueryInMessage(query *brokertypes.QueryInMessage) (*brokertypes.Response, error) {
return getInMessage(b.GetStateDB(), query) return getInMessage(b.GetStateDB(), query)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment