pb

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 14, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Protocol_name = map[int32]string{
		0: "PROTOCOL_UNKNOWN",
		1: "PROTOCOL_HTTP",
		2: "PROTOCOL_HTTPS",
		3: "PROTOCOL_TCP",
		4: "PROTOCOL_UDP",
		5: "PROTOCOL_WEBSOCKET",
		6: "PROTOCOL_GRPC",
	}
	Protocol_value = map[string]int32{
		"PROTOCOL_UNKNOWN":   0,
		"PROTOCOL_HTTP":      1,
		"PROTOCOL_HTTPS":     2,
		"PROTOCOL_TCP":       3,
		"PROTOCOL_UDP":       4,
		"PROTOCOL_WEBSOCKET": 5,
		"PROTOCOL_GRPC":      6,
	}
)

Enum value maps for Protocol.

View Source
var (
	MessageType_name = map[int32]string{
		0:  "MESSAGE_TYPE_UNKNOWN",
		1:  "MESSAGE_TYPE_AUTH_REQUEST",
		2:  "MESSAGE_TYPE_AUTH_RESPONSE",
		3:  "MESSAGE_TYPE_REGISTER_REQUEST",
		4:  "MESSAGE_TYPE_REGISTER_RESPONSE",
		5:  "MESSAGE_TYPE_PING_REQUEST",
		6:  "MESSAGE_TYPE_PING_RESPONSE",
		7:  "MESSAGE_TYPE_STREAM_REQUEST",
		8:  "MESSAGE_TYPE_STREAM_RESPONSE",
		9:  "MESSAGE_TYPE_STATS_REQUEST",
		10: "MESSAGE_TYPE_STATS_RESPONSE",
		11: "MESSAGE_TYPE_CLOSE_REQUEST",
		12: "MESSAGE_TYPE_CLOSE_RESPONSE",
		13: "MESSAGE_TYPE_P2P_OFFER_REQUEST",
		14: "MESSAGE_TYPE_P2P_OFFER_RESPONSE",
		15: "MESSAGE_TYPE_P2P_CANDIDATES",
		16: "MESSAGE_TYPE_P2P_RESULT",
	}
	MessageType_value = map[string]int32{
		"MESSAGE_TYPE_UNKNOWN":            0,
		"MESSAGE_TYPE_AUTH_REQUEST":       1,
		"MESSAGE_TYPE_AUTH_RESPONSE":      2,
		"MESSAGE_TYPE_REGISTER_REQUEST":   3,
		"MESSAGE_TYPE_REGISTER_RESPONSE":  4,
		"MESSAGE_TYPE_PING_REQUEST":       5,
		"MESSAGE_TYPE_PING_RESPONSE":      6,
		"MESSAGE_TYPE_STREAM_REQUEST":     7,
		"MESSAGE_TYPE_STREAM_RESPONSE":    8,
		"MESSAGE_TYPE_STATS_REQUEST":      9,
		"MESSAGE_TYPE_STATS_RESPONSE":     10,
		"MESSAGE_TYPE_CLOSE_REQUEST":      11,
		"MESSAGE_TYPE_CLOSE_RESPONSE":     12,
		"MESSAGE_TYPE_P2P_OFFER_REQUEST":  13,
		"MESSAGE_TYPE_P2P_OFFER_RESPONSE": 14,
		"MESSAGE_TYPE_P2P_CANDIDATES":     15,
		"MESSAGE_TYPE_P2P_RESULT":         16,
	}
)

Enum value maps for MessageType.

View Source
var File_control_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AuthRequest

