node

package
v0.3.1-beta.2 Latest Latest
Warning

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

 Go to latest Published: May 6, 2022 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PointOriginType_name = map[int32]string{
		0:   "node_origin_reserve",
		101: "remote",
		102: "manual",
	}
	PointOriginType_value = map[string]int32{
		"node_origin_reserve": 0,
		"remote":              101,
		"manual":              102,
	}
)

Enum value maps for PointOriginType.

View Source 
var (
	NodeLinkLinkType_name = map[int32]string{
		0: "reserve",
		1: "trojan",
		2: "vmess",
		3: "shadowsocks",
		4: "shadowsocksr",
	}
	NodeLinkLinkType_value = map[string]int32{
		"reserve":      0,
		"trojan":       1,
		"vmess":        2,
		"shadowsocks":  3,
		"shadowsocksr": 4,
	}
)

Enum value maps for NodeLinkLinkType.

View Source 
var File_node_node_proto protoreflect.FileDescriptor
View Source 
var NodeManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.node.node_manager",
	HandlerType: (*NodeManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "now",
			Handler:    _NodeManager_Now_Handler,
		},
		{
			MethodName: "use",
			Handler:    _NodeManager_Use_Handler,
		},
		{
			MethodName: "get_node",
			Handler:    _NodeManager_GetNode_Handler,
		},
		{
			MethodName: "save_node",
			Handler:    _NodeManager_SaveNode_Handler,
		},
		{
			MethodName: "delete_node",
			Handler:    _NodeManager_DeleteNode_Handler,
		},
		{
			MethodName: "get_manager",
			Handler:    _NodeManager_GetManager_Handler,
		},
		{
			MethodName: "save_links",
			Handler:    _NodeManager_SaveLinks_Handler,
		},
		{
			MethodName: "delete_links",
			Handler:    _NodeManager_DeleteLinks_Handler,
		},
		{
			MethodName: "update_links",
			Handler:    _NodeManager_UpdateLinks_Handler,
		},
		{
			MethodName: "get_links",
			Handler:    _NodeManager_GetLinks_Handler,
		},
		{
			MethodName: "latency",
			Handler:    _NodeManager_Latency_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "node/node.proto",
}

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

Functions

func ParseTLSConfig 

func ParseTLSConfig(t *TlsConfig) *tls.Config

func RegisterNodeManagerServer 

func RegisterNodeManagerServer(s grpc.ServiceRegistrar, srv NodeManagerServer)

func RegisterProtocol 

func RegisterProtocol[T isPointProtocol_Protocol](wrap func(T) WrapProxy)

Types

type GetLinksResp 

