tpb

package
v1.3.2 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 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,
		},
	},
	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 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 (x *GetAllRegisteredTunnelRequest) ProtoReflect() protoreflect.Message

func (*GetAllRegisteredTunnelRequest) Reset 

func (x *GetAllRegisteredTunnelRequest) Reset()

func (*GetAllRegisteredTunnelRequest) String 

func (x *GetAllRegisteredTunnelRequest) String() 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 (x *GetAllRegisteredTunnelResponse) GetTunnels() []*RegisterTunnelMeta

func (*GetAllRegisteredTunnelResponse) ProtoMessage 

func (*GetAllRegisteredTunnelResponse) ProtoMessage()

func (*GetAllRegisteredTunnelResponse) ProtoReflect 

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

func (*GetAllRegisteredTunnelResponse) Reset 

func (x *GetAllRegisteredTunnelResponse) Reset()

func (*GetAllRegisteredTunnelResponse) String 

func (x *GetAllRegisteredTunnelResponse) String() 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 (x *GetRegisteredTunnelDescriptionByIDRequest) GetId() string

func (*GetRegisteredTunnelDescriptionByIDRequest) GetSecondaryPassword 

func (x *GetRegisteredTunnelDescriptionByIDRequest) GetSecondaryPassword() string

func (*GetRegisteredTunnelDescriptionByIDRequest) ProtoMessage 

func (*GetRegisteredTunnelDescriptionByIDRequest) ProtoMessage()

func (*GetRegisteredTunnelDescriptionByIDRequest) ProtoReflect 

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

func (*GetRegisteredTunnelDescriptionByIDRequest) Reset 

func (x *GetRegisteredTunnelDescriptionByIDRequest) Reset()

func (*GetRegisteredTunnelDescriptionByIDRequest) String 

func (x *GetRegisteredTunnelDescriptionByIDRequest) String() string

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 (x *QueryExistedDNSLogResponse) ProtoReflect() protoreflect.Message

func (*QueryExistedDNSLogResponse) Reset 

func (x *QueryExistedDNSLogResponse) Reset()

func (*QueryExistedDNSLogResponse) String 

func (x *QueryExistedDNSLogResponse) String() string

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 (x *QueryExistedRandomPortTriggerRequest) GetToken() string

func (*QueryExistedRandomPortTriggerRequest) ProtoMessage 

func (*QueryExistedRandomPortTriggerRequest) ProtoMessage()

func (*QueryExistedRandomPortTriggerRequest) ProtoReflect 

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

func (*QueryExistedRandomPortTriggerRequest) Reset 

func (x *QueryExistedRandomPortTriggerRequest) Reset()

func (*QueryExistedRandomPortTriggerRequest) String 

func (x *QueryExistedRandomPortTriggerRequest) String() 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 (x *QueryExistedRandomPortTriggerResponse) GetEvents() []*RandomPortTriggerEvent

func (*QueryExistedRandomPortTriggerResponse) ProtoMessage 

func (*QueryExistedRandomPortTriggerResponse) ProtoMessage()

func (*QueryExistedRandomPortTriggerResponse) ProtoReflect 

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

func (*QueryExistedRandomPortTriggerResponse) Reset 

func (x *QueryExistedRandomPortTriggerResponse) Reset()

func (*QueryExistedRandomPortTriggerResponse) String 

func (x *QueryExistedRandomPortTriggerResponse) String() 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 (x *QuerySpecificICMPLengthTriggerParams) GetLength() int32

func (*QuerySpecificICMPLengthTriggerParams) ProtoMessage 

func (*QuerySpecificICMPLengthTriggerParams) ProtoMessage()

func (*QuerySpecificICMPLengthTriggerParams) ProtoReflect 

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

func (*QuerySpecificICMPLengthTriggerParams) Reset 

func (x *QuerySpecificICMPLengthTriggerParams) Reset()

func (*QuerySpecificICMPLengthTriggerParams) String 

func (x *QuerySpecificICMPLengthTriggerParams) String() 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 (x *QuerySpecificICMPLengthTriggerResponse) GetNotifications() []*ICMPTriggerNotification

