server

Documentation

Index

• type PcapConfig
• type ProbeServer
  • func NewProbeServer(ctx context.Context, logger *zap.Logger) (*ProbeServer, error)
  • func (s *ProbeServer) PcapConfig() PcapConfig
  • 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 PcapConfig

type PcapConfig struct {
	Device         string
	BufferSize     string
	ImmediateMode  bool
	SnapshotLength string
	Promiscuous    bool
	Timeout        time.Duration
	Filter         string
}

PcapConfig struct

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, error)

NewProbeServer returns a new Server

func (*ProbeServer) PcapConfig

func (s *ProbeServer) PcapConfig() PcapConfig

PcapConfig return ProbeServer.pcapConfig

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.