type GetLinksResp struct {
	Links map[string]*NodeLink `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetLinksResp) Descriptor deprecated 

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

Deprecated: Use GetLinksResp.ProtoReflect.Descriptor instead. 

func (x *GetLinksResp) GetLinks() map[string]*NodeLink

func (*GetLinksResp) ProtoMessage 

func (*GetLinksResp) ProtoMessage()

func (*GetLinksResp) ProtoReflect 

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

func (*GetLinksResp) Reset 

func (x *GetLinksResp) Reset()

func (*GetLinksResp) String 

func (x *GetLinksResp) String() string

type Http 

type Http struct {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*Http) Descriptor deprecated 

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

Deprecated: Use Http.ProtoReflect.Descriptor instead.

func (*Http) GetPassword 

func (x *Http) GetPassword() string

func (*Http) GetUser 

func (x *Http) GetUser() string

func (*Http) ProtoMessage 

func (*Http) ProtoMessage()

func (*Http) ProtoReflect 

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

func (*Http) Reset 

func (x *Http) Reset()

func (*Http) String 

func (x *Http) String() string

type LatencyReq 

type LatencyReq struct {
	Requests []*LatencyReqRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*LatencyReq) Descriptor deprecated 

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

Deprecated: Use LatencyReq.ProtoReflect.Descriptor instead.

func (*LatencyReq) GetRequests 

func (x *LatencyReq) GetRequests() []*LatencyReqRequest

func (*LatencyReq) ProtoMessage 

func (*LatencyReq) ProtoMessage()

func (*LatencyReq) ProtoReflect 

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

func (*LatencyReq) Reset 

func (x *LatencyReq) Reset()

func (*LatencyReq) String 

func (x *LatencyReq) String() string

type LatencyReqRequest 

type LatencyReqRequest struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Udp  bool   `protobuf:"varint,2,opt,name=udp,proto3" json:"udp,omitempty"`
	Tcp  bool   `protobuf:"varint,3,opt,name=tcp,proto3" json:"tcp,omitempty"`
	// contains filtered or unexported fields
}

func (*LatencyReqRequest) Descriptor deprecated 

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

Deprecated: Use LatencyReqRequest.ProtoReflect.Descriptor instead.

func (*LatencyReqRequest) GetHash 

func (x *LatencyReqRequest) GetHash() string

func (*LatencyReqRequest) GetTcp 

func (x *LatencyReqRequest) GetTcp() bool

func (*LatencyReqRequest) GetUdp 

func (x *LatencyReqRequest) GetUdp() bool

func (*LatencyReqRequest) ProtoMessage 

func (*LatencyReqRequest) ProtoMessage()

func (*LatencyReqRequest) ProtoReflect 

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

func (*LatencyReqRequest) Reset 

func (x *LatencyReqRequest) Reset()

func (*LatencyReqRequest) String 

func (x *LatencyReqRequest) String() string

type LatencyResp 

type LatencyResp struct {
	HashLatencyMap map[string]*LatencyRespLatency `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LatencyResp) Descriptor deprecated 

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

Deprecated: Use LatencyResp.ProtoReflect.Descriptor instead.

func (*LatencyResp) GetHashLatencyMap 

func (x *LatencyResp) GetHashLatencyMap() map[string]*LatencyRespLatency

func (*LatencyResp) ProtoMessage 

func (*LatencyResp) ProtoMessage()

func (*LatencyResp) ProtoReflect 

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

func (*LatencyResp) Reset 

func (x *LatencyResp) Reset()

func (*LatencyResp) String 

func (x *LatencyResp) String() string

type LatencyRespLatency 

type LatencyRespLatency struct {
	Tcp string `protobuf:"bytes,1,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Udp string `protobuf:"bytes,2,opt,name=udp,proto3" json:"udp,omitempty"`
	// contains filtered or unexported fields
}

func (*LatencyRespLatency) Descriptor deprecated 

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

Deprecated: Use LatencyRespLatency.ProtoReflect.Descriptor instead.

func (*LatencyRespLatency) GetTcp 

func (x *LatencyRespLatency) GetTcp() string

func (*LatencyRespLatency) GetUdp 

func (x *LatencyRespLatency) GetUdp() string

func (*LatencyRespLatency) ProtoMessage 

func (*LatencyRespLatency) ProtoMessage()

func (*LatencyRespLatency) ProtoReflect 

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

func (*LatencyRespLatency) Reset 

func (x *LatencyRespLatency) Reset()

func (*LatencyRespLatency) String 

func (x *LatencyRespLatency) String() string

type LinkReq 

type LinkReq struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkReq) Descriptor deprecated 

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

Deprecated: Use LinkReq.ProtoReflect.Descriptor instead.

func (*LinkReq) GetNames 

func (x *LinkReq) GetNames() []string

func (*LinkReq) ProtoMessage 

func (*LinkReq) ProtoMessage()

func (*LinkReq) ProtoReflect 

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

func (*LinkReq) Reset 

func (x *LinkReq) Reset()

func (*LinkReq) String 

func (x *LinkReq) String() string

type Manager 

type Manager struct {
	Groups        []string                     `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	GroupNodesMap map[string]*ManagerNodeArray `` /* 171-byte string literal not displayed */
	Nodes         map[string]*Point            `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Manager) Descriptor deprecated 

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

Deprecated: Use Manager.ProtoReflect.Descriptor instead.

func (*Manager) GetGroupNodesMap 

func (x *Manager) GetGroupNodesMap() map[string]*ManagerNodeArray

func (*Manager) GetGroups 

func (x *Manager) GetGroups() []string

func (*Manager) GetNodes 

func (x *Manager) GetNodes() map[string]*Point

func (*Manager) ProtoMessage 

func (*Manager) ProtoMessage()

func (*Manager) ProtoReflect 

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

func (*Manager) Reset 

func (x *Manager) Reset()

func (*Manager) String 

func (x *Manager) String() string

type ManagerNodeArray 

type ManagerNodeArray struct {
	Group       string            `protobuf:"bytes,1,opt,name=group,json=name,proto3" json:"group,omitempty"`
	Nodes       []string          `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	NodeHashMap map[string]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ManagerNodeArray) Descriptor deprecated 

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

