Lines Matching refs:msgpackrpc

47 	err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)
75 err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)
98 err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)
109 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)
116 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)
147 err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)
153 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil {
189 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil {
208 err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR)
215 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR)
223 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR)
231 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR)
240 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR)
254 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR)
299 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil {
332 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil {
351 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out))
359 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
384 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out))
392 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
416 err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)
455 assert.Nil(msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &token))
463 err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)
471 err = msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)
479 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out))
497 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out))
505 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
526 err := msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", &arg, &out)
533 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", &arg, &out); err != nil {
574 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil {
601 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR); err != nil {
609 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
617 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
625 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
633 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
643 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &argR, &outR); err != nil {
649 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
657 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
665 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
673 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
682 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
693 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
704 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
715 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
727 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
738 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister",
769 …if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListDatacenters", struct{}{}, &out); err != nil…
807 …if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListDatacenters", struct{}{}, &out); err != nil…
836 err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
848 msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
891 msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
916 err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
922 msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
973 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out); err != nil {
1039 err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
1084 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out); err != nil {
1135 msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
1164 msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out)
1213 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &reply); err != nil {
1225 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &reply); err != nil {
1249 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil {
1257 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &reply); err != nil {
1283 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListNodes", &args, &out); err != nil {
1301 err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out)
1316 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1368 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1393 err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out)
1420 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1443 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1479 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1490 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1538 …if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err == nil || err.…
1548 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1568 …if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err == nil || err.…
1574 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &args, &out); err != nil {
1603 err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out)
1618 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out); err != nil {
1630 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out); err != nil {
1669 err = msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out)
1686 err = msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out)
1697 err = msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out)
1712 err = msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out)
1817 require.NoError(t, msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out))
1841 err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out)
1870 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out); err != nil {
1896 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &args, &out); err != nil {
1931 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", args, &out))
1940 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
1962 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", args, &out))
1970 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", args, &out))
1980 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
1991 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
2016 require.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", args, &out))
2025 require.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
2035 require.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
2074 assert.Nil(msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &token))
2083 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out))
2090 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out))
2097 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out))
2109 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
2120 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
2142 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", args, &out))
2151 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &req, &resp))
2171 err := msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &args, &out)
2189 if err := msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &args, &out); err != nil {
2223 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", args, &out))
2231 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &req, &resp))
2254 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", args, &out))
2262 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &req, &resp))
2290 err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)
2297 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil {
2307 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", query, &out2); err != nil {
2344 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &token); err != nil {
2365 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &regArg, nil); err != nil {
2385 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &regArg, nil); err != nil {
2404 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ListServices", &opt, &reply); err != nil {
2428 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &opt, &reply); err != nil {
2449 if err := msgpackrpc.CallWithCodec(codec, "Catalog.ServiceNodes", &opt, &reply); err != nil {
2487 if err := msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &args, &reply); err != nil {
2496 if err := msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &args, &reply); err != nil {
2519 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil {
2525 if err := msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &args, &reply); err != nil {
2534 if err := msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &args, &reply); err != nil {
2556 if err := msgpackrpc.CallWithCodec(codec, "Catalog.NodeServices", &opt, &reply); err != nil {