tpb

package
v1.3.4-alpha0725 Latest Latest
Warning

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

Go to latest
Published: Jul 24, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DNSLog_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tpb.DNSLog",
	HandlerType: (*DNSLogServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RequireDomain",
			Handler:    _DNSLog_RequireDomain_Handler,
		},
		{
			MethodName: "QueryExistedDNSLog",
			Handler:    _DNSLog_QueryExistedDNSLog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tunnel.proto",
}

DNSLog_ServiceDesc is the grpc.ServiceDesc for DNSLog service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_tunnel_proto protoreflect.FileDescriptor
View Source
var Tunnel_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tpb.Tunnel",
	HandlerType: (*TunnelServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RemoteIP",
			Handler:    _Tunnel_RemoteIP_Handler,
		},
		{
			MethodName: "RegisterTunnel",
			Handler:    _Tunnel_RegisterTunnel_Handler,
		},
		{
			MethodName: "GetAllRegisteredTunnel",
			Handler:    _Tunnel_GetAllRegisteredTunnel_Handler,
		},
		{
			MethodName: "GetRegisteredTunnelDescriptionByID",
			Handler:    _Tunnel_GetRegisteredTunnelDescriptionByID_Handler,
		},
		{
			MethodName: "RequireRandomPortTrigger",
			Handler:    _Tunnel_RequireRandomPortTrigger_Handler,
		},
		{
			MethodName: "QueryExistedRandomPortTrigger",
			Handler:    _Tunnel_QueryExistedRandomPortTrigger_Handler,
		},
		{
			MethodName: "QuerySpecificICMPLengthTrigger",
			Handler:    _Tunnel_QuerySpecificICMPLengthTrigger_Handler,
		},
		{
			MethodName: "RequireHTTPRequestTrigger",
			Handler:    _Tunnel_RequireHTTPRequestTrigger_Handler,
		},
		{
			MethodName: "QueryExistedHTTPRequestTrigger",
			Handler:    _Tunnel_QueryExistedHTTPRequestTrigger_Handler,
		},
		{
			MethodName: "CheckServerReachable",
			Handler:    _Tunnel_CheckServerReachable_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateTunnel",
			Handler:       _Tunnel_CreateTunnel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "tunnel.proto",
}

Tunnel_ServiceDesc is the grpc.ServiceDesc for Tunnel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterDNSLogServer

func RegisterDNSLogServer(s grpc.ServiceRegistrar, srv DNSLogServer)

func RegisterTunnelServer

func RegisterTunnelServer(s grpc.ServiceRegistrar, srv TunnelServer)

Types

type CheckServerReachableRequest

