session

Documentation

Index

• Constants
• type Config
• type Session
  • func NewSession(clientAddr *net.UDPAddr, conn net.Conn, backend core.Backend, ...) *Session
  • func (s *Session) Close()
  • func (s *Session) IsDone() bool
  • func (s *Session) ListenResponses(sendTo *net.UDPConn)
  • func (s *Session) Write(buf []byte) error

Constants

const (
	UDP_PACKET_SIZE   = 65507
	MAX_PACKETS_QUEUE = 10000
)

Types

type Config

type Config struct {
	MaxRequests        uint64
	MaxResponses       uint64
	ClientIdleTimeout  time.Duration
	BackendIdleTimeout time.Duration
	Transparent        bool
}

type Session

type Session struct {
	// contains filtered or unexported fields
}

func NewSession

func NewSession(clientAddr *net.UDPAddr, conn net.Conn, backend core.Backend, scheduler *scheduler.Scheduler, cfg Config) *Session

func (*Session) Close

func (s *Session) Close()

func (*Session) IsDone

func (s *Session) IsDone() bool

func (*Session) ListenResponses

func (s *Session) ListenResponses(sendTo *net.UDPConn)

*

• ListenResponses waits for responses from backend, and sends them back to client address via
• server connection, so that client is not confused with source host:port of the
• packet it receives

func (*Session) Write

func (s *Session) Write(buf []byte) error