Skip to content

Commit 1583a5a

Browse files
committedMay 15, 2022
imp: merge dubbo getty to alex getty
1 parent 73b0928 commit 1583a5a

File tree

177 files changed

+1470
-16399
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

177 files changed

+1470
-16399
lines changed
 

‎README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ An open source, Go based, RPC framework.
2626

2727
Feature list:
2828

29-
- 1 Transport: TCP(√), UDP(X), Websocket(X)
29+
- 1 Transport: TCP(√), UDP(), Websocket()
3030
- 2 Codec: ProtoBuf(√), JSON(√)
3131
- 3 Strategy: Failover(√), Failfast(√)
3232
- 4 Metrics: Invoke Statistics(X), User Auth(X)

‎examples/echo/tcp-echo/client/app/client.go

+5-2
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,10 @@ import (
2626

2727
import (
2828
"github.com/AlexStocks/getty/transport"
29-
log "github.com/AlexStocks/log4go"
29+
)
30+
31+
import (
32+
log "github.com/AlexStocks/getty/util"
3033
)
3134

3235
var (
@@ -163,7 +166,7 @@ func (c *EchoClient) heartbeat(session getty.Session) {
163166
pkg.B = echoHeartbeatRequestString
164167
pkg.H.Len = (uint16)(len(pkg.B) + 1)
165168

166-
if err := session.WritePkg(&pkg, WritePkgTimeout); err != nil {
169+
if _, _, err := session.WritePkg(&pkg, WritePkgTimeout); err != nil {
167170
log.Warn("session.WritePkg(session{%s}, pkg{%s}) = error{%v}", session.Stat(), pkg, err)
168171
session.Close()
169172

0 commit comments

Comments
 (0)
Please sign in to comment.