Deprecated: Use ManagerNodeArray.ProtoReflect.Descriptor instead.

func (*ManagerNodeArray) GetGroup 

func (x *ManagerNodeArray) GetGroup() string

func (*ManagerNodeArray) GetNodeHashMap 

func (x *ManagerNodeArray) GetNodeHashMap() map[string]string

func (*ManagerNodeArray) GetNodes 

func (x *ManagerNodeArray) GetNodes() []string

func (*ManagerNodeArray) ProtoMessage 

func (*ManagerNodeArray) ProtoMessage()

func (*ManagerNodeArray) ProtoReflect 

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

func (*ManagerNodeArray) Reset 

func (x *ManagerNodeArray) Reset()

func (*ManagerNodeArray) String 

func (x *ManagerNodeArray) String() string

type Node 

type Node struct {
	NowNode *Point               `protobuf:"bytes,1,opt,name=now_node,proto3" json:"now_node,omitempty"`
	Links   map[string]*NodeLink `` /* 151-byte string literal not displayed */
	Manager *Manager             `protobuf:"bytes,3,opt,name=manager,proto3" json:"manager,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead. 

func (x *Node) GetLinks() map[string]*NodeLink

func (*Node) GetManager 

func (x *Node) GetManager() *Manager

func (*Node) GetNowNode 

func (x *Node) GetNowNode() *Point

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string
type NodeLink struct {
	Name string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type NodeLinkLinkType `protobuf:"varint,2,opt,name=type,proto3,enum=yuhaiin.node.NodeLinkLinkType" json:"type,omitempty"`
	Url  string           `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeLink) Descriptor deprecated 

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

Deprecated: Use NodeLink.ProtoReflect.Descriptor instead.

func (*NodeLink) GetName 

func (x *NodeLink) GetName() string

func (*NodeLink) GetType 

func (x *NodeLink) GetType() NodeLinkLinkType

func (*NodeLink) GetUrl 

func (x *NodeLink) GetUrl() string

func (*NodeLink) ProtoMessage 

func (*NodeLink) ProtoMessage()

func (*NodeLink) ProtoReflect 

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

func (*NodeLink) Reset 

func (x *NodeLink) Reset()

func (*NodeLink) String 

func (x *NodeLink) String() string

type NodeLinkLinkType 

type NodeLinkLinkType int32
const (
	NodeLink_reserve      NodeLinkLinkType = 0
	NodeLink_trojan       NodeLinkLinkType = 1
	NodeLink_vmess        NodeLinkLinkType = 2
	NodeLink_shadowsocks  NodeLinkLinkType = 3
	NodeLink_shadowsocksr NodeLinkLinkType = 4
)

func (NodeLinkLinkType) Descriptor 

func (NodeLinkLinkType) Descriptor() protoreflect.EnumDescriptor

func (NodeLinkLinkType) Enum 

func (x NodeLinkLinkType) Enum() *NodeLinkLinkType

func (NodeLinkLinkType) EnumDescriptor deprecated 

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

Deprecated: Use NodeLinkLinkType.Descriptor instead.

func (NodeLinkLinkType) Number 

func (x NodeLinkLinkType) Number() protoreflect.EnumNumber

func (NodeLinkLinkType) String 

func (x NodeLinkLinkType) String() string

func (NodeLinkLinkType) Type 

func (NodeLinkLinkType) Type() protoreflect.EnumType

type NodeManagerClient 