type AuthRequest struct {

	// Token for authentication (team token or API key)
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Client version
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Requested subdomain (optional)
	Subdomain string `protobuf:"bytes,3,opt,name=subdomain,proto3" json:"subdomain,omitempty"`
	// Client capabilities
	Capabilities []string `protobuf:"bytes,4,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

AuthRequest is sent by client to authenticate with the server.

func (*AuthRequest) Descriptor deprecated

func (*AuthRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuthRequest.ProtoReflect.Descriptor instead.

func (*AuthRequest) GetCapabilities

func (x *AuthRequest) GetCapabilities() []string

func (*AuthRequest) GetSubdomain

func (x *AuthRequest) GetSubdomain() string

func (*AuthRequest) GetToken

func (x *AuthRequest) GetToken() string

func (*AuthRequest) GetVersion

func (x *AuthRequest) GetVersion() string

func (*AuthRequest) ProtoMessage

func (*AuthRequest) ProtoMessage()

func (*AuthRequest) ProtoReflect

func (x *AuthRequest) ProtoReflect() protoreflect.Message

func (*AuthRequest) Reset

func (x *AuthRequest) Reset()

func (*AuthRequest) String

func (x *AuthRequest) String() string

type AuthResponse

type AuthResponse struct {

	// Whether authentication succeeded
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if failed
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Assigned subdomain
	Subdomain string `protobuf:"bytes,3,opt,name=subdomain,proto3" json:"subdomain,omitempty"`
	// Public URL for the tunnel
	PublicUrl string `protobuf:"bytes,4,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	// Assigned TCP port (if applicable)
	TcpPort uint32 `protobuf:"varint,5,opt,name=tcp_port,json=tcpPort,proto3" json:"tcp_port,omitempty"`
	// Server capabilities
	Capabilities []string `protobuf:"bytes,6,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// Session ID for this connection
	SessionId string `protobuf:"bytes,7,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

AuthResponse is sent by server after authentication.

func (*AuthResponse) Descriptor deprecated

func (*AuthResponse) Descriptor() ([]byte, []int)

Deprecated: Use AuthResponse.ProtoReflect.Descriptor instead.

func (*AuthResponse) GetCapabilities

func (x *AuthResponse) GetCapabilities() []string

func (*AuthResponse) GetError

func (x *AuthResponse) GetError() string

func (*AuthResponse) GetPublicUrl

func (x *AuthResponse) GetPublicUrl() string

func (*AuthResponse) GetSessionId

func (x *AuthResponse) GetSessionId() string

func (*AuthResponse) GetSubdomain

func (x *AuthResponse) GetSubdomain() string

func (*AuthResponse) GetSuccess

func (x *AuthResponse) GetSuccess() bool

func (*AuthResponse) GetTcpPort

func (x *AuthResponse) GetTcpPort() uint32

func (*AuthResponse) ProtoMessage

func (*AuthResponse) ProtoMessage()

func (*AuthResponse) ProtoReflect

func (x *AuthResponse) ProtoReflect() protoreflect.Message

func (*AuthResponse) Reset

func (x *AuthResponse) Reset()

func (*AuthResponse) String

func (x *AuthResponse) String() string

type CloseRequest

type CloseRequest struct {

	// Tunnel ID to close
	TunnelId string `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Reason for closing
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

CloseRequest is sent to close a tunnel.

func (*CloseRequest) Descriptor deprecated

func (*CloseRequest) Descriptor() ([]byte, []int)

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetReason

func (x *CloseRequest) GetReason() string

func (*CloseRequest) GetTunnelId

func (x *CloseRequest) GetTunnelId() string

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect

func (x *CloseRequest) ProtoReflect() protoreflect.Message

func (*CloseRequest) Reset

func (x *CloseRequest) Reset()

func (*CloseRequest) String

func (x *CloseRequest) String() string

type CloseResponse

type CloseResponse struct {

	// Whether close was successful
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

CloseResponse acknowledges a close request.

func (*CloseResponse) Descriptor deprecated

func (*CloseResponse) Descriptor() ([]byte, []int)

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) GetSuccess

func (x *CloseResponse) GetSuccess() bool

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect

func (x *CloseResponse) ProtoReflect() protoreflect.Message

func (*CloseResponse) Reset

func (x *CloseResponse) Reset()

func (*CloseResponse) String

func (x *CloseResponse) String() string

type ControlMessage

type ControlMessage struct {

	// Message type
	Type MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=wormhole.MessageType" json:"type,omitempty"`
	// Sequence number for request/response matching
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// One of the following messages
	//
	// Types that are valid to be assigned to Payload:
	//
	//	*ControlMessage_AuthRequest
	//	*ControlMessage_AuthResponse
	//	*ControlMessage_RegisterRequest
	//	*ControlMessage_RegisterResponse
	//	*ControlMessage_PingRequest
	//	*ControlMessage_PingResponse
	//	*ControlMessage_StreamRequest
	//	*ControlMessage_StreamResponse
	//	*ControlMessage_StatsRequest
	//	*ControlMessage_StatsResponse
	//	*ControlMessage_CloseRequest
	//	*ControlMessage_CloseResponse
	//	*ControlMessage_P2POfferRequest
	//	*ControlMessage_P2POfferResponse
	//	*ControlMessage_P2PCandidates
	//	*ControlMessage_P2PResult
	Payload isControlMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

ControlMessage is a wrapper for all control messages.

func (*ControlMessage) Descriptor deprecated

func (*ControlMessage) Descriptor() ([]byte, []int)

Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage) GetAuthRequest

func (x *ControlMessage) GetAuthRequest() *AuthRequest

func (*ControlMessage) GetAuthResponse

func (x *ControlMessage) GetAuthResponse() *AuthResponse

func (*ControlMessage) GetCloseRequest

func (x *ControlMessage) GetCloseRequest() *CloseRequest

func (*ControlMessage) GetCloseResponse

func (x *ControlMessage) GetCloseResponse() *CloseResponse

func (*ControlMessage) GetP2PCandidates

func (x *ControlMessage) GetP2PCandidates() *P2PCandidates

func (*ControlMessage) GetP2POfferRequest

func (x *ControlMessage) GetP2POfferRequest() *P2POfferRequest

func (*ControlMessage) GetP2POfferResponse

func (x *ControlMessage) GetP2POfferResponse() *P2POfferResponse

func (*ControlMessage) GetP2PResult

func (x *ControlMessage) GetP2PResult() *P2PResult

func (*ControlMessage) GetPayload

func (x *ControlMessage) GetPayload() isControlMessage_Payload

func (*ControlMessage) GetPingRequest

func (x *ControlMessage) GetPingRequest() *PingRequest

func (*ControlMessage) GetPingResponse

func (x *ControlMessage) GetPingResponse() *PingResponse

func (*ControlMessage) GetRegisterRequest

func (x *ControlMessage) GetRegisterRequest() *RegisterRequest

func (*ControlMessage) GetRegisterResponse

func (x *ControlMessage) GetRegisterResponse() *RegisterResponse

func (*ControlMessage) GetSequence

func (x *ControlMessage) GetSequence() uint64

func (*ControlMessage) GetStatsRequest

func (x *ControlMessage) GetStatsRequest() *StatsRequest

func (*ControlMessage) GetStatsResponse

func (x *ControlMessage) GetStatsResponse() *StatsResponse

func (*ControlMessage) GetStreamRequest

func (x *ControlMessage) GetStreamRequest() *StreamRequest

func (*ControlMessage) GetStreamResponse

func (x *ControlMessage) GetStreamResponse() *StreamResponse

func (*ControlMessage) GetType

func (x *ControlMessage) GetType() MessageType

func (*ControlMessage) ProtoMessage

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) ProtoReflect

