(class string, req *proxy.Request)
| 548 | } |
| 549 | |
| 550 | func (c *Client) makeRequests(class string, req *proxy.Request) (responses []*proxy.Response, err error) { |
| 551 | if req == nil { |
| 552 | return nil, eris.New("empty request") |
| 553 | } |
| 554 | if req.Key == nil { |
| 555 | req.Key = ari.NewKey("", "") |
| 556 | } |
| 557 | |
| 558 | expected := len(c.core.cluster.Matching(req.Key.Node, req.Key.App, c.core.clusterMaxAge)) |
| 559 | |
| 560 | return c.mbus.MultipleRequest(c.subject(class, req), req, expected) |
| 561 | } |
| 562 | |
| 563 | func (c *Client) makeBroadcastRequestReturnFirstGoodResponse(class string, req *proxy.Request) (*proxy.Response, error) { |
| 564 | if req == nil { |
no test coverage detected