tcp

package

v1.2.10 Latest Latest Go to latest Published: Aug 26, 2024 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/darkit/godis

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ListenAndServe(listener net.Listener, handler tcp.Handler, closeChan <-chan struct{})
func ListenAndServeWithSignal(cfg *Config, handler tcp.Handler) error
type Config
type EchoClient
- func (c *EchoClient) Close() error
type EchoHandler
- func MakeEchoHandler() *EchoHandler
- func (h *EchoHandler) Close() error
- func (h *EchoHandler) Handle(ctx context.Context, conn net.Conn)

Constants ¶

This section is empty.

Variables ¶

View Source

var ClientCounter int32

ClientCounter Record the number of clients in the current Godis server

Functions ¶

func ListenAndServe ¶

func ListenAndServe(listener net.Listener, handler tcp.Handler, closeChan <-chan struct{})

ListenAndServe binds port and handle requests, blocking until close

func ListenAndServeWithSignal ¶

func ListenAndServeWithSignal(cfg *Config, handler tcp.Handler) error

ListenAndServeWithSignal binds port and handle requests, blocking until receive stop signal

Types ¶

type Config ¶

type Config struct {
	Address    string        `yaml:"address"`
	MaxConnect uint32        `yaml:"max-connect"`
	Timeout    time.Duration `yaml:"timeout"`
}

Config stores tcp server properties

type EchoClient ¶

type EchoClient struct {
	Conn    net.Conn
	Waiting wait.Wait
}

EchoClient is client for EchoHandler, using for test

func (*EchoClient) Close ¶

func (c *EchoClient) Close() error

Close close connection

type EchoHandler ¶

type EchoHandler struct {
	// contains filtered or unexported fields
}

EchoHandler echos received line to client, using for test

func MakeEchoHandler ¶

func MakeEchoHandler() *EchoHandler

MakeEchoHandler creates EchoHandler

func (*EchoHandler) Close ¶

func (h *EchoHandler) Close() error

Close stops echo handler

func (*EchoHandler) Handle ¶

func (h *EchoHandler) Handle(ctx context.Context, conn net.Conn)

Handle echos received line to client

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL