server

Documentation

Index

• type Forwarder
  • func NewForwarder(ctx context.Context, users config.Users, stream proto.Proxy_ProxyServer) *Forwarder
  • func (f *Forwarder) Close() error
  • func (f *Forwarder) CopyClientToTarget() error
  • func (f *Forwarder) CopyTargetToClient() error
  • func (f *Forwarder) Start() error
• type Server
  • func NewServer(ctx context.Context, users config.Users, ssl *config.SSL) (*Server, error)
  • func (s *Server) ListenAndServe(addr string) error
  • func (s *Server) Proxy(stream proto.Proxy_ProxyServer) error

Types

type Forwarder

type Forwarder struct {
	Ctx    context.Context
	Users  config.Users
	Stream proto.Proxy_ProxyServer
	Conn   net.Conn
	Ack    chan interface{}
}

func NewForwarder

func NewForwarder(ctx context.Context, users config.Users, stream proto.Proxy_ProxyServer) *Forwarder

func (*Forwarder) Close

func (f *Forwarder) Close() error

func (*Forwarder) CopyClientToTarget

func (f *Forwarder) CopyClientToTarget() error

func (*Forwarder) CopyTargetToClient

func (f *Forwarder) CopyTargetToClient() error

func (*Forwarder) Start

func (f *Forwarder) Start() error

type Server

type Server struct {
	proto.UnimplementedProxyServer
	Ctx   context.Context
	Users config.Users
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, users config.Users, ssl *config.SSL) (*Server, error)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(addr string) error

ListenAndServe starts the server at the given address

func (*Server) Proxy

func (s *Server) Proxy(stream proto.Proxy_ProxyServer) error