/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | coordinate_endpoint_test.go | 65 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 75 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out); err != nil { 166 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 174 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 215 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 236 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 248 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 468 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 589 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 610 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | session_endpoint_test.go | 37 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 61 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 98 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 125 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 171 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &token); err != nil { 196 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &id2) 222 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 770 err := msgpackrpc.CallWithCodec(codec, "Session.Renew", &renewR, &session) 864 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 875 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) [all …]
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/agent/consul/ |
H A D | coordinate_endpoint_test.go | 65 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 75 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out); err != nil { 166 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 174 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 216 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 237 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 249 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 470 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 592 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 613 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | catalog_endpoint_test.go | 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", 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", [all …]
|
H A D | session_endpoint_test.go | 37 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 61 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 98 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 125 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 172 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &token); err != nil { 197 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &id2) 223 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 773 err := msgpackrpc.CallWithCodec(codec, "Session.Renew", &renewR, &session) 867 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 878 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | coordinate_endpoint_test.go | 65 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 75 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out); err != nil { 166 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 174 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 216 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 237 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 249 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 470 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 592 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 613 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | session_endpoint_test.go | 38 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 62 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 100 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 127 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 175 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &token); err != nil { 200 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &id2) 226 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 784 err := msgpackrpc.CallWithCodec(codec, "Session.Renew", &renewR, &session) 880 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 891 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) [all …]
|
H A D | health_endpoint_test.go | 38 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil { 89 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil { 104 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil { 672 require.NoError(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) 689 require.NoError(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) 962 assert.Nil(msgpackrpc.CallWithCodec(codec, "ACL.Apply", arg, &token)) 978 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 990 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1002 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1014 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) [all …]
|
H A D | catalog_endpoint_test.go | 18 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 576 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 584 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 592 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 600 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 616 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 624 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 632 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 640 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 649 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | coordinate_endpoint_test.go | 65 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 75 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out); err != nil { 166 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 174 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 215 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 236 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 248 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 468 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 589 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 610 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | catalog_endpoint_test.go | 606 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 614 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 622 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 630 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 646 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 654 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 662 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 670 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 679 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 690 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", [all …]
|
H A D | session_endpoint_test.go | 37 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 61 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 98 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 125 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 171 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &token); err != nil { 196 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &id2) 222 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 770 err := msgpackrpc.CallWithCodec(codec, "Session.Renew", &renewR, &session) 864 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 875 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) [all …]
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | coordinate_endpoint_test.go | 60 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &req, &reply); err != nil { 72 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 82 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out); err != nil { 104 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out); err != nil { 173 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 181 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 224 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out); err != nil { 230 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 251 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 263 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) [all …]
|
H A D | session_endpoint_test.go | 37 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 61 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 98 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 125 if err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out); err != nil { 171 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &token); err != nil { 196 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &id2) 222 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 772 err := msgpackrpc.CallWithCodec(codec, "Session.Renew", &renewR, &session) 866 err := msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) 877 err = msgpackrpc.CallWithCodec(codec, "Session.Apply", &arg, &out) [all …]
|
/dports/sysutils/consul/consul-1.10.3/agent/consul/ |
H A D | coordinate_endpoint_test.go | 18 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 69 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 170 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 178 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 217 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 238 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 250 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 479 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 595 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 616 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | health_endpoint_test.go | 15 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 44 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil { 1014 assert.Nil(msgpackrpc.CallWithCodec(codec, "ACL.Apply", arg, &token)) 1030 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1042 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1054 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1066 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1077 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1230 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) 1247 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) [all …]
|
H A D | catalog_endpoint_test.go | 19 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 623 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 631 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 639 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 647 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 656 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 667 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 678 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 689 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 701 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", [all …]
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | coordinate_endpoint_test.go | 18 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 65 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 166 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 174 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 209 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 230 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 242 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 459 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 567 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 588 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | health_endpoint_test.go | 15 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 40 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil { 966 assert.Nil(msgpackrpc.CallWithCodec(codec, "ACL.Apply", arg, &token)) 982 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 994 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1006 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1018 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1029 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1174 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) 1191 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | coordinate_endpoint_test.go | 18 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 69 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 170 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 178 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 217 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 238 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 250 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 479 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 595 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 616 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | health_endpoint_test.go | 15 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 44 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil { 1014 assert.Nil(msgpackrpc.CallWithCodec(codec, "ACL.Apply", arg, &token)) 1030 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1042 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1054 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1066 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1077 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1230 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) 1247 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) [all …]
|
H A D | catalog_endpoint_test.go | 19 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 623 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 631 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 639 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 647 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 656 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 667 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 678 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 689 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 701 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | coordinate_endpoint_test.go | 18 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 69 if err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg1, &out); err != nil { 170 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 178 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &arg2, &out) 217 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 238 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &arg, &id); err != nil { 250 err = msgpackrpc.CallWithCodec(codec, "Coordinate.Update", &req, &out) 479 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &req, &id); err != nil { 595 err := msgpackrpc.CallWithCodec(codec, "Coordinate.Node", &arg, &resp) 616 if err := msgpackrpc.CallWithCodec(codec, "ACL.Apply", &aclReq, &id); err != nil { [all …]
|
H A D | health_endpoint_test.go | 15 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 44 if err := msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out); err != nil { 1014 assert.Nil(msgpackrpc.CallWithCodec(codec, "ACL.Apply", arg, &token)) 1030 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1042 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1054 assert.Nil(msgpackrpc.CallWithCodec(codec, "Catalog.Register", &args, &out)) 1066 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1077 assert.Nil(msgpackrpc.CallWithCodec(codec, "Health.ServiceNodes", &req, &resp)) 1230 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) 1247 require.Nil(t, msgpackrpc.CallWithCodec(codec, "Catalog.Register", &arg, &out)) [all …]
|
H A D | catalog_endpoint_test.go | 19 msgpackrpc "github.com/hashicorp/net-rpc-msgpackrpc" packageName 623 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 631 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 639 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 647 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 656 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 667 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 678 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 689 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", 701 err = msgpackrpc.CallWithCodec(codec, "Catalog.Deregister", [all …]
|