transporter

Documentation

Overview

nolint: errcheck

Index

• func NewNetDialer(cfg *conf.Config) *net.Dialer
• func NewTCPListener(ctx context.Context, cfg *conf.Config) (net.Listener, error)
• type BaseRelayServer
  • func (b *BaseRelayServer) Close() error
  • func (b *BaseRelayServer) HealthCheck(ctx context.Context) (int64, error)
  • func (b *BaseRelayServer) ListenAndServe(ctx context.Context) error
  • func (b *BaseRelayServer) RelayTCPConn(ctx context.Context, c net.Conn, remote *lb.Node) error
  • func (b *BaseRelayServer) RelayUDPConn(ctx context.Context, c net.Conn, remote *lb.Node) error
• type RawClient
  • func (raw *RawClient) HandShake(ctx context.Context, remote *lb.Node, isTCP bool) (net.Conn, error)
• type RawServer
  • func (s *RawServer) Close() error
  • func (s *RawServer) ListenAndServe(ctx context.Context) error
• type RelayClient
• type RelayServer
  • func NewRelayServer(cfg *conf.Config, cmgr cmgr.Cmgr) (RelayServer, error)
• type WsClient
  • func (s *WsClient) HandShake(ctx context.Context, remote *lb.Node, isTCP bool) (net.Conn, error)
• type WsServer
  • func (s *WsServer) Close() error
  • func (s *WsServer) ListenAndServe(ctx context.Context) error
• type WssClient
• type WssServer
  • func (s *WssServer) ListenAndServe(ctx context.Context) error

Functions

func NewNetDialer

func NewNetDialer(cfg *conf.Config) *net.Dialer

func NewTCPListener

func NewTCPListener(ctx context.Context, cfg *conf.Config) (net.Listener, error)

Types

type BaseRelayServer

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

func (*BaseRelayServer) Close

func (b *BaseRelayServer) Close() error

func (*BaseRelayServer) HealthCheck

func (b *BaseRelayServer) HealthCheck(ctx context.Context) (int64, error)

func (*BaseRelayServer) ListenAndServe

func (b *BaseRelayServer) ListenAndServe(ctx context.Context) error

func (*BaseRelayServer) RelayTCPConn

func (b *BaseRelayServer) RelayTCPConn(ctx context.Context, c net.Conn, remote *lb.Node) error

func (*BaseRelayServer) RelayUDPConn

func (b *BaseRelayServer) RelayUDPConn(ctx context.Context, c net.Conn, remote *lb.Node) error

type RawClient

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

func (*RawClient) HandShake

func (raw *RawClient) HandShake(ctx context.Context, remote *lb.Node, isTCP bool) (net.Conn, error)

type RawServer

type RawServer struct {
	*BaseRelayServer
	// contains filtered or unexported fields
}

func (*RawServer) Close

func (s *RawServer) Close() error

func (*RawServer) ListenAndServe

func (s *RawServer) ListenAndServe(ctx context.Context) error

type RelayClient

type RelayClient interface {
	HandShake(ctx context.Context, remote *lb.Node, isTCP bool) (net.Conn, error)
}

TODO opt this interface

type RelayServer

type RelayServer interface {
	ListenAndServe(ctx context.Context) error
	Close() error

	RelayTCPConn(ctx context.Context, c net.Conn, remote *lb.Node) error
	RelayUDPConn(ctx context.Context, c net.Conn, remote *lb.Node) error
	HealthCheck(ctx context.Context) (int64, error) // latency in ms
}

func NewRelayServer

func NewRelayServer(cfg *conf.Config, cmgr cmgr.Cmgr) (RelayServer, error)

type WsClient

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

func (*WsClient) HandShake

func (s *WsClient) HandShake(ctx context.Context, remote *lb.Node, isTCP bool) (net.Conn, error)

type WsServer

type WsServer struct {
	*BaseRelayServer
	// contains filtered or unexported fields
}

func (*WsServer) Close

func (s *WsServer) Close() error

func (*WsServer) ListenAndServe

func (s *WsServer) ListenAndServe(ctx context.Context) error

type WssClient

type WssClient struct {
	*WsClient
}

type WssServer

type WssServer struct {
	*WsServer
}

func (*WssServer) ListenAndServe

func (s *WssServer) ListenAndServe(ctx context.Context) error