func (x *ControlMessage) ProtoReflect() protoreflect.Message

func (*ControlMessage) Reset

func (x *ControlMessage) Reset()

func (*ControlMessage) String

func (x *ControlMessage) String() string

type ControlMessage_AuthRequest

type ControlMessage_AuthRequest struct {
	AuthRequest *AuthRequest `protobuf:"bytes,10,opt,name=auth_request,json=authRequest,proto3,oneof"`
}

type ControlMessage_AuthResponse

type ControlMessage_AuthResponse struct {
	AuthResponse *AuthResponse `protobuf:"bytes,11,opt,name=auth_response,json=authResponse,proto3,oneof"`
}

type ControlMessage_CloseRequest

type ControlMessage_CloseRequest struct {
	CloseRequest *CloseRequest `protobuf:"bytes,20,opt,name=close_request,json=closeRequest,proto3,oneof"`
}

type ControlMessage_CloseResponse

type ControlMessage_CloseResponse struct {
	CloseResponse *CloseResponse `protobuf:"bytes,21,opt,name=close_response,json=closeResponse,proto3,oneof"`
}

type ControlMessage_P2PCandidates

type ControlMessage_P2PCandidates struct {
	P2PCandidates *P2PCandidates `protobuf:"bytes,24,opt,name=p2p_candidates,json=p2pCandidates,proto3,oneof"`
}

type ControlMessage_P2POfferRequest

type ControlMessage_P2POfferRequest struct {
	P2POfferRequest *P2POfferRequest `protobuf:"bytes,22,opt,name=p2p_offer_request,json=p2pOfferRequest,proto3,oneof"`
}

type ControlMessage_P2POfferResponse

type ControlMessage_P2POfferResponse struct {
	P2POfferResponse *P2POfferResponse `protobuf:"bytes,23,opt,name=p2p_offer_response,json=p2pOfferResponse,proto3,oneof"`
}

