_bak

type Callback func(error error, nodeId string)

type RPCClient struct {
	Nodes   map[string]RpcNodeInfo
	NodeMap map[string][]string

	RoundRobinParam  map[string]int
	WeightRoundParam map[string]struct {
		Index  int
		Weight int
	}
	// contains filtered or unexported fields
}

type RPCClientOpts struct {
}

type RouteContext struct {
}

type RouteContextClass interface {
	GetNodesByType(nodeType string) RouteNodes
}

type RouteNodes []RpcNodeInfo

type RpcMsg interface {
	Namespace() string
	NodeType() string
	HandleName() string
	Method() string
	Args() []interface{}
}

type RpcNodeInfo struct {
	Id       string
	Host     string
	Port     int
	NodeType string
	// contains filtered or unexported fields
}

type TargetRouteFunction func(nodeType string, msg RpcMsg, routeParam interface{}, cb Callback)