Versions in this module Expand all Collapse all v0 v0.1.0 Apr 19, 2026 Changes in this version + const DatagramVersionV3 + const DefaultDatagramVersion + const H2HeaderResponseMeta + const H2HeaderResponseUser + const H2HeaderTCPSrc + const H2HeaderUpgrade + const H2ResponseMetaOrigin + const H2UpgradeConfiguration + const H2UpgradeControlStream + const H2UpgradeWebsocket + const MetadataFlowConnectRateLimited + const MetadataHTTPHeader + const MetadataHTTPHeaderPrefix + const MetadataHTTPHost + const MetadataHTTPMethod + const MetadataHTTPStatus + const ProtocolVersion + var DataStreamSignature = [6]byte + var HeaderEncoding = base64.RawStdEncoding + var RPCStreamSignature = [6]byte + func HasFlowConnectRateLimited(metadata []Metadata) bool + func IsControlResponseHeader(name string) bool + func IsWebsocketClientHeader(name string) bool + func SerializeHeaders(header http.Header) string + func WriteConnectResponse(w io.Writer, responseError error, metadata ...Metadata) error + func WriteRPCStreamSignature(w io.Writer) error + type ConnectRequest struct + Dest string + Metadata []Metadata + Type ConnectionType + func ReadConnectRequest(r io.Reader) (*ConnectRequest, error) + func (r *ConnectRequest) FromCapnp(msg *capnp.Message) error + func (r *ConnectRequest) MetadataMap() map[string]string + type ConnectResponse struct + Error string + Metadata []Metadata + func (r *ConnectResponse) ToCapnp() (*capnp.Message, error) + type ConnectResponseWriter interface + WriteResponse func(responseError error, metadata []Metadata) error + type ConnectionType uint16 + const ConnectionTypeHTTP + const ConnectionTypeTCP + const ConnectionTypeWebsocket + func (c ConnectionType) String() string + type Credentials struct + AccountTag string + Endpoint string + TunnelID uuid.UUID + TunnelSecret []byte + func (c *Credentials) Auth() TunnelAuth + type DatagramSender interface + SendDatagram func(data []byte) error + type DatagramV2Type byte + const DatagramV2TypeIP + const DatagramV2TypeIPWithTrace + const DatagramV2TypeTracingSpan + const DatagramV2TypeUDP + const TypeIDLength + type DatagramV3Type byte + const DatagramV3TypeICMP + const DatagramV3TypePayload + const DatagramV3TypeRegistration + const DatagramV3TypeRegistrationResponse + const MaxV3UDPPayloadLen + type Metadata struct + Key string + Val string + func FlowConnectRateLimitedMetadata() []Metadata + type RegistrationClientInfo struct + Arch string + ClientID []byte + Features []string + Version string + type RegistrationConnectionOptions struct + Client RegistrationClientInfo + CompressionQuality uint8 + NumPreviousAttempts uint8 + OriginLocalIP net.IP + ReplaceExisting bool + type RegistrationResult struct + ConnectionID uuid.UUID + Location string + TunnelIsRemotelyManaged bool + type RegistrationTunnelAuth struct + AccountTag string + TunnelSecret []byte + type RequestID [16]byte + type RetryableError struct + Delay time.Duration + Err error + func (e *RetryableError) Error() string + func (e *RetryableError) Unwrap() error + type StreamType int + const StreamTypeData + const StreamTypeRPC + func ReadStreamSignature(r io.Reader) (StreamType, error) + type TunnelAuth struct + AccountTag string + TunnelSecret []byte + type TunnelToken struct + AccountTag string + Endpoint string + TunnelID uuid.UUID + TunnelSecret []byte + func (t TunnelToken) ToCredentials() Credentials
Go to main page