type ControlMessage_P2PResult

type ControlMessage_P2PResult struct {
	P2PResult *P2PResult `protobuf:"bytes,25,opt,name=p2p_result,json=p2pResult,proto3,oneof"`
}

type ControlMessage_PingRequest

type ControlMessage_PingRequest struct {
	PingRequest *PingRequest `protobuf:"bytes,14,opt,name=ping_request,json=pingRequest,proto3,oneof"`
}

type ControlMessage_PingResponse

type ControlMessage_PingResponse struct {
	PingResponse *PingResponse `protobuf:"bytes,15,opt,name=ping_response,json=pingResponse,proto3,oneof"`
}

type ControlMessage_RegisterRequest

type ControlMessage_RegisterRequest struct {
	RegisterRequest *RegisterRequest `protobuf:"bytes,12,opt,name=register_request,json=registerRequest,proto3,oneof"`
}

type ControlMessage_RegisterResponse

type ControlMessage_RegisterResponse struct {
	RegisterResponse *RegisterResponse `protobuf:"bytes,13,opt,name=register_response,json=registerResponse,proto3,oneof"`
}

type ControlMessage_StatsRequest

type ControlMessage_StatsRequest struct {
	StatsRequest *StatsRequest `protobuf:"bytes,18,opt,name=stats_request,json=statsRequest,proto3,oneof"`
}

type ControlMessage_StatsResponse

type ControlMessage_StatsResponse struct {
	StatsResponse *StatsResponse `protobuf:"bytes,19,opt,name=stats_response,json=statsResponse,proto3,oneof"`
}

type ControlMessage_StreamRequest

type ControlMessage_StreamRequest struct {
	StreamRequest *StreamRequest `protobuf:"bytes,16,opt,name=stream_request,json=streamRequest,proto3,oneof"`
}

type ControlMessage_StreamResponse

type ControlMessage_StreamResponse struct {
	StreamResponse *StreamResponse `protobuf:"bytes,17,opt,name=stream_response,json=streamResponse,proto3,oneof"`
}

type HttpMetadata

type HttpMetadata struct {

	// HTTP method
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// Request URI
	Uri string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	// Host header
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// Content-Type header
	ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// Content-Length
	ContentLength int64 `protobuf:"varint,5,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// contains filtered or unexported fields
}

HttpMetadata contains HTTP-specific information.

func (*HttpMetadata) Descriptor deprecated

func (*HttpMetadata) Descriptor() ([]byte, []int)

Deprecated: Use HttpMetadata.ProtoReflect.Descriptor instead.

func (*HttpMetadata) GetContentLength

func (x *HttpMetadata) GetContentLength() int64

func (*HttpMetadata) GetContentType

func (x *HttpMetadata) GetContentType() string

func (*HttpMetadata) GetHost

func (x *HttpMetadata) GetHost() string

func (*HttpMetadata) GetMethod

func (x *HttpMetadata) GetMethod() string

func (*HttpMetadata) GetUri

func (x *HttpMetadata) GetUri() string

func (*HttpMetadata) ProtoMessage

func (*HttpMetadata) ProtoMessage()

func (*HttpMetadata) ProtoReflect

func (x *HttpMetadata) ProtoReflect() protoreflect.Message

func (*HttpMetadata) Reset

func (x *HttpMetadata) Reset()

func (*HttpMetadata) String

func (x *HttpMetadata) String() string

type MessageType

type MessageType int32

MessageType identifies the type of control message.

const (
	MessageType_MESSAGE_TYPE_UNKNOWN            MessageType = 0
	MessageType_MESSAGE_TYPE_AUTH_REQUEST       MessageType = 1
	MessageType_MESSAGE_TYPE_AUTH_RESPONSE      MessageType = 2
	MessageType_MESSAGE_TYPE_REGISTER_REQUEST   MessageType = 3
	MessageType_MESSAGE_TYPE_REGISTER_RESPONSE  MessageType = 4
	MessageType_MESSAGE_TYPE_PING_REQUEST       MessageType = 5
	MessageType_MESSAGE_TYPE_PING_RESPONSE      MessageType = 6
	MessageType_MESSAGE_TYPE_STREAM_REQUEST     MessageType = 7
	MessageType_MESSAGE_TYPE_STREAM_RESPONSE    MessageType = 8
	MessageType_MESSAGE_TYPE_STATS_REQUEST      MessageType = 9
	MessageType_MESSAGE_TYPE_STATS_RESPONSE     MessageType = 10
	MessageType_MESSAGE_TYPE_CLOSE_REQUEST      MessageType = 11
	MessageType_MESSAGE_TYPE_CLOSE_RESPONSE     MessageType = 12
	MessageType_MESSAGE_TYPE_P2P_OFFER_REQUEST  MessageType = 13
	MessageType_MESSAGE_TYPE_P2P_OFFER_RESPONSE MessageType = 14
	MessageType_MESSAGE_TYPE_P2P_CANDIDATES     MessageType = 15
	MessageType_MESSAGE_TYPE_P2P_RESULT         MessageType = 16
)

func (MessageType) Descriptor

func (MessageType) Enum

func (x MessageType) Enum() *MessageType

func (MessageType) EnumDescriptor deprecated

func (MessageType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageType.Descriptor instead.

func (MessageType) Number

func (x MessageType) Number() protoreflect.EnumNumber

func (MessageType) String

func (x MessageType) String() string

func (MessageType) Type

type P2PCandidates

type P2PCandidates struct {

	// Tunnel ID.
	TunnelId string `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// List of candidate endpoints.
	Candidates []string `protobuf:"bytes,2,rep,name=candidates,proto3" json:"candidates,omitempty"`
	// contains filtered or unexported fields
}

