summaryrefslogtreecommitdiff
path: root/cmd/rr/http
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-10 13:37:49 +0300
committerWolfy-J <[email protected]>2018-06-10 13:37:49 +0300
commitf633e6dff42cd3fa68e801dd70e3704a47949b55 (patch)
treeaef129af6f91a8dbb5926f36d7875c1a796219f2 /cmd/rr/http
parent28fe20760457a31c21330d2a4ec2fec007e04d2d (diff)
merge candidates and configured
Diffstat (limited to 'cmd/rr/http')
-rw-r--r--cmd/rr/http/reload.go4
-rw-r--r--cmd/rr/http/workers.go4
2 files changed, 4 insertions, 4 deletions
diff --git a/cmd/rr/http/reload.go b/cmd/rr/http/reload.go
index 23c36144..5814cc4a 100644
--- a/cmd/rr/http/reload.go
+++ b/cmd/rr/http/reload.go
@@ -36,11 +36,11 @@ func init() {
}
func reloadHandler(cmd *cobra.Command, args []string) error {
- if !rr.Services.Has("rpc") {
+ if !rr.Container.Has("rpc") {
return errors.New("RPC service is not configured")
}
- client, err := rr.Services.Get("rpc").(*rpc.Service).Client()
+ client, err := rr.Container.Get("rpc").(*rpc.Service).Client()
if err != nil {
return err
}
diff --git a/cmd/rr/http/workers.go b/cmd/rr/http/workers.go
index 61fee2a1..6d74a412 100644
--- a/cmd/rr/http/workers.go
+++ b/cmd/rr/http/workers.go
@@ -36,11 +36,11 @@ func init() {
}
func workersHandler(cmd *cobra.Command, args []string) error {
- if !rr.Services.Has("rpc") {
+ if !rr.Container.Has("rpc") {
return errors.New("RPC service is not configured")
}
- client, err := rr.Services.Get("rpc").(*rpc.Service).Client()
+ client, err := rr.Container.Get("rpc").(*rpc.Service).Client()
if err != nil {
return err
}