server

Documentation

Index

• type ProbeServer
  • func NewProbeServer(ctx context.Context, logger *zap.Logger) *ProbeServer
  • func (s *ProbeServer) Shutdown()
  • func (s *ProbeServer) Start() error
• type Proxy
  • func NewProxy(s *Server, conn, remoteConn *net.TCPConn) *Proxy
  • func (p *Proxy) Start()
• type Server
  • func NewServer(ctx context.Context, lAddr, rAddr *net.TCPAddr, logger *zap.Logger) *Server
  • func (s *Server) GracefulShutdown()
  • func (s *Server) Shutdown()
  • func (s *Server) Start() error

Types

type ProbeServer

type ProbeServer struct {
	Wg         *sync.WaitGroup
	ClosedChan chan struct{}
	// contains filtered or unexported fields
}

ProbeServer struct

func NewProbeServer

func NewProbeServer(ctx context.Context, logger *zap.Logger) *ProbeServer

NewProbeServer returns a new Server

func (*ProbeServer) Shutdown

func (s *ProbeServer) Shutdown()

Shutdown server.

func (*ProbeServer) Start

func (s *ProbeServer) Start() error

Start probe server.

type Proxy

type Proxy struct {
	Close context.CancelFunc
	// contains filtered or unexported fields
}

Proxy struct

func NewProxy

func NewProxy(s *Server, conn, remoteConn *net.TCPConn) *Proxy

NewProxy returns a new Proxy

func (*Proxy) Start

func (p *Proxy) Start()

Start proxy

type Server

type Server struct {
	Wg         *sync.WaitGroup
	ClosedChan chan struct{}
	// contains filtered or unexported fields
}

Server struct

func NewServer

func NewServer(ctx context.Context, lAddr, rAddr *net.TCPAddr, logger *zap.Logger) *Server

NewServer returns a new Server

func (*Server) GracefulShutdown

func (s *Server) GracefulShutdown()

GracefulShutdown server.

func (*Server) Shutdown

func (s *Server) Shutdown()

Shutdown server.

func (*Server) Start

func (s *Server) Start() error

Start server.