P2PCandidates carries additional candidate endpoints for hole punching.

func (*P2PCandidates) Descriptor deprecated

func (*P2PCandidates) Descriptor() ([]byte, []int)

Deprecated: Use P2PCandidates.ProtoReflect.Descriptor instead.

func (*P2PCandidates) GetCandidates

func (x *P2PCandidates) GetCandidates() []string

func (*P2PCandidates) GetTunnelId

func (x *P2PCandidates) GetTunnelId() string

func (*P2PCandidates) ProtoMessage

func (*P2PCandidates) ProtoMessage()

func (*P2PCandidates) ProtoReflect

func (x *P2PCandidates) ProtoReflect() protoreflect.Message

func (*P2PCandidates) Reset

func (x *P2PCandidates) Reset()

func (*P2PCandidates) String

func (x *P2PCandidates) String() string

type P2POfferRequest

type P2POfferRequest struct {

	// Tunnel ID wanting P2P.
	TunnelId string `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Sender's detected NAT type.
	NatType string `protobuf:"bytes,2,opt,name=nat_type,json=natType,proto3" json:"nat_type,omitempty"`
	// Sender's public endpoint as discovered by STUN.
	PublicAddr string `protobuf:"bytes,3,opt,name=public_addr,json=publicAddr,proto3" json:"public_addr,omitempty"`
	// Sender's local endpoint.
	LocalAddr string `protobuf:"bytes,4,opt,name=local_addr,json=localAddr,proto3" json:"local_addr,omitempty"`
	// Sender's ECDH X25519 public key (base64-encoded).
	PublicKey string `protobuf:"bytes,5,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// contains filtered or unexported fields
}

P2POfferRequest is sent by a client to initiate a P2P connection.

func (*P2POfferRequest) Descriptor deprecated

func (*P2POfferRequest) Descriptor() ([]byte, []int)

Deprecated: Use P2POfferRequest.ProtoReflect.Descriptor instead.

func (*P2POfferRequest) GetLocalAddr

func (x *P2POfferRequest) GetLocalAddr() string

func (*P2POfferRequest) GetNatType

func (x *P2POfferRequest) GetNatType() string

func (*P2POfferRequest) GetPublicAddr

func (x *P2POfferRequest) GetPublicAddr() string

func (*P2POfferRequest) GetPublicKey

func (x *P2POfferRequest) GetPublicKey() string

func (*P2POfferRequest) GetTunnelId

func (x *P2POfferRequest) GetTunnelId() string

func (*P2POfferRequest) ProtoMessage

func (*P2POfferRequest) ProtoMessage()

func (*P2POfferRequest) ProtoReflect

func (x *P2POfferRequest) ProtoReflect() protoreflect.Message

func (*P2POfferRequest) Reset

func (x *P2POfferRequest) Reset()

func (*P2POfferRequest) String

func (x *P2POfferRequest) String() string

type P2POfferResponse

