hello

README

Run Hello Demo

1. prepare

git clone https://github.com/apache/dubbo-getty.git

cd getty/demo/hello

2. run server

run server: go run tcp/server/server.go

Or run server in task pool mode:

go run tcp/server/server.go -taskPool=true \
    -task_pool_size=2000 \
    -pprof_port=60000

3. run client

go run tcp/client/client.go

Or run client in task pool mode:

go run tcp/client/client.go -taskPool=true \
    -task_pool_size=50 \
    -pprof_port=60001

Documentation

Index

• Constants
• Variables
• func ClientRequest()
• type MessageHandler
  • func (h *MessageHandler) OnClose(session getty.Session)
  • func (h *MessageHandler) OnCron(session getty.Session)
  • func (h *MessageHandler) OnError(session getty.Session, err error)
  • func (h *MessageHandler) OnMessage(session getty.Session, pkg interface{})
  • func (h *MessageHandler) OnOpen(session getty.Session) error
• type PackageHandler
  • func (h *PackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error)
  • func (h *PackageHandler) Write(ss getty.Session, p interface{}) ([]byte, error)

Constants

const (
	CronPeriod      = 20e9
	WritePkgTimeout = 1e8
)

Variables

var Sessions []getty.Session

Functions

func ClientRequest

func ClientRequest()

Types

type MessageHandler

type MessageHandler struct {
	SessionOnOpen func(session getty.Session)
}

func (*MessageHandler) OnClose

func (h *MessageHandler) OnClose(session getty.Session)

func (*MessageHandler) OnCron

func (h *MessageHandler) OnCron(session getty.Session)

func (*MessageHandler) OnError

func (h *MessageHandler) OnError(session getty.Session, err error)

func (*MessageHandler) OnMessage

func (h *MessageHandler) OnMessage(session getty.Session, pkg interface{})

func (*MessageHandler) OnOpen

func (h *MessageHandler) OnOpen(session getty.Session) error

type PackageHandler

type PackageHandler struct{}

func (*PackageHandler) Read

func (h *PackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error)

func (*PackageHandler) Write

func (h *PackageHandler) Write(ss getty.Session, p interface{}) ([]byte, error)