tcp

Documentation

Index

• 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)

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