type P2POfferResponse struct {

	// Whether a peer was found.
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Reason if the offer was rejected.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Peer's public endpoint.
	PeerAddr string `protobuf:"bytes,3,opt,name=peer_addr,json=peerAddr,proto3" json:"peer_addr,omitempty"`
	// Peer's NAT type.
	PeerNatType string `protobuf:"bytes,4,opt,name=peer_nat_type,json=peerNatType,proto3" json:"peer_nat_type,omitempty"`
	// Peer's ECDH X25519 public key (base64-encoded).
	PeerPublicKey string `protobuf:"bytes,5,opt,name=peer_public_key,json=peerPublicKey,proto3" json:"peer_public_key,omitempty"`
	// contains filtered or unexported fields
}

P2POfferResponse is the server's response to a P2P offer.

func (*P2POfferResponse) Descriptor deprecated

func (*P2POfferResponse) Descriptor() ([]byte, []int)

Deprecated: Use P2POfferResponse.ProtoReflect.Descriptor instead.

func (*P2POfferResponse) GetError

func (x *P2POfferResponse) GetError() string

func (*P2POfferResponse) GetPeerAddr

func (x *P2POfferResponse) GetPeerAddr() string

func (*P2POfferResponse) GetPeerNatType

func (x *P2POfferResponse) GetPeerNatType() string

func (*P2POfferResponse) GetPeerPublicKey

func (x *P2POfferResponse) GetPeerPublicKey() string

func (*P2POfferResponse) GetSuccess

func (x *P2POfferResponse) GetSuccess() bool

func (*P2POfferResponse) ProtoMessage

func (*P2POfferResponse) ProtoMessage()

func (*P2POfferResponse) ProtoReflect

func (x *P2POfferResponse) ProtoReflect() protoreflect.Message

func (*P2POfferResponse) Reset

func (x *P2POfferResponse) Reset()

func (*P2POfferResponse) String

func (x *P2POfferResponse) String() string

type P2PResult

