quicproxy

Documentation

Index

• func ServeProxy(ctx context.Context, frontend ProxyFrontend, conn quic.Connection, ...) error
• type Allocation
• type Handlers
• type ProxyFrontend
• type ProxyProtoFrontend
  • func (pf *ProxyProtoFrontend) Handle(ctx context.Context, handlers Handlers) error
  • func (pf *ProxyProtoFrontend) ListenAndServe(ctx context.Context) error
• type RawFrontend
  • func (rf RawFrontend) Handle(ctx context.Context, handlers Handlers) error
  • func (rf RawFrontend) ListenAndServe(ctx context.Context) error
• type Server
  • func NewServer(ctx context.Context, opts ServerOpts) (*Server, error)
  • func (srv *Server) Close() error
  • func (srv *Server) Serve(ctx context.Context) error
• type ServerOpts

Functions

func ServeProxy

func ServeProxy(ctx context.Context, frontend ProxyFrontend, conn quic.Connection, callback func(Allocation) error) error

Types

type Allocation

type Allocation struct {
	Endpoint string
}

type Handlers

type Handlers struct {
	OnAllocation func(Allocation) error
	OnCleanup    func(Allocation, error)
	HandleConn   func(net.Conn)
}

type ProxyFrontend

type ProxyFrontend interface {
	ListenAndServe(context.Context) error
	Handle(context.Context, Handlers) error
}

type ProxyProtoFrontend

type ProxyProtoFrontend struct {
	ListenPort         int
	PortStart, PortEnd int
	PublicAddr         string
	// contains filtered or unexported fields
}

func (*ProxyProtoFrontend) Handle

func (pf *ProxyProtoFrontend) Handle(ctx context.Context, handlers Handlers) error

func (*ProxyProtoFrontend) ListenAndServe

func (pf *ProxyProtoFrontend) ListenAndServe(ctx context.Context) error

type RawFrontend

type RawFrontend struct {
	PublicAddr string
}

func (RawFrontend) Handle

func (rf RawFrontend) Handle(ctx context.Context, handlers Handlers) error

func (RawFrontend) ListenAndServe

func (rf RawFrontend) ListenAndServe(ctx context.Context) error

type Server

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

func NewServer

func NewServer(ctx context.Context, opts ServerOpts) (*Server, error)

func (*Server) Close

func (srv *Server) Close() error

func (*Server) Serve

func (srv *Server) Serve(ctx context.Context) error

type ServerOpts

type ServerOpts struct {
	ProxyFrontend    ProxyFrontend
	ListenAddr       string
	Subjects         tlscerts.Subjects
	EnableGitHubOIDC bool
}