Documentation
¶
Index ¶
- Variables
- type AuthRequest
- func (*AuthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthRequest) GetCapabilities() []string
- func (x *AuthRequest) GetSubdomain() string
- func (x *AuthRequest) GetToken() string
- func (x *AuthRequest) GetVersion() string
- func (*AuthRequest) ProtoMessage()
- func (x *AuthRequest) ProtoReflect() protoreflect.Message
- func (x *AuthRequest) Reset()
- func (x *AuthRequest) String() string
- type AuthResponse
- func (*AuthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthResponse) GetCapabilities() []string
- func (x *AuthResponse) GetError() string
- func (x *AuthResponse) GetPublicUrl() string
- func (x *AuthResponse) GetSessionId() string
- func (x *AuthResponse) GetSubdomain() string
- func (x *AuthResponse) GetSuccess() bool
- func (x *AuthResponse) GetTcpPort() uint32
- func (*AuthResponse) ProtoMessage()
- func (x *AuthResponse) ProtoReflect() protoreflect.Message
- func (x *AuthResponse) Reset()
- func (x *AuthResponse) String() string
- type CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseRequest) GetReason() string
- func (x *CloseRequest) GetTunnelId() string
- func (*CloseRequest) ProtoMessage()
- func (x *CloseRequest) ProtoReflect() protoreflect.Message
- func (x *CloseRequest) Reset()
- func (x *CloseRequest) String() string
- type CloseResponse
- type ControlMessage
- func (*ControlMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ControlMessage) GetAuthRequest() *AuthRequest
- func (x *ControlMessage) GetAuthResponse() *AuthResponse
- func (x *ControlMessage) GetCloseRequest() *CloseRequest
- func (x *ControlMessage) GetCloseResponse() *CloseResponse
- func (x *ControlMessage) GetP2PCandidates() *P2PCandidates
- func (x *ControlMessage) GetP2POfferRequest() *P2POfferRequest
- func (x *ControlMessage) GetP2POfferResponse() *P2POfferResponse
- func (x *ControlMessage) GetP2PResult() *P2PResult
- func (x *ControlMessage) GetPayload() isControlMessage_Payload
- func (x *ControlMessage) GetPingRequest() *PingRequest
- func (x *ControlMessage) GetPingResponse() *PingResponse
- func (x *ControlMessage) GetRegisterRequest() *RegisterRequest
- func (x *ControlMessage) GetRegisterResponse() *RegisterResponse
- func (x *ControlMessage) GetSequence() uint64
- func (x *ControlMessage) GetStatsRequest() *StatsRequest
- func (x *ControlMessage) GetStatsResponse() *StatsResponse
- func (x *ControlMessage) GetStreamRequest() *StreamRequest
- func (x *ControlMessage) GetStreamResponse() *StreamResponse
- func (x *ControlMessage) GetType() MessageType
- func (*ControlMessage) ProtoMessage()
- func (x *ControlMessage) ProtoReflect() protoreflect.Message
- func (x *ControlMessage) Reset()
- func (x *ControlMessage) String() string
- type ControlMessage_AuthRequest
- type ControlMessage_AuthResponse
- type ControlMessage_CloseRequest
- type ControlMessage_CloseResponse
- type ControlMessage_P2PCandidates
- type ControlMessage_P2POfferRequest
- type ControlMessage_P2POfferResponse
- type ControlMessage_P2PResult
- type ControlMessage_PingRequest
- type ControlMessage_PingResponse
- type ControlMessage_RegisterRequest
- type ControlMessage_RegisterResponse
- type ControlMessage_StatsRequest
- type ControlMessage_StatsResponse
- type ControlMessage_StreamRequest
- type ControlMessage_StreamResponse
- type HttpMetadata
- func (*HttpMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *HttpMetadata) GetContentLength() int64
- func (x *HttpMetadata) GetContentType() string
- func (x *HttpMetadata) GetHost() string
- func (x *HttpMetadata) GetMethod() string
- func (x *HttpMetadata) GetUri() string
- func (*HttpMetadata) ProtoMessage()
- func (x *HttpMetadata) ProtoReflect() protoreflect.Message
- func (x *HttpMetadata) Reset()
- func (x *HttpMetadata) String() string
- type MessageType
- func (MessageType) Descriptor() protoreflect.EnumDescriptor
- func (x MessageType) Enum() *MessageType
- func (MessageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageType) Number() protoreflect.EnumNumber
- func (x MessageType) String() string
- func (MessageType) Type() protoreflect.EnumType
- type P2PCandidates
- func (*P2PCandidates) Descriptor() ([]byte, []int)deprecated
- func (x *P2PCandidates) GetCandidates() []string
- func (x *P2PCandidates) GetTunnelId() string
- func (*P2PCandidates) ProtoMessage()
- func (x *P2PCandidates) ProtoReflect() protoreflect.Message
- func (x *P2PCandidates) Reset()
- func (x *P2PCandidates) String() string
- type P2POfferRequest
- func (*P2POfferRequest) Descriptor() ([]byte, []int)deprecated
- func (x *P2POfferRequest) GetLocalAddr() string
- func (x *P2POfferRequest) GetNatType() string
- func (x *P2POfferRequest) GetPublicAddr() string
- func (x *P2POfferRequest) GetPublicKey() string
- func (x *P2POfferRequest) GetTunnelId() string
- func (*P2POfferRequest) ProtoMessage()
- func (x *P2POfferRequest) ProtoReflect() protoreflect.Message
- func (x *P2POfferRequest) Reset()
- func (x *P2POfferRequest) String() string
- type P2POfferResponse
- func (*P2POfferResponse) Descriptor() ([]byte, []int)deprecated
- func (x *P2POfferResponse) GetError() string
- func (x *P2POfferResponse) GetPeerAddr() string
- func (x *P2POfferResponse) GetPeerNatType() string
- func (x *P2POfferResponse) GetPeerPublicKey() string
- func (x *P2POfferResponse) GetSuccess() bool
- func (*P2POfferResponse) ProtoMessage()
- func (x *P2POfferResponse) ProtoReflect() protoreflect.Message
- func (x *P2POfferResponse) Reset()
- func (x *P2POfferResponse) String() string
- type P2PResult
- func (*P2PResult) Descriptor() ([]byte, []int)deprecated
- func (x *P2PResult) GetError() string
- func (x *P2PResult) GetPeerAddr() string
- func (x *P2PResult) GetSuccess() bool
- func (x *P2PResult) GetTunnelId() string
- func (*P2PResult) ProtoMessage()
- func (x *P2PResult) ProtoReflect() protoreflect.Message
- func (x *P2PResult) Reset()
- func (x *P2PResult) String() string
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PingRequest) GetPingId() uint64
- func (x *PingRequest) GetTimestamp() int64
- func (*PingRequest) ProtoMessage()
- func (x *PingRequest) ProtoReflect() protoreflect.Message
- func (x *PingRequest) Reset()
- func (x *PingRequest) String() string
- type PingResponse
- func (*PingResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingResponse) GetPingId() uint64
- func (x *PingResponse) GetTimestamp() int64
- func (*PingResponse) ProtoMessage()
- func (x *PingResponse) ProtoReflect() protoreflect.Message
- func (x *PingResponse) Reset()
- func (x *PingResponse) String() string
- type Protocol
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRequest) GetHostname() string
- func (x *RegisterRequest) GetLocalPort() uint32
- func (x *RegisterRequest) GetPathPrefix() string
- func (x *RegisterRequest) GetProtocol() Protocol
- func (x *RegisterRequest) GetSubdomain() string
- func (*RegisterRequest) ProtoMessage()
- func (x *RegisterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRequest) Reset()
- func (x *RegisterRequest) String() string
- type RegisterResponse
- func (*RegisterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterResponse) GetError() string
- func (x *RegisterResponse) GetPublicUrl() string
- func (x *RegisterResponse) GetSuccess() bool
- func (x *RegisterResponse) GetTcpPort() uint32
- func (x *RegisterResponse) GetTunnelId() string
- func (*RegisterResponse) ProtoMessage()
- func (x *RegisterResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterResponse) Reset()
- func (x *RegisterResponse) String() string
- type StatsRequest
- type StatsResponse
- func (*StatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatsResponse) GetActiveConnections() uint32
- func (x *StatsResponse) GetActiveTunnels() uint32
- func (x *StatsResponse) GetBytesReceived() uint64
- func (x *StatsResponse) GetBytesSent() uint64
- func (x *StatsResponse) GetRequestsHandled() uint64
- func (x *StatsResponse) GetUptimeSeconds() uint64
- func (*StatsResponse) ProtoMessage()
- func (x *StatsResponse) ProtoReflect() protoreflect.Message
- func (x *StatsResponse) Reset()
- func (x *StatsResponse) String() string
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest) GetHttpMetadata() *HttpMetadata
- func (x *StreamRequest) GetProtocol() Protocol
- func (x *StreamRequest) GetRemoteAddr() string
- func (x *StreamRequest) GetRequestId() string
- func (x *StreamRequest) GetTunnelId() string
- func (*StreamRequest) ProtoMessage()
- func (x *StreamRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRequest) Reset()
- func (x *StreamRequest) String() string
- type StreamResponse
- func (*StreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamResponse) GetAccepted() bool
- func (x *StreamResponse) GetError() string
- func (x *StreamResponse) GetRequestId() string
- func (*StreamResponse) ProtoMessage()
- func (x *StreamResponse) ProtoReflect() protoreflect.Message
- func (x *StreamResponse) Reset()
- func (x *StreamResponse) String() string
Constants ¶
This section is empty.
Variables ¶
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.
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.
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) Descriptor() protoreflect.EnumDescriptor
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 ¶
func (MessageType) Type() protoreflect.EnumType
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) GetPeerAddr ¶
func (*P2PResult) GetSuccess ¶
func (*P2PResult) GetTunnelId ¶
func (*P2PResult) ProtoMessage ¶
func (*P2PResult) ProtoMessage()
func (*P2PResult) ProtoReflect ¶
func (x *P2PResult) ProtoReflect() protoreflect.Message
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.
func (Protocol) Descriptor ¶
func (Protocol) Descriptor() protoreflect.EnumDescriptor
func (Protocol) EnumDescriptor
deprecated
func (Protocol) Number ¶
func (x Protocol) Number() protoreflect.EnumNumber
func (Protocol) Type ¶
func (Protocol) Type() protoreflect.EnumType
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