type P2PResult struct {

	// Tunnel ID.
	TunnelId string `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Whether P2P was established.
	Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// Confirmed peer address (if successful).
	PeerAddr string `protobuf:"bytes,3,opt,name=peer_addr,json=peerAddr,proto3" json:"peer_addr,omitempty"`
	// Reason if P2P failed.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

P2PResult reports the outcome of a P2P connection attempt.

func (*P2PResult) Descriptor deprecated

func (*P2PResult) Descriptor() ([]byte, []int)

Deprecated: Use P2PResult.ProtoReflect.Descriptor instead.

func (*P2PResult) GetError

func (x *P2PResult) GetError() string

func (*P2PResult) GetPeerAddr

func (x *P2PResult) GetPeerAddr() string

func (*P2PResult) GetSuccess

func (x *P2PResult) GetSuccess() bool

func (*P2PResult) GetTunnelId

func (x *P2PResult) GetTunnelId() string

func (*P2PResult) ProtoMessage

func (*P2PResult) ProtoMessage()

func (*P2PResult) ProtoReflect

func (x *P2PResult) ProtoReflect() protoreflect.Message

func (*P2PResult) Reset

func (x *P2PResult) Reset()

func (*P2PResult) String

func (x *P2PResult) String() string

type PingRequest

type PingRequest struct {

	// Ping ID for matching responses
	PingId uint64 `protobuf:"varint,1,opt,name=ping_id,json=pingId,proto3" json:"ping_id,omitempty"`
	// Timestamp when ping was sent
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

PingRequest is used for keep-alive.

func (*PingRequest) Descriptor deprecated

func (*PingRequest) Descriptor() ([]byte, []int)

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetPingId

func (x *PingRequest) GetPingId() uint64

func (*PingRequest) GetTimestamp

func (x *PingRequest) GetTimestamp() int64

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResponse

type PingResponse struct {

	// Echo back the ping ID
	PingId uint64 `protobuf:"varint,1,opt,name=ping_id,json=pingId,proto3" json:"ping_id,omitempty"`
	// Server timestamp
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

PingResponse is the response to a ping.

func (*PingResponse) Descriptor deprecated

func (*PingResponse) Descriptor() ([]byte, []int)

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetPingId

func (x *PingResponse) GetPingId() uint64

func (*PingResponse) GetTimestamp

func (x *PingResponse) GetTimestamp() int64

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

func (x *PingResponse) ProtoReflect() protoreflect.Message

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type Protocol

type Protocol int32

Protocol defines the protocol type for a tunnel.

const (
	Protocol_PROTOCOL_UNKNOWN   Protocol = 0
	Protocol_PROTOCOL_HTTP      Protocol = 1
	Protocol_PROTOCOL_HTTPS     Protocol = 2
	Protocol_PROTOCOL_TCP       Protocol = 3
	Protocol_PROTOCOL_UDP       Protocol = 4
	Protocol_PROTOCOL_WEBSOCKET Protocol = 5
	Protocol_PROTOCOL_GRPC      Protocol = 6
)

func (Protocol) Descriptor

func (Protocol) Descriptor() protoreflect.EnumDescriptor

func (Protocol) Enum

func (x Protocol) Enum() *Protocol

func (Protocol) EnumDescriptor deprecated

func (Protocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use Protocol.Descriptor instead.

func (Protocol) Number

func (x Protocol) Number() protoreflect.EnumNumber

func (Protocol) String

func (x Protocol) String() string

func (Protocol) Type

type RegisterRequest

type RegisterRequest struct {

	// Local port being exposed
	LocalPort uint32 `protobuf:"varint,1,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
	// Protocol type
	Protocol Protocol `protobuf:"varint,2,opt,name=protocol,proto3,enum=wormhole.Protocol" json:"protocol,omitempty"`
	// Requested subdomain (optional)
	Subdomain string `protobuf:"bytes,3,opt,name=subdomain,proto3" json:"subdomain,omitempty"`
	// Custom hostname (for HTTP routing)
	Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Path prefix for HTTP routing (optional).
	PathPrefix string `protobuf:"bytes,5,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	// contains filtered or unexported fields
}

RegisterRequest is sent by client to register a tunnel.

func (*RegisterRequest) Descriptor deprecated

func (*RegisterRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetHostname

func (x *RegisterRequest) GetHostname() string

func (*RegisterRequest) GetLocalPort

func (x *RegisterRequest) GetLocalPort() uint32

func (*RegisterRequest) GetPathPrefix

func (x *RegisterRequest) GetPathPrefix() string

func (*RegisterRequest) GetProtocol

func (x *RegisterRequest) GetProtocol() Protocol

func (*RegisterRequest) GetSubdomain

func (x *RegisterRequest) GetSubdomain() string

func (*RegisterRequest) ProtoMessage

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect

func (x *RegisterRequest) ProtoReflect() protoreflect.Message

func (*RegisterRequest) Reset

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String

func (x *RegisterRequest) String() string

type RegisterResponse

type RegisterResponse struct {

	// Whether registration succeeded
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if failed
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Assigned tunnel ID
	TunnelId string `protobuf:"bytes,3,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Public URL for the tunnel
	PublicUrl string `protobuf:"bytes,4,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	// Assigned TCP port (for TCP tunnels)
	TcpPort uint32 `protobuf:"varint,5,opt,name=tcp_port,json=tcpPort,proto3" json:"tcp_port,omitempty"`
	// contains filtered or unexported fields
}

RegisterResponse is sent by server after tunnel registration.

func (*RegisterResponse) Descriptor deprecated

func (*RegisterResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetError

func (x *RegisterResponse) GetError() string

func (*RegisterResponse) GetPublicUrl

func (x *RegisterResponse) GetPublicUrl() string

func (*RegisterResponse) GetSuccess

func (x *RegisterResponse) GetSuccess() bool

func (*RegisterResponse) GetTcpPort

func (x *RegisterResponse) GetTcpPort() uint32

func (*RegisterResponse) GetTunnelId

func (x *RegisterResponse) GetTunnelId() string

func (*RegisterResponse) ProtoMessage

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect

func (x *RegisterResponse) ProtoReflect() protoreflect.Message

func (*RegisterResponse) Reset

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String

func (x *RegisterResponse) String() string

type StatsRequest

type StatsRequest struct {

	// Session ID to get stats for (empty for all)
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

StatsRequest requests statistics from the server.

func (*StatsRequest) Descriptor deprecated

func (*StatsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) GetSessionId

func (x *StatsRequest) GetSessionId() string

func (*StatsRequest) ProtoMessage

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect

func (x *StatsRequest) ProtoReflect() protoreflect.Message

func (*StatsRequest) Reset

func (x *StatsRequest) Reset()

func (*StatsRequest) String

func (x *StatsRequest) String() string

type StatsResponse

type StatsResponse struct {

	// Number of active tunnels
	ActiveTunnels uint32 `protobuf:"varint,1,opt,name=active_tunnels,json=activeTunnels,proto3" json:"active_tunnels,omitempty"`
	// Number of active connections
	ActiveConnections uint32 `protobuf:"varint,2,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
	// Total bytes sent
	BytesSent uint64 `protobuf:"varint,3,opt,name=bytes_sent,json=bytesSent,proto3" json:"bytes_sent,omitempty"`
	// Total bytes received
	BytesReceived uint64 `protobuf:"varint,4,opt,name=bytes_received,json=bytesReceived,proto3" json:"bytes_received,omitempty"`
	// Number of requests handled
	RequestsHandled uint64 `protobuf:"varint,5,opt,name=requests_handled,json=requestsHandled,proto3" json:"requests_handled,omitempty"`
	// Uptime in seconds
	UptimeSeconds uint64 `protobuf:"varint,6,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"`
	// contains filtered or unexported fields
}

