tblyler/hoarder
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Clean up rpc.go file

Browse source
This commit is contained in:
Tony Blyler 2016-07-23 16:26:52 -04:00
parent 44e04ef998
commit d248260789
No known key found for this signature in database
GPG key ID: 25C9D3A655D1A65C
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
queue/rpc.go
View file

@ -2,19 +2,24 @@ package queue
import "errors" import "errors"
// RPCReq contains information for communicating with the RPC server
type RPCReq struct { type RPCReq struct {
method string method string
replyChan chan interface{} replyChan chan interface{}
} }
// RPCResponse holds the response
type RPCResponse string type RPCResponse string
// Status contains RPC request information
type Status struct { type Status struct {
queueChan chan RPCReq queueChan chan RPCReq
} }
// RPCArgs arg information for the RPC server
type RPCArgs struct{} type RPCArgs struct{}
// Downloads gets download statuses
func (s *Status) Downloads(_ RPCArgs, reply *RPCResponse) error { func (s *Status) Downloads(_ RPCArgs, reply *RPCResponse) error {
replyChan := make(chan interface{}) replyChan := make(chan interface{})
req := RPCReq{ req := RPCReq{
@ -31,7 +36,6 @@ func (s *Status) Downloads(_ RPCArgs, reply *RPCResponse) error {
break break
default: default:
return errors.New("error: unexpected return value") return errors.New("error: unexpected return value")
break
} }
return nil return nil