commons_go/rpc
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2017-11-30 12:43:52 +09:00
parent e4d00640d2
commit 92448ee89d
3 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
client/client_handlers.go
View File

@ -8,6 +8,7 @@ import (
"git.loafle.net/commons_go/rpc" "git.loafle.net/commons_go/rpc"
"git.loafle.net/commons_go/rpc/protocol" "git.loafle.net/commons_go/rpc/protocol"
cuc "git.loafle.net/commons_go/util/context"
) )
type ClientHandlers struct { type ClientHandlers struct {

7
client/rwc/socket/client_rwc_handlers.go
View File

@ -1,7 +1,6 @@
package socket package socket
import ( import (
"fmt"
"io" "io"
"git.loafle.net/commons_go/logging" "git.loafle.net/commons_go/logging"
@ -18,12 +17,6 @@ func New(address string) client.ClientReadWriteCloseHandler {
type ClientReadWriteCloseHandlers struct { type ClientReadWriteCloseHandlers struct {
client.ClientReadWriteCloseHandlers client.ClientReadWriteCloseHandlers
Address string
}
func (crwch *ClientReadWriteCloseHandlers) Connect(clientCTX client.ClientContext) (interface{}, error) {
return nil, fmt.Errorf("RPC Client RWC Handler: ClientHandlers method[Connect] is not implement")
} }
func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}) (protocol.ClientResponseCodec, error) { func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}) (protocol.ClientResponseCodec, error) {

5
client/rwc/websocket/fasthttp/client_rwc_handlers.go
View File

@ -1,7 +1,6 @@
package fasthttp package fasthttp
import ( import (
"fmt"
"io" "io"
"github.com/gorilla/websocket" "github.com/gorilla/websocket"
@ -19,10 +18,6 @@ type ClientReadWriteCloseHandlers struct {
client.ClientReadWriteCloseHandlers client.ClientReadWriteCloseHandlers
} }
func (crwch *ClientReadWriteCloseHandlers) Connect(clientCTX client.ClientContext) (interface{}, error) {
return nil, fmt.Errorf("RPC Client RWC Handler: ClientHandlers method[Connect] is not implement")
}
func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}) (protocol.ClientResponseCodec, error) { func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}) (protocol.ClientResponseCodec, error) {
if nil == conn { if nil == conn {
return nil, io.EOF return nil, io.EOF