StatsResponse contains statistics.

func (*StatsResponse) Descriptor deprecated

func (*StatsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetActiveConnections

func (x *StatsResponse) GetActiveConnections() uint32

func (*StatsResponse) GetActiveTunnels

func (x *StatsResponse) GetActiveTunnels() uint32

func (*StatsResponse) GetBytesReceived

func (x *StatsResponse) GetBytesReceived() uint64

func (*StatsResponse) GetBytesSent

func (x *StatsResponse) GetBytesSent() uint64

func (*StatsResponse) GetRequestsHandled

func (x *StatsResponse) GetRequestsHandled() uint64

func (*StatsResponse) GetUptimeSeconds

func (x *StatsResponse) GetUptimeSeconds() uint64

func (*StatsResponse) ProtoMessage

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect

func (x *StatsResponse) ProtoReflect() protoreflect.Message

func (*StatsResponse) Reset

func (x *StatsResponse) Reset()

func (*StatsResponse) String

func (x *StatsResponse) String() string

type StreamRequest

type StreamRequest struct {

	// Tunnel ID this stream belongs to
	TunnelId string `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// Request ID for correlation
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Remote address of the incoming connection
	RemoteAddr string `protobuf:"bytes,3,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	// Protocol of the incoming request
	Protocol Protocol `protobuf:"varint,4,opt,name=protocol,proto3,enum=wormhole.Protocol" json:"protocol,omitempty"`
	// HTTP-specific metadata
	HttpMetadata *HttpMetadata `protobuf:"bytes,5,opt,name=http_metadata,json=httpMetadata,proto3" json:"http_metadata,omitempty"`
	// contains filtered or unexported fields
}

StreamRequest is sent to initiate a new stream.

func (*StreamRequest) Descriptor deprecated

func (*StreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetHttpMetadata

func (x *StreamRequest) GetHttpMetadata() *HttpMetadata

func (*StreamRequest) GetProtocol

func (x *StreamRequest) GetProtocol() Protocol

func (*StreamRequest) GetRemoteAddr

func (x *StreamRequest) GetRemoteAddr() string

func (*StreamRequest) GetRequestId

func (x *StreamRequest) GetRequestId() string

func (*StreamRequest) GetTunnelId

func (x *StreamRequest) GetTunnelId() string

func (*StreamRequest) ProtoMessage

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect

func (x *StreamRequest) ProtoReflect() protoreflect.Message

func (*StreamRequest) Reset

func (x *StreamRequest) Reset()

func (*StreamRequest) String

func (x *StreamRequest) String() string

type StreamResponse

type StreamResponse struct {

	// Request ID for correlation
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Whether the stream was accepted
	Accepted bool `protobuf:"varint,2,opt,name=accepted,proto3" json:"accepted,omitempty"`
	// Error message if rejected
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

StreamResponse is the response to a stream request.

func (*StreamResponse) Descriptor deprecated

func (*StreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetAccepted

func (x *StreamResponse) GetAccepted() bool

func (*StreamResponse) GetError

func (x *StreamResponse) GetError() string

func (*StreamResponse) GetRequestId

func (x *StreamResponse) GetRequestId() string

func (*StreamResponse) ProtoMessage

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect

func (x *StreamResponse) ProtoReflect() protoreflect.Message

func (*StreamResponse) Reset

func (x *StreamResponse) Reset()

func (*StreamResponse) String

func (x *StreamResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL