diff options
author | Wolfy-J <[email protected]> | 2018-09-10 14:29:10 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-09-10 14:29:10 +0300 |
commit | 7ab1e77f2db902cf8a485e3a28bfdbd58a613dc9 (patch) | |
tree | 748253cb7d5b758a0b61ab4a88023e5fed4f4a3b /service/rpc | |
parent | ceb5033d5bb2fb641c886d4010f05498552152c2 (diff) |
go fmt
Diffstat (limited to 'service/rpc')
-rw-r--r-- | service/rpc/service.go | 3 | ||||
-rw-r--r-- | service/rpc/service_test.go | 8 |
2 files changed, 6 insertions, 5 deletions
diff --git a/service/rpc/service.go b/service/rpc/service.go index 9cd32755..14e34319 100644 --- a/service/rpc/service.go +++ b/service/rpc/service.go @@ -3,9 +3,9 @@ package rpc import ( "errors" "github.com/spiral/goridge" + "github.com/spiral/roadrunner/service/env" "net/rpc" "sync" - "github.com/spiral/roadrunner/service/env" ) const ( @@ -16,6 +16,7 @@ const ( // rpc server connection. EnvKey = "RR_RPC" ) + // Service is RPC service. type Service struct { cfg *Config diff --git a/service/rpc/service_test.go b/service/rpc/service_test.go index e47e9cdd..59e0e05d 100644 --- a/service/rpc/service_test.go +++ b/service/rpc/service_test.go @@ -30,7 +30,7 @@ func Test_RegisterNotConfigured(t *testing.T) { func Test_Enabled(t *testing.T) { s := &Service{} - ok, err := s.Init(&Config{Enable: true, Listen: "tcp://localhost:9008"},nil) + ok, err := s.Init(&Config{Enable: true, Listen: "tcp://localhost:9008"}, nil) assert.NoError(t, err) assert.True(t, ok) @@ -38,7 +38,7 @@ func Test_Enabled(t *testing.T) { func Test_StopNonServing(t *testing.T) { s := &Service{} - ok, err := s.Init(&Config{Enable: true, Listen: "tcp://localhost:9008"},nil) + ok, err := s.Init(&Config{Enable: true, Listen: "tcp://localhost:9008"}, nil) assert.NoError(t, err) assert.True(t, ok) @@ -47,7 +47,7 @@ func Test_StopNonServing(t *testing.T) { func Test_Serve_Errors(t *testing.T) { s := &Service{} - ok, err := s.Init(&Config{Enable: true, Listen: "mailformed"},nil) + ok, err := s.Init(&Config{Enable: true, Listen: "mailformed"}, nil) assert.NoError(t, err) assert.True(t, ok) @@ -60,7 +60,7 @@ func Test_Serve_Errors(t *testing.T) { func Test_Serve_Client(t *testing.T) { s := &Service{} - ok, err := s.Init(&Config{Enable: true, Listen: "tcp://localhost:9018"},nil) + ok, err := s.Init(&Config{Enable: true, Listen: "tcp://localhost:9018"}, nil) assert.NoError(t, err) assert.True(t, ok) |