ufo

README

ufo

Listening on TCP port 0 makes the system allocate a random port for you.

...
  ln, err := net.Listen("tcp", ":0")
  if err != nil {
          return err
  }
  log.Println("listening on", ln.Addr().String())
  return http.Serve(ln, http.FileServer(http.Dir(".")))
...

2022/09/24 23:09:17 listening on ::48982

Taking inspiration from that, ufo is a Golang service that allocates random subdomains to clients with automatic SSL, HTTP/3 for free.

The programming interface is the almost the same as [net.Listen]

...
  ln, err := ufo.Listen("https://ufo.k0s.io")
  if err != nil {
          return err
  }
  log.Println("listening on", ln.URL())
  return http.Serve(ln, http.FileServer(http.Dir(".")))
...

2022/09/24 23:09:17 listening on https://1.ufo.k0s.io

deploy server:

$ kubectl apply -f https://raw.githubusercontent.com/btwiuse/ufo/main/deploy.yaml

install client:

$ go install github.com/btwiuse/ufo/cmd/ufo@latest

example apps:

$ ufo hello
$ ufo gos
$ ufo sse
$ ufo echo

TODO

• reverseproxy WebTransport requests
• support user specified hostname, requiring netrc authentication
• support custom root domain, for example HOST=usesthis.app
• support concurrent rw on session manager map

Documentation

Index

• Constants
• func Dial(ctx context.Context, u *url.URL, hdr http.Header) (*webtransport.Session, error)
• func Listen(u string) (*listener, error)
• func Serve(u string, handler http.Handler) error
• type StreamConn
  • func (sc *StreamConn) LocalAddr() net.Addr
  • func (sc *StreamConn) RemoteAddr() net.Addr

Constants

const EnableDatagrams = true

const MaxIncomingStreams int64 = 1 << 60

2^60 == 1152921504606846976

const MaxIncomingUniStreams int64 = 1 << 60

2^60 == 1152921504606846976

Functions

func Dial

func Dial(ctx context.Context, u *url.URL, hdr http.Header) (*webtransport.Session, error)

Dial is a wrapper around webtransport.Dial with automatic HTTP/3 service discovery

func Listen

func Listen(u string) (*listener, error)

func Serve

func Serve(u string, handler http.Handler) error

Types

type StreamConn

type StreamConn struct {
	webtransport.Stream
	Session *webtransport.Session
}

func (*StreamConn) LocalAddr

func (sc *StreamConn) LocalAddr() net.Addr

func (*StreamConn) RemoteAddr

func (sc *StreamConn) RemoteAddr() net.Addr