func (*QuerySpecificICMPLengthTriggerResponse) ProtoMessage 

func (*QuerySpecificICMPLengthTriggerResponse) ProtoMessage()

func (*QuerySpecificICMPLengthTriggerResponse) ProtoReflect 

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

func (*QuerySpecificICMPLengthTriggerResponse) Reset 

func (x *QuerySpecificICMPLengthTriggerResponse) Reset()

func (*QuerySpecificICMPLengthTriggerResponse) String 

func (x *QuerySpecificICMPLengthTriggerResponse) String() 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 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 (x *RequireRandomPortTriggerParams) ProtoReflect() protoreflect.Message

func (*RequireRandomPortTriggerParams) Reset 

func (x *RequireRandomPortTriggerParams) Reset()

func (*RequireRandomPortTriggerParams) String 

func (x *RequireRandomPortTriggerParams) String() 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 (x *RequireRandomPortTriggerResponse) GetPort() int32

func (*RequireRandomPortTriggerResponse) GetToken 

func (x *RequireRandomPortTriggerResponse) GetToken() string

func (*RequireRandomPortTriggerResponse) ProtoMessage 

func (*RequireRandomPortTriggerResponse) ProtoMessage()

func (*RequireRandomPortTriggerResponse) ProtoReflect 

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

func (*RequireRandomPortTriggerResponse) Reset 

func (x *RequireRandomPortTriggerResponse) Reset()

func (*RequireRandomPortTriggerResponse) String 

func (x *RequireRandomPortTriggerResponse) String() 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)
}

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)
	// 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) QueryExistedDNSLog 

func (UnimplementedDNSLogServer) QueryExistedDNSLog(context.Context, *QueryExistedDNSLogParams) (*QueryExistedDNSLogResponse, error)

func (UnimplementedDNSLogServer) RequireDomain 

func (UnimplementedDNSLogServer) RequireDomain(context.Context, *RequireDomainParams) (*RequireDomainResponse, error)

type UnimplementedTunnelServer 

type UnimplementedTunnelServer struct {
}

UnimplementedTunnelServer must be embedded to have forward compatible implementations.

func (UnimplementedTunnelServer) CreateTunnel 

func (UnimplementedTunnelServer) CreateTunnel(Tunnel_CreateTunnelServer) error

func (UnimplementedTunnelServer) GetAllRegisteredTunnel 

func (UnimplementedTunnelServer) GetAllRegisteredTunnel(context.Context, *GetAllRegisteredTunnelRequest) (*GetAllRegisteredTunnelResponse, error)

func (UnimplementedTunnelServer) GetRegisteredTunnelDescriptionByID 

func (UnimplementedTunnelServer) GetRegisteredTunnelDescriptionByID(context.Context, *GetRegisteredTunnelDescriptionByIDRequest) (*RegisteredTunnel, error)

func (UnimplementedTunnelServer) QueryExistedRandomPortTrigger 

func (UnimplementedTunnelServer) QueryExistedRandomPortTrigger(context.Context, *QueryExistedRandomPortTriggerRequest) (*QueryExistedRandomPortTriggerResponse, error)

func (UnimplementedTunnelServer) QuerySpecificICMPLengthTrigger 

func (UnimplementedTunnelServer) QuerySpecificICMPLengthTrigger(context.Context, *QuerySpecificICMPLengthTriggerParams) (*QuerySpecificICMPLengthTriggerResponse, error)

func (UnimplementedTunnelServer) RegisterTunnel 

func (UnimplementedTunnelServer) RegisterTunnel(context.Context, *RegisterTunnelRequest) (*RegisterTunnelResponse, error)

func (UnimplementedTunnelServer) RemoteIP 

func (UnimplementedTunnelServer) RemoteIP(context.Context, *Empty) (*RemoteIPResponse, error)

func (UnimplementedTunnelServer) RequireRandomPortTrigger 

func (UnimplementedTunnelServer) RequireRandomPortTrigger(context.Context, *RequireRandomPortTriggerParams) (*RequireRandomPortTriggerResponse, error)

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.