Home
last modified time | relevance | path

Searched refs:msgpackrpc (Results 1 – 25 of 425) sorted by relevance

12345678910>>...17

/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/agent/consul/
H A Dcoordinate_endpoint_test.go65 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 Dsession_endpoint_test.go37 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 Dcoordinate_endpoint_test.go65 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 Dcatalog_endpoint_test.go609 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 Dsession_endpoint_test.go37 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 Dcoordinate_endpoint_test.go65 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 Dsession_endpoint_test.go38 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 Dhealth_endpoint_test.go38 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 Dcatalog_endpoint_test.go18 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 Dcoordinate_endpoint_test.go65 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 Dcatalog_endpoint_test.go606 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 Dsession_endpoint_test.go37 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 Dcoordinate_endpoint_test.go60 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 Dsession_endpoint_test.go37 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 Dcoordinate_endpoint_test.go18 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 Dhealth_endpoint_test.go15 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 Dcatalog_endpoint_test.go19 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 Dcoordinate_endpoint_test.go18 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 Dhealth_endpoint_test.go15 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 Dcoordinate_endpoint_test.go18 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 Dhealth_endpoint_test.go15 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 Dcatalog_endpoint_test.go19 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 Dcoordinate_endpoint_test.go18 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 Dhealth_endpoint_test.go15 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 Dcatalog_endpoint_test.go19 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 …]

12345678910>>...17