tcp

Documentation

Index

• Constants
• func Copy(to io.Writer, from io.Reader, ch chan<- core.ReadWriteCount) error
• type Server
  • func New(name string, cfg config.Server) (*Server, error)
  • func (this *Server) Cfg() config.Server
  • func (this *Server) HandleClientConnect(ctx *core.TcpContext)
  • func (this *Server) HandleClientDisconnect(client net.Conn)
  • func (this *Server) Listen() (err error)
  • func (this *Server) Start() error
  • func (this *Server) Stop()

Constants

const (

	/* Buffer size to handle data from socket */
	BUFFER_SIZE = 16 * 1024

	/* Interval of pushing aggregated read/write stats */
	PROXY_STATS_PUSH_INTERVAL = 1 * time.Second
)

Functions

func Copy

func Copy(to io.Writer, from io.Reader, ch chan<- core.ReadWriteCount) error

*

• It's build by analogy of io.Copy

Types

type Server

type Server struct {

	/* Get certificate filled by external service */
	GetCertificate func(*tls.ClientHelloInfo) (*tls.Certificate, error)
	// contains filtered or unexported fields
}

*

• Server listens for client connections and
• proxies it to backends

func New

func New(name string, cfg config.Server) (*Server, error)

*

• Creates new server instance

func (*Server) Cfg

func (this *Server) Cfg() config.Server

*

• Returns current server configuration

func (*Server) HandleClientConnect

func (this *Server) HandleClientConnect(ctx *core.TcpContext)

*

• Handle new client connection

func (*Server) HandleClientDisconnect

func (this *Server) HandleClientDisconnect(client net.Conn)

*

• Handle client disconnection

func (*Server) Listen

func (this *Server) Listen() (err error)

*

• Listen on specified port for a connections

func (*Server) Start

func (this *Server) Start() error

*

• Start server

func (*Server) Stop

func (this *Server) Stop()

*

• Stop, dropping all connections