type CheckServerReachableRequest struct {
	Url       string `protobuf:"bytes,1,opt,name=Url,proto3" json:"Url,omitempty"`
	HttpCheck bool   `protobuf:"varint,2,opt,name=HttpCheck,proto3" json:"HttpCheck,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckServerReachableRequest) Descriptor deprecated

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

Deprecated: Use CheckServerReachableRequest.ProtoReflect.Descriptor instead.

func (*CheckServerReachableRequest) GetHttpCheck

func (x *CheckServerReachableRequest) GetHttpCheck() bool

func (*CheckServerReachableRequest) GetUrl

func (x *CheckServerReachableRequest) GetUrl() string

func (*CheckServerReachableRequest) ProtoMessage

func (*CheckServerReachableRequest) ProtoMessage()

func (*CheckServerReachableRequest) ProtoReflect

func (*CheckServerReachableRequest) Reset

func (x *CheckServerReachableRequest) Reset()

func (*CheckServerReachableRequest) String

func (x *CheckServerReachableRequest) String() string

type CheckServerReachableResponse

type CheckServerReachableResponse struct {
	Reachable    bool   `protobuf:"varint,1,opt,name=Reachable,proto3" json:"Reachable,omitempty"`
	Verbose      string `protobuf:"bytes,2,opt,name=Verbose,proto3" json:"Verbose,omitempty"`
	HTTPResponse []byte `protobuf:"bytes,3,opt,name=HTTPResponse,proto3" json:"HTTPResponse,omitempty"`
	HTTPRequest  []byte `protobuf:"bytes,4,opt,name=HTTPRequest,proto3" json:"HTTPRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckServerReachableResponse) Descriptor deprecated

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

Deprecated: Use CheckServerReachableResponse.ProtoReflect.Descriptor instead.

func (*CheckServerReachableResponse) GetHTTPRequest

func (x *CheckServerReachableResponse) GetHTTPRequest() []byte

func (*CheckServerReachableResponse) GetHTTPResponse

func (x *CheckServerReachableResponse) GetHTTPResponse() []byte

func (*CheckServerReachableResponse) GetReachable

func (x *CheckServerReachableResponse) GetReachable() bool

func (*CheckServerReachableResponse) GetVerbose

func (x *CheckServerReachableResponse) GetVerbose() string

func (*CheckServerReachableResponse) ProtoMessage

func (*CheckServerReachableResponse) ProtoMessage()

func (*CheckServerReachableResponse) ProtoReflect

func (*CheckServerReachableResponse) Reset

func (x *CheckServerReachableResponse) Reset()

func (*CheckServerReachableResponse) String

type DNSLogClient

type DNSLogClient interface {
	RequireDomain(ctx context.Context, in *RequireDomainParams, opts ...grpc.CallOption) (*RequireDomainResponse, error)
	QueryExistedDNSLog(ctx context.Context, in *QueryExistedDNSLogParams, opts ...grpc.CallOption) (*QueryExistedDNSLogResponse, error)
}

DNSLogClient is the client API for DNSLog service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDNSLogClient

func NewDNSLogClient(cc grpc.ClientConnInterface) DNSLogClient

type DNSLogEvent

type DNSLogEvent struct {
	Type       string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Token      string `protobuf:"bytes,2,opt,name=Token,proto3" json:"Token,omitempty"`
	Domain     string `protobuf:"bytes,3,opt,name=Domain,proto3" json:"Domain,omitempty"`
	RemoteAddr string `protobuf:"bytes,4,opt,name=RemoteAddr,proto3" json:"RemoteAddr,omitempty"`
	RemoteIP   string `protobuf:"bytes,5,opt,name=RemoteIP,proto3" json:"RemoteIP,omitempty"`
	RemotePort int32  `protobuf:"varint,6,opt,name=RemotePort,proto3" json:"RemotePort,omitempty"`
	Raw        []byte `protobuf:"bytes,7,opt,name=Raw,proto3" json:"Raw,omitempty"`
	Timestamp  int64  `protobuf:"varint,8,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Mode       string `protobuf:"bytes,9,opt,name=Mode,proto3" json:"Mode,omitempty"`
	// contains filtered or unexported fields
}

func (*DNSLogEvent) Descriptor deprecated

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

Deprecated: Use DNSLogEvent.ProtoReflect.Descriptor instead.

func (*DNSLogEvent) GetDomain

func (x *DNSLogEvent) GetDomain() string

func (*DNSLogEvent) GetMode added in v1.2.4

func (x *DNSLogEvent) GetMode() string

func (*DNSLogEvent) GetRaw

func (x *DNSLogEvent) GetRaw() []byte

func (*DNSLogEvent) GetRemoteAddr

func (x *DNSLogEvent) GetRemoteAddr() string

func (*DNSLogEvent) GetRemoteIP

func (x *DNSLogEvent) GetRemoteIP() string

func (*DNSLogEvent) GetRemotePort

func (x *DNSLogEvent) GetRemotePort() int32

func (*DNSLogEvent) GetTimestamp

func (x *DNSLogEvent) GetTimestamp() int64

func (*DNSLogEvent) GetToken

func (x *DNSLogEvent) GetToken() string

func (*DNSLogEvent) GetType

func (x *DNSLogEvent) GetType() string

func (*DNSLogEvent) ProtoMessage

func (*DNSLogEvent) ProtoMessage()

func (*DNSLogEvent) ProtoReflect

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

func (*DNSLogEvent) Reset

func (x *DNSLogEvent) Reset()

func (*DNSLogEvent) String

func (x *DNSLogEvent) String() string

type DNSLogServer

type DNSLogServer interface {
	RequireDomain(context.Context, *RequireDomainParams) (*RequireDomainResponse, error)
	QueryExistedDNSLog(context.Context, *QueryExistedDNSLogParams) (*QueryExistedDNSLogResponse, error)
	// contains filtered or unexported methods
}

DNSLogServer is the server API for DNSLog service. All implementations must embed UnimplementedDNSLogServer for forward compatibility

type Empty

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type GetAllRegisteredTunnelRequest

type GetAllRegisteredTunnelRequest struct {

	// 二级密码
	SecondaryPassword string `protobuf:"bytes,5,opt,name=SecondaryPassword,proto3" json:"SecondaryPassword,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllRegisteredTunnelRequest) Descriptor deprecated

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

Deprecated: Use GetAllRegisteredTunnelRequest.ProtoReflect.Descriptor instead.

func (*GetAllRegisteredTunnelRequest) GetSecondaryPassword

func (x *GetAllRegisteredTunnelRequest) GetSecondaryPassword() string

func (*GetAllRegisteredTunnelRequest) ProtoMessage

func (*GetAllRegisteredTunnelRequest) ProtoMessage()

func (*GetAllRegisteredTunnelRequest) ProtoReflect

func (*GetAllRegisteredTunnelRequest) Reset

func (x *GetAllRegisteredTunnelRequest) Reset()

func (*GetAllRegisteredTunnelRequest) String

type GetAllRegisteredTunnelResponse

type GetAllRegisteredTunnelResponse struct {
	Tunnels []*RegisterTunnelMeta `protobuf:"bytes,1,rep,name=Tunnels,proto3" json:"Tunnels,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllRegisteredTunnelResponse) Descriptor deprecated

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

Deprecated: Use GetAllRegisteredTunnelResponse.ProtoReflect.Descriptor instead.

func (*GetAllRegisteredTunnelResponse) GetTunnels

func (*GetAllRegisteredTunnelResponse) ProtoMessage

func (*GetAllRegisteredTunnelResponse) ProtoMessage()

func (*GetAllRegisteredTunnelResponse) ProtoReflect

func (*GetAllRegisteredTunnelResponse) Reset

func (x *GetAllRegisteredTunnelResponse) Reset()

func (*GetAllRegisteredTunnelResponse) String

type GetRegisteredTunnelDescriptionByIDRequest

type GetRegisteredTunnelDescriptionByIDRequest struct {
	Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	// 二级密码
	SecondaryPassword string `protobuf:"bytes,2,opt,name=SecondaryPassword,proto3" json:"SecondaryPassword,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegisteredTunnelDescriptionByIDRequest) Descriptor deprecated

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

Deprecated: Use GetRegisteredTunnelDescriptionByIDRequest.ProtoReflect.Descriptor instead.

func (*GetRegisteredTunnelDescriptionByIDRequest) GetId

func (*GetRegisteredTunnelDescriptionByIDRequest) GetSecondaryPassword

func (x *GetRegisteredTunnelDescriptionByIDRequest) GetSecondaryPassword() string

func (*GetRegisteredTunnelDescriptionByIDRequest) ProtoMessage

func (*GetRegisteredTunnelDescriptionByIDRequest) ProtoReflect

func (*GetRegisteredTunnelDescriptionByIDRequest) Reset

func (*GetRegisteredTunnelDescriptionByIDRequest) String

type HTTPRequestTriggerNotification added in v1.3.3

type HTTPRequestTriggerNotification struct {
	Url              string `protobuf:"bytes,1,opt,name=Url,proto3" json:"Url,omitempty"`
	RemoteAddr       string `protobuf:"bytes,2,opt,name=RemoteAddr,proto3" json:"RemoteAddr,omitempty"`
	IsHttps          bool   `protobuf:"varint,3,opt,name=IsHttps,proto3" json:"IsHttps,omitempty"`
	TriggerTimestamp int64  `protobuf:"varint,4,opt,name=TriggerTimestamp,proto3" json:"TriggerTimestamp,omitempty"`
	Timestamp        int64  `protobuf:"varint,5,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Request          []byte `protobuf:"bytes,6,opt,name=Request,proto3" json:"Request,omitempty"`
	Response         []byte `protobuf:"bytes,7,opt,name=Response,proto3" json:"Response,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPRequestTriggerNotification) Descriptor deprecated added in v1.3.3

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

Deprecated: Use HTTPRequestTriggerNotification.ProtoReflect.Descriptor instead.

func (*HTTPRequestTriggerNotification) GetIsHttps added in v1.3.3

func (x *HTTPRequestTriggerNotification) GetIsHttps() bool

func (*HTTPRequestTriggerNotification) GetRemoteAddr added in v1.3.3

func (x *HTTPRequestTriggerNotification) GetRemoteAddr() string

func (*HTTPRequestTriggerNotification) GetRequest added in v1.3.3

func (x *HTTPRequestTriggerNotification) GetRequest() []byte

func (*HTTPRequestTriggerNotification) GetResponse added in v1.3.3

func (x *HTTPRequestTriggerNotification) GetResponse() []byte

func (*HTTPRequestTriggerNotification) GetTimestamp added in v1.3.3

func (x *HTTPRequestTriggerNotification) GetTimestamp() int64

func (*HTTPRequestTriggerNotification) GetTriggerTimestamp added in v1.3.3

func (x *HTTPRequestTriggerNotification) GetTriggerTimestamp() int64

func (*HTTPRequestTriggerNotification) GetUrl added in v1.3.3

func (*HTTPRequestTriggerNotification) ProtoMessage added in v1.3.3

func (*HTTPRequestTriggerNotification) ProtoMessage()

func (*HTTPRequestTriggerNotification) ProtoReflect added in v1.3.3

func (*HTTPRequestTriggerNotification) Reset added in v1.3.3

func (x *HTTPRequestTriggerNotification) Reset()

func (*HTTPRequestTriggerNotification) String added in v1.3.3

type ICMPTriggerNotification

type ICMPTriggerNotification struct {
	Size                               int32    `protobuf:"varint,1,opt,name=Size,proto3" json:"Size,omitempty"`
	CurrentRemoteAddr                  string   `protobuf:"bytes,2,opt,name=CurrentRemoteAddr,proto3" json:"CurrentRemoteAddr,omitempty"`
	Histories                          []string `protobuf:"bytes,3,rep,name=Histories,proto3" json:"Histories,omitempty"`
	CurrentRemoteCachedConnectionCount int32    `protobuf:"varint,4,opt,name=CurrentRemoteCachedConnectionCount,proto3" json:"CurrentRemoteCachedConnectionCount,omitempty"`
	SizeCachedHistoryConnectionCount   int32    `protobuf:"varint,5,opt,name=SizeCachedHistoryConnectionCount,proto3" json:"SizeCachedHistoryConnectionCount,omitempty"`
	TriggerTimestamp                   int64    `protobuf:"varint,6,opt,name=TriggerTimestamp,proto3" json:"TriggerTimestamp,omitempty"`
	Timestamp                          int64    `protobuf:"varint,7,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ICMPTriggerNotification) Descriptor deprecated

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

Deprecated: Use ICMPTriggerNotification.ProtoReflect.Descriptor instead.

func (*ICMPTriggerNotification) GetCurrentRemoteAddr

func (x *ICMPTriggerNotification) GetCurrentRemoteAddr() string

func (*ICMPTriggerNotification) GetCurrentRemoteCachedConnectionCount

func (x *ICMPTriggerNotification) GetCurrentRemoteCachedConnectionCount() int32

func (*ICMPTriggerNotification) GetHistories

func (x *ICMPTriggerNotification) GetHistories() []string

func (*ICMPTriggerNotification) GetSize

func (x *ICMPTriggerNotification) GetSize() int32

func (*ICMPTriggerNotification) GetSizeCachedHistoryConnectionCount

func (x *ICMPTriggerNotification) GetSizeCachedHistoryConnectionCount() int32

func (*ICMPTriggerNotification) GetTimestamp

func (x *ICMPTriggerNotification) GetTimestamp() int64

func (*ICMPTriggerNotification) GetTriggerTimestamp

func (x *ICMPTriggerNotification) GetTriggerTimestamp() int64

func (*ICMPTriggerNotification) ProtoMessage

func (*ICMPTriggerNotification) ProtoMessage()

func (*ICMPTriggerNotification) ProtoReflect

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

func (*ICMPTriggerNotification) Reset

func (x *ICMPTriggerNotification) Reset()

func (*ICMPTriggerNotification) String

func (x *ICMPTriggerNotification) String() string

type Mirror

type Mirror struct {
	Id      string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Port    int32  `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	Network string `protobuf:"bytes,3,opt,name=Network,proto3" json:"Network,omitempty"`
	// contains filtered or unexported fields
}

func (*Mirror) Descriptor deprecated

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

Deprecated: Use Mirror.ProtoReflect.Descriptor instead.

func (*Mirror) GetId

func (x *Mirror) GetId() string

func (*Mirror) GetNetwork

func (x *Mirror) GetNetwork() string

func (*Mirror) GetPort

func (x *Mirror) GetPort() int32

func (*Mirror) ProtoMessage

func (*Mirror) ProtoMessage()

func (*Mirror) ProtoReflect

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

func (*Mirror) Reset

func (x *Mirror) Reset()

func (*Mirror) String

func (x *Mirror) String() string

type QueryExistedDNSLogParams

type QueryExistedDNSLogParams struct {
	Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	Mode  string `protobuf:"bytes,2,opt,name=Mode,proto3" json:"Mode,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExistedDNSLogParams) Descriptor deprecated

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

Deprecated: Use QueryExistedDNSLogParams.ProtoReflect.Descriptor instead.

func (*QueryExistedDNSLogParams) GetMode added in v1.2.4

func (x *QueryExistedDNSLogParams) GetMode() string

func (*QueryExistedDNSLogParams) GetToken

func (x *QueryExistedDNSLogParams) GetToken() string

func (*QueryExistedDNSLogParams) ProtoMessage

func (*QueryExistedDNSLogParams) ProtoMessage()

func (*QueryExistedDNSLogParams) ProtoReflect

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

func (*QueryExistedDNSLogParams) Reset

func (x *QueryExistedDNSLogParams) Reset()

func (*QueryExistedDNSLogParams) String

func (x *QueryExistedDNSLogParams) String() string

type QueryExistedDNSLogResponse

type QueryExistedDNSLogResponse struct {
	Events []*DNSLogEvent `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExistedDNSLogResponse) Descriptor deprecated

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

Deprecated: Use QueryExistedDNSLogResponse.ProtoReflect.Descriptor instead.

func (*QueryExistedDNSLogResponse) GetEvents

func (x *QueryExistedDNSLogResponse) GetEvents() []*DNSLogEvent

func (*QueryExistedDNSLogResponse) ProtoMessage

func (*QueryExistedDNSLogResponse) ProtoMessage()

func (*QueryExistedDNSLogResponse) ProtoReflect

func (*QueryExistedDNSLogResponse) Reset

func (x *QueryExistedDNSLogResponse) Reset()

func (*QueryExistedDNSLogResponse) String

func (x *QueryExistedDNSLogResponse) String() string

type QueryExistedHTTPRequestTriggerRequest added in v1.3.3

type QueryExistedHTTPRequestTriggerRequest struct {
	Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExistedHTTPRequestTriggerRequest) Descriptor deprecated added in v1.3.3

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

Deprecated: Use QueryExistedHTTPRequestTriggerRequest.ProtoReflect.Descriptor instead.

func (*QueryExistedHTTPRequestTriggerRequest) GetToken added in v1.3.3

func (*QueryExistedHTTPRequestTriggerRequest) ProtoMessage added in v1.3.3

func (*QueryExistedHTTPRequestTriggerRequest) ProtoMessage()

func (*QueryExistedHTTPRequestTriggerRequest) ProtoReflect added in v1.3.3

func (*QueryExistedHTTPRequestTriggerRequest) Reset added in v1.3.3

func (*QueryExistedHTTPRequestTriggerRequest) String added in v1.3.3

type QueryExistedHTTPRequestTriggerResponse added in v1.3.3

type QueryExistedHTTPRequestTriggerResponse struct {
	Notifications []*HTTPRequestTriggerNotification `protobuf:"bytes,1,rep,name=Notifications,proto3" json:"Notifications,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExistedHTTPRequestTriggerResponse) Descriptor deprecated added in v1.3.3

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

Deprecated: Use QueryExistedHTTPRequestTriggerResponse.ProtoReflect.Descriptor instead.

func (*QueryExistedHTTPRequestTriggerResponse) GetNotifications added in v1.3.3

func (*QueryExistedHTTPRequestTriggerResponse) ProtoMessage added in v1.3.3

func (*QueryExistedHTTPRequestTriggerResponse) ProtoReflect added in v1.3.3

func (*QueryExistedHTTPRequestTriggerResponse) Reset added in v1.3.3

func (*QueryExistedHTTPRequestTriggerResponse) String added in v1.3.3

type QueryExistedRandomPortTriggerRequest

type QueryExistedRandomPortTriggerRequest struct {
	Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExistedRandomPortTriggerRequest) Descriptor deprecated

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

Deprecated: Use QueryExistedRandomPortTriggerRequest.ProtoReflect.Descriptor instead.

func (*QueryExistedRandomPortTriggerRequest) GetToken

func (*QueryExistedRandomPortTriggerRequest) ProtoMessage

func (*QueryExistedRandomPortTriggerRequest) ProtoMessage()

func (*QueryExistedRandomPortTriggerRequest) ProtoReflect

func (*QueryExistedRandomPortTriggerRequest) Reset

func (*QueryExistedRandomPortTriggerRequest) String

type QueryExistedRandomPortTriggerResponse

type QueryExistedRandomPortTriggerResponse struct {
	Events []*RandomPortTriggerEvent `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExistedRandomPortTriggerResponse) Descriptor deprecated

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

Deprecated: Use QueryExistedRandomPortTriggerResponse.ProtoReflect.Descriptor instead.

func (*QueryExistedRandomPortTriggerResponse) GetEvents

func (*QueryExistedRandomPortTriggerResponse) ProtoMessage

func (*QueryExistedRandomPortTriggerResponse) ProtoMessage()

func (*QueryExistedRandomPortTriggerResponse) ProtoReflect

func (*QueryExistedRandomPortTriggerResponse) Reset

func (*QueryExistedRandomPortTriggerResponse) String

type QuerySpecificICMPLengthTriggerParams

type QuerySpecificICMPLengthTriggerParams struct {
	Length int32 `protobuf:"varint,1,opt,name=Length,proto3" json:"Length,omitempty"`
	// contains filtered or unexported fields
}

func (*QuerySpecificICMPLengthTriggerParams) Descriptor deprecated

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

Deprecated: Use QuerySpecificICMPLengthTriggerParams.ProtoReflect.Descriptor instead.

func (*QuerySpecificICMPLengthTriggerParams) GetLength

func (*QuerySpecificICMPLengthTriggerParams) ProtoMessage

func (*QuerySpecificICMPLengthTriggerParams) ProtoMessage()

func (*QuerySpecificICMPLengthTriggerParams) ProtoReflect

func (*QuerySpecificICMPLengthTriggerParams) Reset

func (*QuerySpecificICMPLengthTriggerParams) String

type QuerySpecificICMPLengthTriggerResponse

type QuerySpecificICMPLengthTriggerResponse struct {
	Notifications []*ICMPTriggerNotification `protobuf:"bytes,1,rep,name=Notifications,proto3" json:"Notifications,omitempty"`
	// contains filtered or unexported fields
}

func (*QuerySpecificICMPLengthTriggerResponse) Descriptor deprecated

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

Deprecated: Use QuerySpecificICMPLengthTriggerResponse.ProtoReflect.Descriptor instead.

func (*QuerySpecificICMPLengthTriggerResponse) GetNotifications

func (*QuerySpecificICMPLengthTriggerResponse) ProtoMessage

func (*QuerySpecificICMPLengthTriggerResponse) ProtoReflect

func (*QuerySpecificICMPLengthTriggerResponse) Reset

func (*QuerySpecificICMPLengthTriggerResponse) String

type RandomPortTriggerEvent

type RandomPortTriggerEvent struct {
	RemoteAddr                            string   `protobuf:"bytes,1,opt,name=RemoteAddr,proto3" json:"RemoteAddr,omitempty"`
	RemoteIP                              string   `protobuf:"bytes,2,opt,name=RemoteIP,proto3" json:"RemoteIP,omitempty"`
	RemotePort                            int32    `protobuf:"varint,3,opt,name=RemotePort,proto3" json:"RemotePort,omitempty"`
	LocalPort                             int32    `protobuf:"varint,4,opt,name=LocalPort,proto3" json:"LocalPort,omitempty"`
	History                               []string `protobuf:"bytes,5,rep,name=History,proto3" json:"History,omitempty"`
	CurrentRemoteCachedConnectionCount    int32    `protobuf:"varint,6,opt,name=CurrentRemoteCachedConnectionCount,proto3" json:"CurrentRemoteCachedConnectionCount,omitempty"`
	LocalPortCachedHistoryConnectionCount int32    `` /* 128-byte string literal not displayed */
	TriggerTimestamp                      int64    `protobuf:"varint,8,opt,name=TriggerTimestamp,proto3" json:"TriggerTimestamp,omitempty"`
	Timestamp                             int64    `protobuf:"varint,9,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*RandomPortTriggerEvent) Descriptor deprecated

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

Deprecated: Use RandomPortTriggerEvent.ProtoReflect.Descriptor instead.

func (*RandomPortTriggerEvent) GetCurrentRemoteCachedConnectionCount

func (x *RandomPortTriggerEvent) GetCurrentRemoteCachedConnectionCount() int32

func (*RandomPortTriggerEvent) GetHistory

func (x *RandomPortTriggerEvent) GetHistory() []string

func (*RandomPortTriggerEvent) GetLocalPort

func (x *RandomPortTriggerEvent) GetLocalPort() int32

func (*RandomPortTriggerEvent) GetLocalPortCachedHistoryConnectionCount

func (x *RandomPortTriggerEvent) GetLocalPortCachedHistoryConnectionCount() int32

func (*RandomPortTriggerEvent) GetRemoteAddr

func (x *RandomPortTriggerEvent) GetRemoteAddr() string

func (*RandomPortTriggerEvent) GetRemoteIP

func (x *RandomPortTriggerEvent) GetRemoteIP() string

func (*RandomPortTriggerEvent) GetRemotePort

func (x *RandomPortTriggerEvent) GetRemotePort() int32

func (*RandomPortTriggerEvent) GetTimestamp

func (x *RandomPortTriggerEvent) GetTimestamp() int64

func (*RandomPortTriggerEvent) GetTriggerTimestamp

func (x *RandomPortTriggerEvent) GetTriggerTimestamp() int64

func (*RandomPortTriggerEvent) ProtoMessage

func (*RandomPortTriggerEvent) ProtoMessage()

func (*RandomPortTriggerEvent) ProtoReflect

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

func (*RandomPortTriggerEvent) Reset

func (x *RandomPortTriggerEvent) Reset()

func (*RandomPortTriggerEvent) String

func (x *RandomPortTriggerEvent) String() string

type RegisterTunnelMeta

type RegisterTunnelMeta struct {
	ConnectHost string `protobuf:"bytes,1,opt,name=ConnectHost,proto3" json:"ConnectHost,omitempty"`
	ConnectPort int64  `protobuf:"varint,2,opt,name=ConnectPort,proto3" json:"ConnectPort,omitempty"`
	Id          string `protobuf:"bytes,3,opt,name=Id,proto3" json:"Id,omitempty"`
	Verbose     string `protobuf:"bytes,4,opt,name=Verbose,proto3" json:"Verbose,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterTunnelMeta) Descriptor deprecated

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

Deprecated: Use RegisterTunnelMeta.ProtoReflect.Descriptor instead.

func (*RegisterTunnelMeta) GetConnectHost

func (x *RegisterTunnelMeta) GetConnectHost() string

func (*RegisterTunnelMeta) GetConnectPort

func (x *RegisterTunnelMeta) GetConnectPort() int64

func (*RegisterTunnelMeta) GetId

func (x *RegisterTunnelMeta) GetId() string

func (*RegisterTunnelMeta) GetVerbose

func (x *RegisterTunnelMeta) GetVerbose() string

func (*RegisterTunnelMeta) ProtoMessage

func (*RegisterTunnelMeta) ProtoMessage()

func (*RegisterTunnelMeta) ProtoReflect

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

func (*RegisterTunnelMeta) Reset

func (x *RegisterTunnelMeta) Reset()

func (*RegisterTunnelMeta) String

func (x *RegisterTunnelMeta) String() string

type RegisterTunnelRequest

type RegisterTunnelRequest struct {
	PublicKeyPEM []byte `protobuf:"bytes,1,opt,name=PublicKeyPEM,proto3" json:"PublicKeyPEM,omitempty"`
	Secret       string `protobuf:"bytes,2,opt,name=Secret,proto3" json:"Secret,omitempty"`
	// 用来描述 Tunnel 携带信息的,比如想要测试的机器名或者测试的内容之类的
	Verbose string `protobuf:"bytes,3,opt,name=Verbose,proto3" json:"Verbose,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterTunnelRequest) Descriptor deprecated

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

Deprecated: Use RegisterTunnelRequest.ProtoReflect.Descriptor instead.

func (*RegisterTunnelRequest) GetPublicKeyPEM

func (x *RegisterTunnelRequest) GetPublicKeyPEM() []byte

func (*RegisterTunnelRequest) GetSecret

func (x *RegisterTunnelRequest) GetSecret() string

func (*RegisterTunnelRequest) GetVerbose

func (x *RegisterTunnelRequest) GetVerbose() string

func (*RegisterTunnelRequest) ProtoMessage

func (*RegisterTunnelRequest) ProtoMessage()

func (*RegisterTunnelRequest) ProtoReflect

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

func (*RegisterTunnelRequest) Reset

func (x *RegisterTunnelRequest) Reset()

func (*RegisterTunnelRequest) String

func (x *RegisterTunnelRequest) String() string

type RegisterTunnelResponse

type RegisterTunnelResponse struct {
	Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterTunnelResponse) Descriptor deprecated

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

Deprecated: Use RegisterTunnelResponse.ProtoReflect.Descriptor instead.

func (*RegisterTunnelResponse) GetId

func (x *RegisterTunnelResponse) GetId() string

func (*RegisterTunnelResponse) ProtoMessage

func (*RegisterTunnelResponse) ProtoMessage()

func (*RegisterTunnelResponse) ProtoReflect

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

func (*RegisterTunnelResponse) Reset

func (x *RegisterTunnelResponse) Reset()

func (*RegisterTunnelResponse) String

func (x *RegisterTunnelResponse) String() string

type RegisteredTunnel

type RegisteredTunnel struct {
	Info *RegisterTunnelMeta `protobuf:"bytes,1,opt,name=Info,proto3" json:"Info,omitempty"`
	Auth []byte              `protobuf:"bytes,2,opt,name=Auth,proto3" json:"Auth,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisteredTunnel) Descriptor deprecated

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

Deprecated: Use RegisteredTunnel.ProtoReflect.Descriptor instead.

func (*RegisteredTunnel) GetAuth

func (x *RegisteredTunnel) GetAuth() []byte

func (*RegisteredTunnel) GetInfo

func (x *RegisteredTunnel) GetInfo() *RegisterTunnelMeta

func (*RegisteredTunnel) ProtoMessage

func (*RegisteredTunnel) ProtoMessage()

func (*RegisteredTunnel) ProtoReflect

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

func (*RegisteredTunnel) Reset

func (x *RegisteredTunnel) Reset()

func (*RegisteredTunnel) String

func (x *RegisteredTunnel) String() string

type RemoteIPResponse

type RemoteIPResponse struct {
	IPAddress string `protobuf:"bytes,1,opt,name=IPAddress,proto3" json:"IPAddress,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteIPResponse) Descriptor deprecated

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

Deprecated: Use RemoteIPResponse.ProtoReflect.Descriptor instead.

func (*RemoteIPResponse) GetIPAddress

func (x *RemoteIPResponse) GetIPAddress() string

func (*RemoteIPResponse) ProtoMessage

func (*RemoteIPResponse) ProtoMessage()

func (*RemoteIPResponse) ProtoReflect

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

func (*RemoteIPResponse) Reset

func (x *RemoteIPResponse) Reset()

func (*RemoteIPResponse) String

func (x *RemoteIPResponse) String() string

type RequireDomainParams

type RequireDomainParams struct {
	Mode string `protobuf:"bytes,1,opt,name=Mode,proto3" json:"Mode,omitempty"`
	// contains filtered or unexported fields
}

func (*RequireDomainParams) Descriptor deprecated

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

Deprecated: Use RequireDomainParams.ProtoReflect.Descriptor instead.

func (*RequireDomainParams) GetMode added in v1.2.4

func (x *RequireDomainParams) GetMode() string

func (*RequireDomainParams) ProtoMessage

func (*RequireDomainParams) ProtoMessage()

func (*RequireDomainParams) ProtoReflect

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

func (*RequireDomainParams) Reset

func (x *RequireDomainParams) Reset()

func (*RequireDomainParams) String

func (x *RequireDomainParams) String() string

type RequireDomainResponse

type RequireDomainResponse struct {
	Domain string `protobuf:"bytes,1,opt,name=Domain,proto3" json:"Domain,omitempty"`
	Token  string `protobuf:"bytes,2,opt,name=Token,proto3" json:"Token,omitempty"`
	Mode   string `protobuf:"bytes,3,opt,name=Mode,proto3" json:"Mode,omitempty"`
	// contains filtered or unexported fields
}

func (*RequireDomainResponse) Descriptor deprecated

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

Deprecated: Use RequireDomainResponse.ProtoReflect.Descriptor instead.

func (*RequireDomainResponse) GetDomain

func (x *RequireDomainResponse) GetDomain() string

func (*RequireDomainResponse) GetMode added in v1.2.4

func (x *RequireDomainResponse) GetMode() string

func (*RequireDomainResponse) GetToken

func (x *RequireDomainResponse) GetToken() string

func (*RequireDomainResponse) ProtoMessage

func (*RequireDomainResponse) ProtoMessage()

func (*RequireDomainResponse) ProtoReflect

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

func (*RequireDomainResponse) Reset

func (x *RequireDomainResponse) Reset()

func (*RequireDomainResponse) String

func (x *RequireDomainResponse) String() string

type RequireHTTPRequestTriggerParams added in v1.3.3

type RequireHTTPRequestTriggerParams struct {
	Token                string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	TTLSeconds           int32  `protobuf:"varint,2,opt,name=TTLSeconds,proto3" json:"TTLSeconds,omitempty"`
	ExpectedHTTPResponse []byte `protobuf:"bytes,3,opt,name=ExpectedHTTPResponse,proto3" json:"ExpectedHTTPResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*RequireHTTPRequestTriggerParams) Descriptor deprecated added in v1.3.3

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

Deprecated: Use RequireHTTPRequestTriggerParams.ProtoReflect.Descriptor instead.

func (*RequireHTTPRequestTriggerParams) GetExpectedHTTPResponse added in v1.3.3

func (x *RequireHTTPRequestTriggerParams) GetExpectedHTTPResponse() []byte

func (*RequireHTTPRequestTriggerParams) GetTTLSeconds added in v1.3.3

func (x *RequireHTTPRequestTriggerParams) GetTTLSeconds() int32

func (*RequireHTTPRequestTriggerParams) GetToken added in v1.3.3

func (*RequireHTTPRequestTriggerParams) ProtoMessage added in v1.3.3

func (*RequireHTTPRequestTriggerParams) ProtoMessage()

func (*RequireHTTPRequestTriggerParams) ProtoReflect added in v1.3.3

func (*RequireHTTPRequestTriggerParams) Reset added in v1.3.3

func (*RequireHTTPRequestTriggerParams) String added in v1.3.3

type RequireHTTPRequestTriggerResponse added in v1.3.3

type RequireHTTPRequestTriggerResponse struct {
	PrimaryUrl  string   `protobuf:"bytes,1,opt,name=PrimaryUrl,proto3" json:"PrimaryUrl,omitempty"`
	PrimaryHost string   `protobuf:"bytes,2,opt,name=PrimaryHost,proto3" json:"PrimaryHost,omitempty"`
	Urls        []string `protobuf:"bytes,3,rep,name=Urls,proto3" json:"Urls,omitempty"`
	Hosts       []string `protobuf:"bytes,4,rep,name=Hosts,proto3" json:"Hosts,omitempty"`
	Token       string   `protobuf:"bytes,5,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*RequireHTTPRequestTriggerResponse) Descriptor deprecated added in v1.3.3

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

Deprecated: Use RequireHTTPRequestTriggerResponse.ProtoReflect.Descriptor instead.

func (*RequireHTTPRequestTriggerResponse) GetHosts added in v1.3.3

func (x *RequireHTTPRequestTriggerResponse) GetHosts() []string

func (*RequireHTTPRequestTriggerResponse) GetPrimaryHost added in v1.3.3

func (x *RequireHTTPRequestTriggerResponse) GetPrimaryHost() string

func (*RequireHTTPRequestTriggerResponse) GetPrimaryUrl added in v1.3.3

func (x *RequireHTTPRequestTriggerResponse) GetPrimaryUrl() string

func (*RequireHTTPRequestTriggerResponse) GetToken added in v1.3.3

func (*RequireHTTPRequestTriggerResponse) GetUrls added in v1.3.3

func (*RequireHTTPRequestTriggerResponse) ProtoMessage added in v1.3.3

func (*RequireHTTPRequestTriggerResponse) ProtoMessage()

func (*RequireHTTPRequestTriggerResponse) ProtoReflect added in v1.3.3

func (*RequireHTTPRequestTriggerResponse) Reset added in v1.3.3

func (*RequireHTTPRequestTriggerResponse) String added in v1.3.3

type RequireRandomPortTriggerParams

type RequireRandomPortTriggerParams struct {
	Token      string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	TTLSeconds int32  `protobuf:"varint,2,opt,name=TTLSeconds,proto3" json:"TTLSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*RequireRandomPortTriggerParams) Descriptor deprecated

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

Deprecated: Use RequireRandomPortTriggerParams.ProtoReflect.Descriptor instead.

func (*RequireRandomPortTriggerParams) GetTTLSeconds

func (x *RequireRandomPortTriggerParams) GetTTLSeconds() int32

func (*RequireRandomPortTriggerParams) GetToken

func (x *RequireRandomPortTriggerParams) GetToken() string

func (*RequireRandomPortTriggerParams) ProtoMessage

func (*RequireRandomPortTriggerParams) ProtoMessage()

func (*RequireRandomPortTriggerParams) ProtoReflect

func (*RequireRandomPortTriggerParams) Reset

func (x *RequireRandomPortTriggerParams) Reset()

func (*RequireRandomPortTriggerParams) String

type RequireRandomPortTriggerResponse

type RequireRandomPortTriggerResponse struct {
	Port       int32  `protobuf:"varint,1,opt,name=Port,proto3" json:"Port,omitempty"`
	Token      string `protobuf:"bytes,2,opt,name=Token,proto3" json:"Token,omitempty"`
	ExternalIP string `protobuf:"bytes,3,opt,name=ExternalIP,proto3" json:"ExternalIP,omitempty"`
	// contains filtered or unexported fields
}

func (*RequireRandomPortTriggerResponse) Descriptor deprecated

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

Deprecated: Use RequireRandomPortTriggerResponse.ProtoReflect.Descriptor instead.

func (*RequireRandomPortTriggerResponse) GetExternalIP

func (x *RequireRandomPortTriggerResponse) GetExternalIP() string

func (*RequireRandomPortTriggerResponse) GetPort

func (*RequireRandomPortTriggerResponse) GetToken

func (*RequireRandomPortTriggerResponse) ProtoMessage

func (*RequireRandomPortTriggerResponse) ProtoMessage()

func (*RequireRandomPortTriggerResponse) ProtoReflect

func (*RequireRandomPortTriggerResponse) Reset

func (*RequireRandomPortTriggerResponse) String

type TunnelClient

type TunnelClient interface {
	RemoteIP(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RemoteIPResponse, error)
	CreateTunnel(ctx context.Context, opts ...grpc.CallOption) (Tunnel_CreateTunnelClient, error)
	// 注册一个隧道
	RegisterTunnel(ctx context.Context, in *RegisterTunnelRequest, opts ...grpc.CallOption) (*RegisterTunnelResponse, error)
	// 获取所有隧道的简要描述信息
	GetAllRegisteredTunnel(ctx context.Context, in *GetAllRegisteredTunnelRequest, opts ...grpc.CallOption) (*GetAllRegisteredTunnelResponse, error)
	GetRegisteredTunnelDescriptionByID(ctx context.Context, in *GetRegisteredTunnelDescriptionByIDRequest, opts ...grpc.CallOption) (*RegisteredTunnel, error)
	// 随机端口触发器
	RequireRandomPortTrigger(ctx context.Context, in *RequireRandomPortTriggerParams, opts ...grpc.CallOption) (*RequireRandomPortTriggerResponse, error)
	QueryExistedRandomPortTrigger(ctx context.Context, in *QueryExistedRandomPortTriggerRequest, opts ...grpc.CallOption) (*QueryExistedRandomPortTriggerResponse, error)
	// 随机 ICMP 长度触发器
	QuerySpecificICMPLengthTrigger(ctx context.Context, in *QuerySpecificICMPLengthTriggerParams, opts ...grpc.CallOption) (*QuerySpecificICMPLengthTriggerResponse, error)
	RequireHTTPRequestTrigger(ctx context.Context, in *RequireHTTPRequestTriggerParams, opts ...grpc.CallOption) (*RequireHTTPRequestTriggerResponse, error)
	QueryExistedHTTPRequestTrigger(ctx context.Context, in *QueryExistedHTTPRequestTriggerRequest, opts ...grpc.CallOption) (*QueryExistedHTTPRequestTriggerResponse, error)
	CheckServerReachable(ctx context.Context, in *CheckServerReachableRequest, opts ...grpc.CallOption) (*CheckServerReachableResponse, error)
}

TunnelClient is the client API for Tunnel service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTunnelClient

func NewTunnelClient(cc grpc.ClientConnInterface) TunnelClient

type TunnelInput

type TunnelInput struct {
	Mirrors []*Mirror `protobuf:"bytes,1,rep,name=Mirrors,proto3" json:"Mirrors,omitempty"`
	// 发送给哪个端口镜像的?
	ToId string `protobuf:"bytes,2,opt,name=ToId,proto3" json:"ToId,omitempty"`
	// 数据
	Data []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	// 对应的远端地址是啥?用来区分 conn
	ToRemoteAddr string `protobuf:"bytes,4,opt,name=ToRemoteAddr,proto3" json:"ToRemoteAddr,omitempty"`
	// Close
	Close bool `protobuf:"varint,5,opt,name=Close,proto3" json:"Close,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelInput) Descriptor deprecated

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

Deprecated: Use TunnelInput.ProtoReflect.Descriptor instead.

func (*TunnelInput) GetClose

func (x *TunnelInput) GetClose() bool

func (*TunnelInput) GetData

func (x *TunnelInput) GetData() []byte

func (*TunnelInput) GetMirrors

func (x *TunnelInput) GetMirrors() []*Mirror

func (*TunnelInput) GetToId

func (x *TunnelInput) GetToId() string

func (*TunnelInput) GetToRemoteAddr

func (x *TunnelInput) GetToRemoteAddr() string

func (*TunnelInput) ProtoMessage

func (*TunnelInput) ProtoMessage()

func (*TunnelInput) ProtoReflect

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

func (*TunnelInput) Reset

func (x *TunnelInput) Reset()

func (*TunnelInput) String

func (x *TunnelInput) String() string

type TunnelOutput

type TunnelOutput struct {
	FromId     string `protobuf:"bytes,1,opt,name=FromId,proto3" json:"FromId,omitempty"`
	RemoteAddr string `protobuf:"bytes,2,opt,name=RemoteAddr,proto3" json:"RemoteAddr,omitempty"`
	Data       []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	Close      bool   `protobuf:"varint,4,opt,name=Close,proto3" json:"Close,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelOutput) Descriptor deprecated

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

Deprecated: Use TunnelOutput.ProtoReflect.Descriptor instead.

func (*TunnelOutput) GetClose

func (x *TunnelOutput) GetClose() bool

func (*TunnelOutput) GetData

func (x *TunnelOutput) GetData() []byte

func (*TunnelOutput) GetFromId

func (x *TunnelOutput) GetFromId() string

func (*TunnelOutput) GetRemoteAddr

func (x *TunnelOutput) GetRemoteAddr() string

func (*TunnelOutput) ProtoMessage

func (*TunnelOutput) ProtoMessage()

func (*TunnelOutput) ProtoReflect

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

func (*TunnelOutput) Reset

func (x *TunnelOutput) Reset()

func (*TunnelOutput) String

func (x *TunnelOutput) String() string

type TunnelServer

type TunnelServer interface {
	RemoteIP(context.Context, *Empty) (*RemoteIPResponse, error)
	CreateTunnel(Tunnel_CreateTunnelServer) error
	// 注册一个隧道
	RegisterTunnel(context.Context, *RegisterTunnelRequest) (*RegisterTunnelResponse, error)
	// 获取所有隧道的简要描述信息
	GetAllRegisteredTunnel(context.Context, *GetAllRegisteredTunnelRequest) (*GetAllRegisteredTunnelResponse, error)
	GetRegisteredTunnelDescriptionByID(context.Context, *GetRegisteredTunnelDescriptionByIDRequest) (*RegisteredTunnel, error)
	// 随机端口触发器
	RequireRandomPortTrigger(context.Context, *RequireRandomPortTriggerParams) (*RequireRandomPortTriggerResponse, error)
	QueryExistedRandomPortTrigger(context.Context, *QueryExistedRandomPortTriggerRequest) (*QueryExistedRandomPortTriggerResponse, error)
	// 随机 ICMP 长度触发器
	QuerySpecificICMPLengthTrigger(context.Context, *QuerySpecificICMPLengthTriggerParams) (*QuerySpecificICMPLengthTriggerResponse, error)
	RequireHTTPRequestTrigger(context.Context, *RequireHTTPRequestTriggerParams) (*RequireHTTPRequestTriggerResponse, error)
	QueryExistedHTTPRequestTrigger(context.Context, *QueryExistedHTTPRequestTriggerRequest) (*QueryExistedHTTPRequestTriggerResponse, error)
	CheckServerReachable(context.Context, *CheckServerReachableRequest) (*CheckServerReachableResponse, error)
	// contains filtered or unexported methods
}

TunnelServer is the server API for Tunnel service. All implementations must embed UnimplementedTunnelServer for forward compatibility

type Tunnel_CreateTunnelClient

type Tunnel_CreateTunnelClient interface {
	Send(*TunnelInput) error
	Recv() (*TunnelOutput, error)
	grpc.ClientStream
}

type Tunnel_CreateTunnelServer

type Tunnel_CreateTunnelServer interface {
	Send(*TunnelOutput) error
	Recv() (*TunnelInput, error)
	grpc.ServerStream
}

type UnimplementedDNSLogServer

type UnimplementedDNSLogServer struct {
}

UnimplementedDNSLogServer must be embedded to have forward compatible implementations.

func (UnimplementedDNSLogServer) RequireDomain

type UnimplementedTunnelServer

type UnimplementedTunnelServer struct {
}

UnimplementedTunnelServer must be embedded to have forward compatible implementations.

func (UnimplementedTunnelServer) CreateTunnel

func (UnimplementedTunnelServer) QueryExistedHTTPRequestTrigger added in v1.3.3

func (UnimplementedTunnelServer) RegisterTunnel

func (UnimplementedTunnelServer) RemoteIP

func (UnimplementedTunnelServer) RequireHTTPRequestTrigger added in v1.3.3

type UnsafeDNSLogServer

type UnsafeDNSLogServer interface {
	// contains filtered or unexported methods
}

UnsafeDNSLogServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DNSLogServer will result in compilation errors.

type UnsafeTunnelServer

type UnsafeTunnelServer interface {
	// contains filtered or unexported methods
}

UnsafeTunnelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TunnelServer will result in compilation errors.

Jump to

Keyboard shortcuts

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