upate bhsgo,use MsgQueryTopicReply_BHNodeAddress

liuxiaolong

2021-06-02 e67dc008802aafb884dc94da054f2090da4005e2

upate bhsgo,use MsgQueryTopicReply_BHNodeAddress

 client.go

@@ -44,21 +44,21 @@
    }
}

var getNetNode = func(topic string) []bhome_msg.BHAddress{
var getNetNode = func(topic string) []*bhome_msg.MsgQueryTopicReply_BHNodeAddress{
    return nil
}

func InitGetNetNode(fn func(name string)[]bhome_msg.BHAddress) {
    if fn != nil {
        getNetNode = fn
    }
func InitGetNetNode(fn func(name string)[]*bhome_msg.MsgQueryTopicReply_BHNodeAddress) {
    //if fn != nil {
    //    getNetNode = fn
    //}
}

var busReq = func(req *bhome_msg.MsgRequestTopic,dest []bhome_msg.BHAddress) ([]byte, error) {
var busReq = func(req *bhome_msg.MsgRequestTopic,dest []*bhome_msg.MsgQueryTopicReply_BHNodeAddress) ([]byte, error) {
    return nil, errors.New("please init InitDoReq first")
}

func InitDoReq(fn func(*bhome_msg.MsgRequestTopic, []bhome_msg.BHAddress) ([]byte, error)) {
func InitDoReq(fn func(*bhome_msg.MsgRequestTopic, []*bhome_msg.MsgQueryTopicReply_BHNodeAddress) ([]byte, error)) {
    if fn != nil {
        busReq = fn
    }

 clientFactory.go

@@ -16,7 +16,7 @@
}

type Option struct {
    nodes []bhome_msg.BHAddress
    nodes []*bhome_msg.MsgQueryTopicReply_BHNodeAddress
}

type IOption interface {
@@ -37,7 +37,7 @@
    }
}

func WithNodes(nodeArr []bhome_msg.BHAddress) IOption {
func WithNodes(nodeArr []*bhome_msg.MsgQueryTopicReply_BHNodeAddress) IOption {
    return newFuncOption(func(o *Option) {
        o.nodes = nodeArr
    })

 sbusClient.go

@@ -9,7 +9,7 @@
)

type SBusClient struct {
    nodes []bhome_msg.BHAddress
    nodes []*bhome_msg.MsgQueryTopicReply_BHNodeAddress
}

type ProcInfo struct {