intra

type DuplexConn interface {
	io.ReadWriter
	io.ReaderFrom
	CloseWrite() error
	CloseRead() error
}

type RetryStats struct {
	Bytes   int32 // Number of bytes uploaded before the retry.
	Chunks  int16 // Number of writes before the retry.
	Split   int16 // Number of bytes in the first retried segment.
	Timeout bool  // True if the retry was caused by a timeout.
}

type TCPListener interface {
	OnTCPSocketClosed(*TCPSocketSummary)
}

type TCPSocketSummary struct {
	DownloadBytes int64       // Total bytes downloaded.
	UploadBytes   int64       // Total bytes uploaded.
	Duration      int32       // Duration in seconds.
	ServerPort    int16       // The server port.  All values except 80, 443, and 0 are set to -1.
	Synack        int32       // TCP handshake latency (ms)
	Retry         *RetryStats // Non-nil if a retry occurred.
}

type UDPListener interface {
	OnUDPSocketClosed(*UDPSocketSummary)
}

type UDPSocketSummary struct {
	UploadBytes   int64 // Amount uploaded (bytes)
	DownloadBytes int64 // Amount downloaded (bytes)
	Duration      int32 // How long the socket was open (seconds)
}