type NodeManagerClient interface {
	Now(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Point, error)
	// use req is hash string of point
	Use(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*Point, error)
	GetNode(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*Point, error)
	SaveNode(ctx context.Context, in *Point, opts ...grpc.CallOption) (*Point, error)
	DeleteNode(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetManager(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*Manager, error)
	SaveLinks(ctx context.Context, in *SaveLinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteLinks(ctx context.Context, in *LinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpdateLinks(ctx context.Context, in *LinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetLinks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLinksResp, error)
	Latency(ctx context.Context, in *LatencyReq, opts ...grpc.CallOption) (*LatencyResp, error)
}

NodeManagerClient is the client API for NodeManager 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 NewNodeManagerClient 

func NewNodeManagerClient(cc grpc.ClientConnInterface) NodeManagerClient

type NodeManagerServer 

type NodeManagerServer interface {
	Now(context.Context, *emptypb.Empty) (*Point, error)
	// use req is hash string of point
	Use(context.Context, *wrapperspb.StringValue) (*Point, error)
	GetNode(context.Context, *wrapperspb.StringValue) (*Point, error)
	SaveNode(context.Context, *Point) (*Point, error)
	DeleteNode(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)
	GetManager(context.Context, *wrapperspb.StringValue) (*Manager, error)
	SaveLinks(context.Context, *SaveLinkReq) (*emptypb.Empty, error)
	DeleteLinks(context.Context, *LinkReq) (*emptypb.Empty, error)
	UpdateLinks(context.Context, *LinkReq) (*emptypb.Empty, error)
	GetLinks(context.Context, *emptypb.Empty) (*GetLinksResp, error)
	Latency(context.Context, *LatencyReq) (*LatencyResp, error)
	// contains filtered or unexported methods
}

NodeManagerServer is the server API for NodeManager service. All implementations must embed UnimplementedNodeManagerServer for forward compatibility

type None 

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

func (*None) Descriptor deprecated 

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

Deprecated: Use None.ProtoReflect.Descriptor instead.

func (*None) ProtoMessage 

func (*None) ProtoMessage()

func (*None) ProtoReflect 

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

func (*None) Reset 

func (x *None) Reset()

func (*None) String 

func (x *None) String() string

type ObfsHttp 

type ObfsHttp struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ObfsHttp) Descriptor deprecated 

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

Deprecated: Use ObfsHttp.ProtoReflect.Descriptor instead.

func (*ObfsHttp) GetHost 

func (x *ObfsHttp) GetHost() string

func (*ObfsHttp) GetPort 

func (x *ObfsHttp) GetPort() string

func (*ObfsHttp) ProtoMessage 

func (*ObfsHttp) ProtoMessage()

func (*ObfsHttp) ProtoReflect 

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

func (*ObfsHttp) Reset 

func (x *ObfsHttp) Reset()

func (*ObfsHttp) String 

func (x *ObfsHttp) String() string

type Point 

type Point struct {
	Hash   string          `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Name   string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group  string          `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Origin PointOriginType `protobuf:"varint,4,opt,name=origin,proto3,enum=yuhaiin.node.PointOriginType" json:"origin,omitempty"`
	// will use protocols' order to create dialer
	Protocols []*PointProtocol `protobuf:"bytes,5,rep,name=protocols,proto3" json:"protocols,omitempty"`
	// contains filtered or unexported fields
}

func (*Point) Descriptor deprecated 

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

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetGroup 

func (x *Point) GetGroup() string

func (*Point) GetHash 

func (x *Point) GetHash() string

func (*Point) GetName 

func (x *Point) GetName() string

func (*Point) GetOrigin 

func (x *Point) GetOrigin() PointOriginType

func (*Point) GetProtocols 

func (x *Point) GetProtocols() []*PointProtocol

func (*Point) ProtoMessage 

func (*Point) ProtoMessage()

func (*Point) ProtoReflect 

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

func (*Point) Reset 

func (x *Point) Reset()

func (*Point) String 

func (x *Point) String() string

type PointOriginType 

type PointOriginType int32
const (
	Point_node_origin_reserve PointOriginType = 0
	Point_remote              PointOriginType = 101
	Point_manual              PointOriginType = 102
)

func (PointOriginType) Descriptor 

func (PointOriginType) Descriptor() protoreflect.EnumDescriptor

func (PointOriginType) Enum 

func (x PointOriginType) Enum() *PointOriginType

func (PointOriginType) EnumDescriptor deprecated 

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

Deprecated: Use PointOriginType.Descriptor instead.

func (PointOriginType) Number 

func (x PointOriginType) Number() protoreflect.EnumNumber

func (PointOriginType) String 

func (x PointOriginType) String() string

func (PointOriginType) Type 

func (PointOriginType) Type() protoreflect.EnumType

type PointProtocol 

type PointProtocol struct {

	// Types that are assignable to Protocol:
	//	*PointProtocol_Shadowsocks
	//	*PointProtocol_Shadowsocksr
	//	*PointProtocol_Vmess
	//	*PointProtocol_Websocket
	//	*PointProtocol_Quic
	//	*PointProtocol_ObfsHttp
	//	*PointProtocol_Trojan
	//	*PointProtocol_Simple
	//	*PointProtocol_None
	//	*PointProtocol_Socks5
	//	*PointProtocol_Http
	Protocol isPointProtocol_Protocol `protobuf_oneof:"protocol"`
	// contains filtered or unexported fields
}

func (*PointProtocol) Descriptor deprecated 

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

Deprecated: Use PointProtocol.ProtoReflect.Descriptor instead.

func (*PointProtocol) GetHttp 

func (x *PointProtocol) GetHttp() *Http

func (*PointProtocol) GetNone 

func (x *PointProtocol) GetNone() *None

func (*PointProtocol) GetObfsHttp 

func (x *PointProtocol) GetObfsHttp() *ObfsHttp

func (*PointProtocol) GetProtocol 

func (m *PointProtocol) GetProtocol() isPointProtocol_Protocol

func (*PointProtocol) GetQuic 

func (x *PointProtocol) GetQuic() *Quic

func (*PointProtocol) GetShadowsocks 

func (x *PointProtocol) GetShadowsocks() *Shadowsocks

func (*PointProtocol) GetShadowsocksr 

func (x *PointProtocol) GetShadowsocksr() *Shadowsocksr

func (*PointProtocol) GetSimple 

func (x *PointProtocol) GetSimple() *Simple

func (*PointProtocol) GetSocks5 

func (x *PointProtocol) GetSocks5() *Socks5

func (*PointProtocol) GetTrojan 

func (x *PointProtocol) GetTrojan() *Trojan

func (*PointProtocol) GetVmess 

func (x *PointProtocol) GetVmess() *Vmess

func (*PointProtocol) GetWebsocket 

func (x *PointProtocol) GetWebsocket() *Websocket

func (*PointProtocol) ProtoMessage 

func (*PointProtocol) ProtoMessage()

func (*PointProtocol) ProtoReflect 

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

func (*PointProtocol) Reset 

func (x *PointProtocol) Reset()

func (*PointProtocol) String 

func (x *PointProtocol) String() string

type PointProtocol_Http 

type PointProtocol_Http struct {
	Http *Http `protobuf:"bytes,11,opt,name=http,proto3,oneof"`
}

type PointProtocol_None 

type PointProtocol_None struct {
	None *None `protobuf:"bytes,9,opt,name=none,proto3,oneof"`
}

type PointProtocol_ObfsHttp 

type PointProtocol_ObfsHttp struct {
	ObfsHttp *ObfsHttp `protobuf:"bytes,6,opt,name=obfs_http,proto3,oneof"`
}

type PointProtocol_Quic 

type PointProtocol_Quic struct {
	Quic *Quic `protobuf:"bytes,5,opt,name=quic,proto3,oneof"`
}

type PointProtocol_Shadowsocks 

type PointProtocol_Shadowsocks struct {
	Shadowsocks *Shadowsocks `protobuf:"bytes,1,opt,name=shadowsocks,proto3,oneof"`
}

type PointProtocol_Shadowsocksr 

type PointProtocol_Shadowsocksr struct {
	Shadowsocksr *Shadowsocksr `protobuf:"bytes,2,opt,name=shadowsocksr,proto3,oneof"`
}

type PointProtocol_Simple 

type PointProtocol_Simple struct {
	Simple *Simple `protobuf:"bytes,8,opt,name=simple,proto3,oneof"`
}

type PointProtocol_Socks5 

type PointProtocol_Socks5 struct {
	Socks5 *Socks5 `protobuf:"bytes,10,opt,name=socks5,proto3,oneof"`
}

type PointProtocol_Trojan 

type PointProtocol_Trojan struct {
	Trojan *Trojan `protobuf:"bytes,7,opt,name=trojan,proto3,oneof"`
}

type PointProtocol_Vmess 

type PointProtocol_Vmess struct {
	Vmess *Vmess `protobuf:"bytes,3,opt,name=vmess,proto3,oneof"`
}

type PointProtocol_Websocket 

type PointProtocol_Websocket struct {
	Websocket *Websocket `protobuf:"bytes,4,opt,name=websocket,proto3,oneof"`
}

type Quic 

type Quic struct {
	Tls *TlsConfig `protobuf:"bytes,1,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

func (*Quic) Descriptor deprecated 

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

Deprecated: Use Quic.ProtoReflect.Descriptor instead.

func (*Quic) GetTls 

func (x *Quic) GetTls() *TlsConfig

func (*Quic) ProtoMessage 

func (*Quic) ProtoMessage()

func (*Quic) ProtoReflect 

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

func (*Quic) Reset 

func (x *Quic) Reset()

func (*Quic) String 

func (x *Quic) String() string

type SaveLinkReq 

type SaveLinkReq struct {
	Links []*NodeLink `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveLinkReq) Descriptor deprecated 

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

Deprecated: Use SaveLinkReq.ProtoReflect.Descriptor instead. 

func (x *SaveLinkReq) GetLinks() []*NodeLink

func (*SaveLinkReq) ProtoMessage 

func (*SaveLinkReq) ProtoMessage()

func (*SaveLinkReq) ProtoReflect 

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

func (*SaveLinkReq) Reset 

func (x *SaveLinkReq) Reset()

func (*SaveLinkReq) String 

func (x *SaveLinkReq) String() string

type Shadowsocks 

type Shadowsocks struct {
	Server   string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	Port     string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	Method   string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*Shadowsocks) Descriptor deprecated 

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

Deprecated: Use Shadowsocks.ProtoReflect.Descriptor instead.

func (*Shadowsocks) GetMethod 

func (x *Shadowsocks) GetMethod() string

func (*Shadowsocks) GetPassword 

func (x *Shadowsocks) GetPassword() string

func (*Shadowsocks) GetPort 

func (x *Shadowsocks) GetPort() string

func (*Shadowsocks) GetServer 

func (x *Shadowsocks) GetServer() string

func (*Shadowsocks) ProtoMessage 

func (*Shadowsocks) ProtoMessage()

func (*Shadowsocks) ProtoReflect 

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

func (*Shadowsocks) Reset 

func (x *Shadowsocks) Reset()

func (*Shadowsocks) String 

func (x *Shadowsocks) String() string

type Shadowsocksr 

type Shadowsocksr struct {
	Server     string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	Port       string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	Method     string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Password   string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	Obfs       string `protobuf:"bytes,5,opt,name=obfs,proto3" json:"obfs,omitempty"`
	Obfsparam  string `protobuf:"bytes,6,opt,name=obfsparam,proto3" json:"obfsparam,omitempty"`
	Protocol   string `protobuf:"bytes,7,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Protoparam string `protobuf:"bytes,8,opt,name=protoparam,proto3" json:"protoparam,omitempty"`
	// contains filtered or unexported fields
}

func (*Shadowsocksr) Descriptor deprecated 

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

Deprecated: Use Shadowsocksr.ProtoReflect.Descriptor instead.

func (*Shadowsocksr) GetMethod 

func (x *Shadowsocksr) GetMethod() string

func (*Shadowsocksr) GetObfs 

func (x *Shadowsocksr) GetObfs() string

func (*Shadowsocksr) GetObfsparam 

func (x *Shadowsocksr) GetObfsparam() string

func (*Shadowsocksr) GetPassword 

func (x *Shadowsocksr) GetPassword() string

func (*Shadowsocksr) GetPort 

func (x *Shadowsocksr) GetPort() string

func (*Shadowsocksr) GetProtocol 

func (x *Shadowsocksr) GetProtocol() string

func (*Shadowsocksr) GetProtoparam 

func (x *Shadowsocksr) GetProtoparam() string

func (*Shadowsocksr) GetServer 

func (x *Shadowsocksr) GetServer() string

func (*Shadowsocksr) ProtoMessage 

func (*Shadowsocksr) ProtoMessage()

func (*Shadowsocksr) ProtoReflect 

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

func (*Shadowsocksr) Reset 

func (x *Shadowsocksr) Reset()

func (*Shadowsocksr) String 

func (x *Shadowsocksr) String() string

type Simple 

type Simple struct {
	Host string     `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port int32      `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Tls  *TlsConfig `protobuf:"bytes,3,opt,name=tls,json=tls_config,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

func (*Simple) Descriptor deprecated 

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

Deprecated: Use Simple.ProtoReflect.Descriptor instead.

func (*Simple) GetHost 

func (x *Simple) GetHost() string

func (*Simple) GetPort 

func (x *Simple) GetPort() int32

func (*Simple) GetTls 

func (x *Simple) GetTls() *TlsConfig

func (*Simple) ProtoMessage 

func (*Simple) ProtoMessage()

func (*Simple) ProtoReflect 

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

func (*Simple) Reset 

func (x *Simple) Reset()

func (*Simple) String 

func (x *Simple) String() string

type Socks5 

type Socks5 struct {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*Socks5) Descriptor deprecated 

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

Deprecated: Use Socks5.ProtoReflect.Descriptor instead.

func (*Socks5) GetPassword 

func (x *Socks5) GetPassword() string

func (*Socks5) GetUser 

func (x *Socks5) GetUser() string

func (*Socks5) ProtoMessage 

func (*Socks5) ProtoMessage()

func (*Socks5) ProtoReflect 

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

func (*Socks5) Reset 

func (x *Socks5) Reset()

func (*Socks5) String 

func (x *Socks5) String() string

type TlsConfig 

type TlsConfig struct {
	Enable             bool     `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	ServerName         string   `protobuf:"bytes,2,opt,name=server_name,proto3" json:"server_name,omitempty"`
	CaCert             [][]byte `protobuf:"bytes,3,rep,name=ca_cert,proto3" json:"ca_cert,omitempty"`
	InsecureSkipVerify bool     `protobuf:"varint,4,opt,name=insecure_skip_verify,proto3" json:"insecure_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

func (*TlsConfig) Descriptor deprecated 

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

Deprecated: Use TlsConfig.ProtoReflect.Descriptor instead.

func (*TlsConfig) GetCaCert 

func (x *TlsConfig) GetCaCert() [][]byte

func (*TlsConfig) GetEnable 

func (x *TlsConfig) GetEnable() bool

func (*TlsConfig) GetInsecureSkipVerify 

func (x *TlsConfig) GetInsecureSkipVerify() bool

func (*TlsConfig) GetServerName 

func (x *TlsConfig) GetServerName() string

func (*TlsConfig) ProtoMessage 

func (*TlsConfig) ProtoMessage()

func (*TlsConfig) ProtoReflect 

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

func (*TlsConfig) Reset 

func (x *TlsConfig) Reset()

func (*TlsConfig) String 

func (x *TlsConfig) String() string

type Trojan 

type Trojan struct {
	Password string `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"`
	Peer     string `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// contains filtered or unexported fields
}

func (*Trojan) Descriptor deprecated 

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

Deprecated: Use Trojan.ProtoReflect.Descriptor instead.

func (*Trojan) GetPassword 

func (x *Trojan) GetPassword() string

func (*Trojan) GetPeer 

func (x *Trojan) GetPeer() string

func (*Trojan) ProtoMessage 

func (*Trojan) ProtoMessage()

func (*Trojan) ProtoReflect 

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

func (*Trojan) Reset 

func (x *Trojan) Reset()

func (*Trojan) String 

func (x *Trojan) String() string

type UnimplementedNodeManagerServer 

type UnimplementedNodeManagerServer struct {
}

UnimplementedNodeManagerServer must be embedded to have forward compatible implementations. 

func (UnimplementedNodeManagerServer) DeleteLinks(context.Context, *LinkReq) (*emptypb.Empty, error)

func (UnimplementedNodeManagerServer) DeleteNode 

func (UnimplementedNodeManagerServer) DeleteNode(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)
func (UnimplementedNodeManagerServer) GetLinks(context.Context, *emptypb.Empty) (*GetLinksResp, error)

func (UnimplementedNodeManagerServer) GetManager 

func (UnimplementedNodeManagerServer) GetManager(context.Context, *wrapperspb.StringValue) (*Manager, error)

func (UnimplementedNodeManagerServer) GetNode 

func (UnimplementedNodeManagerServer) GetNode(context.Context, *wrapperspb.StringValue) (*Point, error)

func (UnimplementedNodeManagerServer) Latency 

func (UnimplementedNodeManagerServer) Latency(context.Context, *LatencyReq) (*LatencyResp, error)

func (UnimplementedNodeManagerServer) Now 

func (UnimplementedNodeManagerServer) Now(context.Context, *emptypb.Empty) (*Point, error)
func (UnimplementedNodeManagerServer) SaveLinks(context.Context, *SaveLinkReq) (*emptypb.Empty, error)

func (UnimplementedNodeManagerServer) SaveNode 

func (UnimplementedNodeManagerServer) SaveNode(context.Context, *Point) (*Point, error)
func (UnimplementedNodeManagerServer) UpdateLinks(context.Context, *LinkReq) (*emptypb.Empty, error)

func (UnimplementedNodeManagerServer) Use 

func (UnimplementedNodeManagerServer) Use(context.Context, *wrapperspb.StringValue) (*Point, error)

type UnsafeNodeManagerServer 

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

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

type Vmess 

type Vmess struct {

	// uuid
	Uuid string `protobuf:"bytes,1,opt,name=uuid,json=id,proto3" json:"uuid,omitempty"`
	// alter id
	AlterId  string `protobuf:"bytes,2,opt,name=alter_id,json=aid,proto3" json:"alter_id,omitempty"`
	Security string `protobuf:"bytes,3,opt,name=security,proto3" json:"security,omitempty"`
	// contains filtered or unexported fields
}

func (*Vmess) Descriptor deprecated 

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

Deprecated: Use Vmess.ProtoReflect.Descriptor instead.

func (*Vmess) GetAlterId 

func (x *Vmess) GetAlterId() string

func (*Vmess) GetSecurity 

func (x *Vmess) GetSecurity() string

func (*Vmess) GetUuid 

func (x *Vmess) GetUuid() string

func (*Vmess) ProtoMessage 

func (*Vmess) ProtoMessage()

func (*Vmess) ProtoReflect 

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

func (*Vmess) Reset 

func (x *Vmess) Reset()

func (*Vmess) String 

func (x *Vmess) String() string

type Websocket 

type Websocket struct {
	Host string     `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Path string     `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Tls  *TlsConfig `protobuf:"bytes,3,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

func (*Websocket) Descriptor deprecated 

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

Deprecated: Use Websocket.ProtoReflect.Descriptor instead.

func (*Websocket) GetHost 

func (x *Websocket) GetHost() string

func (*Websocket) GetPath 

func (x *Websocket) GetPath() string

func (*Websocket) GetTls 

func (x *Websocket) GetTls() *TlsConfig

func (*Websocket) ProtoMessage 

func (*Websocket) ProtoMessage()

func (*Websocket) ProtoReflect 

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

func (*Websocket) Reset 

func (x *Websocket) Reset()

func (*Websocket) String 

func (x *Websocket) String() string

type WrapProxy 

type WrapProxy func(p proxy.Proxy) (proxy.Proxy, error)

func ErrConn 

func ErrConn(err error) WrapProxy

func Wrap 

func Wrap(p isPointProtocol_Protocol) WrapProxy

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.