grpc

Documentation

Index

• Constants
• func NewGrpcClientConn(c proto.Tunnel_OnConnectClient, conn *grpc.ClientConn) io.ReadWriteCloser
• func NewGrpcServerConn(conn proto.Tunnel_OnConnectServer) io.ReadWriteCloser
• func VerifyTokenFromContext(ctx context.Context, token string) error
• type Client
  • func NewClient(opts util.ToxOptions) (*Client, error)
  • func (t *Client) Connect(ctx context.Context) (util.ToxConn, error)
• type GrpcClientConn
  • func (conn *GrpcClientConn) Close() error
  • func (conn *GrpcClientConn) Read(p []byte) (int, error)
  • func (conn *GrpcClientConn) Write(p []byte) (int, error)
• type GrpcServerConn
  • func (conn *GrpcServerConn) Close() error
  • func (conn *GrpcServerConn) Read(p []byte) (int, error)
  • func (conn *GrpcServerConn) Write(p []byte) (int, error)
• type Server
  • func NewServer(opts util.ToxOptions) (*Server, error)
  • func (s *Server) ListenAndServe(handler func(util.ToxConn)) error
  • func (s *Server) OnConnect(stream proto.Tunnel_OnConnectServer) error

Constants

const (
	DialTimeout     = 5 * time.Second
	ConnectTimeout  = 5 * time.Second
	BackoffMaxDelay = 3 * time.Second

	InitialWindowSize     = 1 << 30
	InitialConnWindowSize = 1 << 30

	KeepAliveTimeout = time.Duration(3) * time.Second
	KeepAliveTime    = time.Duration(10) * time.Second

	MaxRecvMsgSize = 1 << 30
	MaxSendMsgSize = 1 << 30

	ReadBufferSize  = 1 << 10
	WriteBufferSize = 1 << 10

	MaxIdle              = 8
	MaxActive            = 64
	MaxConcurrentStreams = 64
)

Functions

func NewGrpcClientConn

func NewGrpcClientConn(c proto.Tunnel_OnConnectClient, conn *grpc.ClientConn) io.ReadWriteCloser

func NewGrpcServerConn

func NewGrpcServerConn(conn proto.Tunnel_OnConnectServer) io.ReadWriteCloser

func VerifyTokenFromContext

func VerifyTokenFromContext(ctx context.Context, token string) error

Types

type Client

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

func NewClient

func NewClient(opts util.ToxOptions) (*Client, error)

func (*Client) Connect

func (t *Client) Connect(ctx context.Context) (util.ToxConn, error)

type GrpcClientConn

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

func (*GrpcClientConn) Close

func (conn *GrpcClientConn) Close() error

func (*GrpcClientConn) Read

func (conn *GrpcClientConn) Read(p []byte) (int, error)

func (*GrpcClientConn) Write

func (conn *GrpcClientConn) Write(p []byte) (int, error)

type GrpcServerConn

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

func (*GrpcServerConn) Close

func (conn *GrpcServerConn) Close() error

func (*GrpcServerConn) Read

func (conn *GrpcServerConn) Read(p []byte) (int, error)

func (*GrpcServerConn) Write

func (conn *GrpcServerConn) Write(p []byte) (int, error)

type Server

type Server struct {
	proto.UnimplementedTunnelServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(opts util.ToxOptions) (*Server, error)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(handler func(util.ToxConn)) error

func (*Server) OnConnect

func (s *Server) OnConnect(stream proto.Tunnel_OnConnectServer) error