handler

Documentation

Index

• func Listen(network, address string, onClose func()) (net.Listener, error)
• type Client
  • func NewClient(name, displayName, host, pubPort, intPort string, sharePub bool, l *log.Entry) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) IntAddr() string
  • func (c *Client) IntBindAddr() string
  • func (c *Client) PubAddr() string
  • func (c *Client) PubBindAddr() string
  • func (c *Client) SetSTUNInfo(host, backendPort, protocol string)
  • func (c *Client) Start()
• type Handler
  • func New(host string) *Handler
  • func (h *Handler) Close()
  • func (h *Handler) CreateClient(req *api.CreateClientRequest, svr api.ControlService_CreateClientServer) error
  • func (h *Handler) ListBackendServiceUsers(ctx context.Context, req *api.ListBackendServiceUsersRequest) (*api.ListBackendServiceUsersResponse, error)
  • func (h *Handler) ListClients(ctx context.Context, req *api.ListClientsRequest) (*api.ListClientsResponse, error)
  • func (h *Handler) ListInternalService(ctx context.Context, req *api.ListInternalServiceRequest) (*api.ListInternalServiceResponse, error)
  • func (h *Handler) StartInternalService(ctx context.Context, req *api.StartInternalServiceRequest) (*api.InternalService, error)
• type InternalService
• type PairedConn
  • func NewPairedConn(src, dst net.Conn) *PairedConn
  • func (pc *PairedConn) Close()
  • func (pc *PairedConn) Copy()
  • func (pc *PairedConn) String() string
• type SharedListener
  • func (sl *SharedListener) Accept() (net.Conn, error)
  • func (sl *SharedListener) Addr() net.Addr
  • func (sl *SharedListener) Close() error
• type Token
  • func (t Token) Len() int
  • func (t Token) String() string

Functions

func Listen

func Listen(network, address string, onClose func()) (net.Listener, error)

Types

type Client

type Client struct {
	NewPubConnNotifyCH chan Token
	// contains filtered or unexported fields
}

func NewClient

func NewClient(name, displayName, host, pubPort, intPort string, sharePub bool, l *log.Entry) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) IntAddr

func (c *Client) IntAddr() string

func (*Client) IntBindAddr

func (c *Client) IntBindAddr() string

func (*Client) PubAddr

func (c *Client) PubAddr() string

func (*Client) PubBindAddr

func (c *Client) PubBindAddr() string

func (*Client) SetSTUNInfo

func (c *Client) SetSTUNInfo(host, backendPort, protocol string)

func (*Client) Start

func (c *Client) Start()

type Handler

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

func New

func New(host string) *Handler

func (*Handler) Close

func (h *Handler) Close()

func (*Handler) CreateClient

func (h *Handler) CreateClient(req *api.CreateClientRequest, svr api.ControlService_CreateClientServer) error

CreateClient creates a new internal listener for clients. Whether public listener is unique depends on request parameter.

func (*Handler) ListBackendServiceUsers

func (h *Handler) ListBackendServiceUsers(ctx context.Context, req *api.ListBackendServiceUsersRequest) (*api.ListBackendServiceUsersResponse, error)

func (*Handler) ListClients

func (h *Handler) ListClients(ctx context.Context, req *api.ListClientsRequest) (*api.ListClientsResponse, error)

func (*Handler) ListInternalService

func (h *Handler) ListInternalService(ctx context.Context, req *api.ListInternalServiceRequest) (*api.ListInternalServiceResponse, error)

func (*Handler) StartInternalService

func (h *Handler) StartInternalService(ctx context.Context, req *api.StartInternalServiceRequest) (*api.InternalService, error)

type InternalService

type InternalService struct {
	PublicPort  int32
	Name        string
	Close       func()
	ServiceName string
	Addr        string
}

type PairedConn

type PairedConn struct {
	SRC, DEST net.Conn
	SpeedIn   float64
	SpeedOut  float64
	OnClose   func()
	// contains filtered or unexported fields
}

func NewPairedConn

func NewPairedConn(src, dst net.Conn) *PairedConn

func (*PairedConn) Close

func (pc *PairedConn) Close()

func (*PairedConn) Copy

func (pc *PairedConn) Copy()

func (*PairedConn) String

func (pc *PairedConn) String() string

type SharedListener

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

SharedListener uses reference count to ensure listening on the same address will success. SO_REUSEPORT ?

func (*SharedListener) Accept

func (sl *SharedListener) Accept() (net.Conn, error)

func (*SharedListener) Addr

func (sl *SharedListener) Addr() net.Addr

func (*SharedListener) Close

func (sl *SharedListener) Close() error

type Token

type Token int

func (Token) Len

func (t Token) Len() int

func (Token) String

func (t Token) String() string