grpc

package
v1.7.3 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ProxyPoolService_GetProxyNodes_FullMethodName         = "/v2raypool.ProxyPoolService/GetProxyNodes"
	ProxyPoolService_GetProxyNodesByDomain_FullMethodName = "/v2raypool.ProxyPoolService/GetProxyNodesByDomain"
	ProxyPoolService_SetTestUrl_FullMethodName            = "/v2raypool.ProxyPoolService/SetTestUrl"
	ProxyPoolService_StartProxyPoolAll_FullMethodName     = "/v2raypool.ProxyPoolService/StartProxyPoolAll"
	ProxyPoolService_StopProxyPoolAll_FullMethodName      = "/v2raypool.ProxyPoolService/StopProxyPoolAll"
	ProxyPoolService_TestProxyPoolAll_FullMethodName      = "/v2raypool.ProxyPoolService/TestProxyPoolAll"
	ProxyPoolService_TestProxyPoolAllForce_FullMethodName = "/v2raypool.ProxyPoolService/TestProxyPoolAllForce"
	ProxyPoolService_KillAllNodes_FullMethodName          = "/v2raypool.ProxyPoolService/KillAllNodes"
	ProxyPoolService_ActiveProxyNode_FullMethodName       = "/v2raypool.ProxyPoolService/ActiveProxyNode"
	ProxyPoolService_UpdateProxySubscribe_FullMethodName  = "/v2raypool.ProxyPoolService/UpdateProxySubscribe"
)

Variables

View Source 
var File_v2raypool_proto protoreflect.FileDescriptor
View Source 
var ProxyPoolService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2raypool.ProxyPoolService",
	HandlerType: (*ProxyPoolServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetProxyNodes",
			Handler:    _ProxyPoolService_GetProxyNodes_Handler,
		},
		{
			MethodName: "GetProxyNodesByDomain",
			Handler:    _ProxyPoolService_GetProxyNodesByDomain_Handler,
		},
		{
			MethodName: "SetTestUrl",
			Handler:    _ProxyPoolService_SetTestUrl_Handler,
		},
		{
			MethodName: "StartProxyPoolAll",
			Handler:    _ProxyPoolService_StartProxyPoolAll_Handler,
		},
		{
			MethodName: "StopProxyPoolAll",
			Handler:    _ProxyPoolService_StopProxyPoolAll_Handler,
		},
		{
			MethodName: "TestProxyPoolAll",
			Handler:    _ProxyPoolService_TestProxyPoolAll_Handler,
		},
		{
			MethodName: "TestProxyPoolAllForce",
			Handler:    _ProxyPoolService_TestProxyPoolAllForce_Handler,
		},
		{
			MethodName: "KillAllNodes",
			Handler:    _ProxyPoolService_KillAllNodes_Handler,
		},
		{
			MethodName: "ActiveProxyNode",
			Handler:    _ProxyPoolService_ActiveProxyNode_Handler,
		},
		{
			MethodName: "UpdateProxySubscribe",
			Handler:    _ProxyPoolService_UpdateProxySubscribe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v2raypool.proto",
}

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

Functions

func RegisterProxyPoolServiceServer 

func RegisterProxyPoolServiceServer(s grpc.ServiceRegistrar, srv ProxyPoolServiceServer)

Types

type KillNodesResult 

type KillNodesResult struct {
	Status  uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Msg     string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Total   uint32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	Runport uint32 `protobuf:"varint,4,opt,name=runport,proto3" json:"runport,omitempty"`
	Kill    uint32 `protobuf:"varint,5,opt,name=kill,proto3" json:"kill,omitempty"`
	Fail    uint32 `protobuf:"varint,6,opt,name=fail,proto3" json:"fail,omitempty"`
	// contains filtered or unexported fields
}

func (*KillNodesResult) Descriptor deprecated 

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

Deprecated: Use KillNodesResult.ProtoReflect.Descriptor instead.

func (*KillNodesResult) GetFail 

func (x *KillNodesResult) GetFail() uint32

func (*KillNodesResult) GetKill 

func (x *KillNodesResult) GetKill() uint32

func (*KillNodesResult) GetMsg 

func (x *KillNodesResult) GetMsg() string

func (*KillNodesResult) GetRunport 

func (x *KillNodesResult) GetRunport() uint32

func (*KillNodesResult) GetStatus 

func (x *KillNodesResult) GetStatus() uint32

func (*KillNodesResult) GetTotal 

func (x *KillNodesResult) GetTotal() uint32

func (*KillNodesResult) ProtoMessage 

func (*KillNodesResult) ProtoMessage()

func (*KillNodesResult) ProtoReflect 

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

func (*KillNodesResult) Reset 

func (x *KillNodesResult) Reset()

func (*KillNodesResult) String 

func (x *KillNodesResult) String() string

type OptRequest 

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

func (*OptRequest) Descriptor deprecated 

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

Deprecated: Use OptRequest.ProtoReflect.Descriptor instead.

func (*OptRequest) ProtoMessage 

func (*OptRequest) ProtoMessage()

func (*OptRequest) ProtoReflect 

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

func (*OptRequest) Reset 

func (x *OptRequest) Reset()

func (*OptRequest) String 

func (x *OptRequest) String() string

type OptRequestDomain 

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

func (*OptRequestDomain) Descriptor deprecated 

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

Deprecated: Use OptRequestDomain.ProtoReflect.Descriptor instead.

func (*OptRequestDomain) GetDomain 

func (x *OptRequestDomain) GetDomain() string

func (*OptRequestDomain) ProtoMessage 

func (*OptRequestDomain) ProtoMessage()

func (*OptRequestDomain) ProtoReflect 

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

func (*OptRequestDomain) Reset 

func (x *OptRequestDomain) Reset()

func (*OptRequestDomain) String 

func (x *OptRequestDomain) String() string

type OptRequestUrl 

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

func (*OptRequestUrl) Descriptor deprecated 

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

Deprecated: Use OptRequestUrl.ProtoReflect.Descriptor instead.

func (*OptRequestUrl) GetUrl 

func (x *OptRequestUrl) GetUrl() string

func (*OptRequestUrl) ProtoMessage 

func (*OptRequestUrl) ProtoMessage()

func (*OptRequestUrl) ProtoReflect 

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

func (*OptRequestUrl) Reset 

func (x *OptRequestUrl) Reset()

func (*OptRequestUrl) String 

func (x *OptRequestUrl) String() string

type OptResult 

type OptResult struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*OptResult) Descriptor deprecated 

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

Deprecated: Use OptResult.ProtoReflect.Descriptor instead.

func (*OptResult) GetMsg 

func (x *OptResult) GetMsg() string

func (*OptResult) GetStatus 

func (x *OptResult) GetStatus() uint32

func (*OptResult) ProtoMessage 

func (*OptResult) ProtoMessage()

func (*OptResult) ProtoReflect 

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

func (*OptResult) Reset 

func (x *OptResult) Reset()

func (*OptResult) String 

func (x *OptResult) String() string

type ProxyNode 

type ProxyNode struct {
	Index      uint32  `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Id         string  `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	LocalPort  uint32  `protobuf:"varint,3,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
	Speed      float32 `protobuf:"fixed32,4,opt,name=speed,proto3" json:"speed,omitempty"`
	Title      string  `protobuf:"bytes,5,opt,name=title,proto3" json:"title,omitempty"`
	LocalAddr  string  `protobuf:"bytes,6,opt,name=local_addr,json=localAddr,proto3" json:"local_addr,omitempty"`
	RemoteAddr string  `protobuf:"bytes,7,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	IsRunning  bool    `protobuf:"varint,8,opt,name=is_running,json=isRunning,proto3" json:"is_running,omitempty"`
	IsOk       bool    `protobuf:"varint,9,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	TestAt     string  `protobuf:"bytes,10,opt,name=test_at,json=testAt,proto3" json:"test_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyNode) Descriptor deprecated 

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

Deprecated: Use ProxyNode.ProtoReflect.Descriptor instead.

func (*ProxyNode) GetId 

func (x *ProxyNode) GetId() string

func (*ProxyNode) GetIndex 

func (x *ProxyNode) GetIndex() uint32

func (*ProxyNode) GetIsOk 

func (x *ProxyNode) GetIsOk() bool

func (*ProxyNode) GetIsRunning 

func (x *ProxyNode) GetIsRunning() bool

func (*ProxyNode) GetLocalAddr 

func (x *ProxyNode) GetLocalAddr() string

func (*ProxyNode) GetLocalPort 

func (x *ProxyNode) GetLocalPort() uint32

func (*ProxyNode) GetRemoteAddr 

func (x *ProxyNode) GetRemoteAddr() string

func (*ProxyNode) GetSpeed 

func (x *ProxyNode) GetSpeed() float32

func (*ProxyNode) GetTestAt 

func (x *ProxyNode) GetTestAt() string

func (*ProxyNode) GetTitle 

func (x *ProxyNode) GetTitle() string

func (*ProxyNode) ProtoMessage 

func (*ProxyNode) ProtoMessage()

func (*ProxyNode) ProtoReflect 

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

func (*ProxyNode) Reset 

func (x *ProxyNode) Reset()

func (*ProxyNode) String 

func (x *ProxyNode) String() string

type ProxyNodes 

type ProxyNodes struct {
	Items []*ProxyNode `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyNodes) Descriptor deprecated 

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

Deprecated: Use ProxyNodes.ProtoReflect.Descriptor instead.

func (*ProxyNodes) GetItems 

func (x *ProxyNodes) GetItems() []*ProxyNode

func (*ProxyNodes) ProtoMessage 

func (*ProxyNodes) ProtoMessage()

func (*ProxyNodes) ProtoReflect 

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

func (*ProxyNodes) Reset 

func (x *ProxyNodes) Reset()

func (*ProxyNodes) String 

func (x *ProxyNodes) String() string

type ProxyNodes_OptResult 

type ProxyNodes_OptResult struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyNodes_OptResult) Descriptor deprecated 

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

Deprecated: Use ProxyNodes_OptResult.ProtoReflect.Descriptor instead.

func (*ProxyNodes_OptResult) GetMsg 

func (x *ProxyNodes_OptResult) GetMsg() string

func (*ProxyNodes_OptResult) GetStatus 

func (x *ProxyNodes_OptResult) GetStatus() uint32

func (*ProxyNodes_OptResult) ProtoMessage 

func (*ProxyNodes_OptResult) ProtoMessage()

func (*ProxyNodes_OptResult) ProtoReflect 

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

func (*ProxyNodes_OptResult) Reset 

func (x *ProxyNodes_OptResult) Reset()

func (*ProxyNodes_OptResult) String 

func (x *ProxyNodes_OptResult) String() string

type ProxyPoolServiceClient 

type ProxyPoolServiceClient interface {
	GetProxyNodes(ctx context.Context, in *ProxyNode, opts ...grpc.CallOption) (*ProxyNodes, error)
	GetProxyNodesByDomain(ctx context.Context, in *OptRequestDomain, opts ...grpc.CallOption) (*ProxyNodes, error)
	SetTestUrl(ctx context.Context, in *OptRequestUrl, opts ...grpc.CallOption) (*OptResult, error)
	StartProxyPoolAll(ctx context.Context, in *OptRequest, opts ...grpc.CallOption) (*OptResult, error)
	StopProxyPoolAll(ctx context.Context, in *OptRequest, opts ...grpc.CallOption) (*OptResult, error)
	TestProxyPoolAll(ctx context.Context, in *OptRequest, opts ...grpc.CallOption) (*OptResult, error)
	TestProxyPoolAllForce(ctx context.Context, in *OptRequest, opts ...grpc.CallOption) (*OptResult, error)
	KillAllNodes(ctx context.Context, in *OptRequest, opts ...grpc.CallOption) (*KillNodesResult, error)
	ActiveProxyNode(ctx context.Context, in *ProxyNode, opts ...grpc.CallOption) (*OptResult, error)
	UpdateProxySubscribe(ctx context.Context, in *OptRequest, opts ...grpc.CallOption) (*UpdateSubscribeResult, error)
}

ProxyPoolServiceClient is the client API for ProxyPoolService 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 NewProxyPoolServiceClient 

func NewProxyPoolServiceClient(cc grpc.ClientConnInterface) ProxyPoolServiceClient

type ProxyPoolServiceServer 

type ProxyPoolServiceServer interface {
	GetProxyNodes(context.Context, *ProxyNode) (*ProxyNodes, error)
	GetProxyNodesByDomain(context.Context, *OptRequestDomain) (*ProxyNodes, error)
	SetTestUrl(context.Context, *OptRequestUrl) (*OptResult, error)
	StartProxyPoolAll(context.Context, *OptRequest) (*OptResult, error)
	StopProxyPoolAll(context.Context, *OptRequest) (*OptResult, error)
	TestProxyPoolAll(context.Context, *OptRequest) (*OptResult, error)
	TestProxyPoolAllForce(context.Context, *OptRequest) (*OptResult, error)
	KillAllNodes(context.Context, *OptRequest) (*KillNodesResult, error)
	ActiveProxyNode(context.Context, *ProxyNode) (*OptResult, error)
	UpdateProxySubscribe(context.Context, *OptRequest) (*UpdateSubscribeResult, error)
	// contains filtered or unexported methods
}

ProxyPoolServiceServer is the server API for ProxyPoolService service. All implementations must embed UnimplementedProxyPoolServiceServer for forward compatibility

type UnimplementedProxyPoolServiceServer 

type UnimplementedProxyPoolServiceServer struct {
}

UnimplementedProxyPoolServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyPoolServiceServer) ActiveProxyNode 

func (UnimplementedProxyPoolServiceServer) ActiveProxyNode(context.Context, *ProxyNode) (*OptResult, error)

func (UnimplementedProxyPoolServiceServer) GetProxyNodes 

func (UnimplementedProxyPoolServiceServer) GetProxyNodes(context.Context, *ProxyNode) (*ProxyNodes, error)

func (UnimplementedProxyPoolServiceServer) GetProxyNodesByDomain 

func (UnimplementedProxyPoolServiceServer) GetProxyNodesByDomain(context.Context, *OptRequestDomain) (*ProxyNodes, error)

func (UnimplementedProxyPoolServiceServer) KillAllNodes 

func (UnimplementedProxyPoolServiceServer) KillAllNodes(context.Context, *OptRequest) (*KillNodesResult, error)

func (UnimplementedProxyPoolServiceServer) SetTestUrl 

func (UnimplementedProxyPoolServiceServer) SetTestUrl(context.Context, *OptRequestUrl) (*OptResult, error)

func (UnimplementedProxyPoolServiceServer) StartProxyPoolAll 

func (UnimplementedProxyPoolServiceServer) StartProxyPoolAll(context.Context, *OptRequest) (*OptResult, error)

func (UnimplementedProxyPoolServiceServer) StopProxyPoolAll 

func (UnimplementedProxyPoolServiceServer) StopProxyPoolAll(context.Context, *OptRequest) (*OptResult, error)

func (UnimplementedProxyPoolServiceServer) TestProxyPoolAll 

func (UnimplementedProxyPoolServiceServer) TestProxyPoolAll(context.Context, *OptRequest) (*OptResult, error)

func (UnimplementedProxyPoolServiceServer) TestProxyPoolAllForce 

func (UnimplementedProxyPoolServiceServer) TestProxyPoolAllForce(context.Context, *OptRequest) (*OptResult, error)

func (UnimplementedProxyPoolServiceServer) UpdateProxySubscribe 

func (UnimplementedProxyPoolServiceServer) UpdateProxySubscribe(context.Context, *OptRequest) (*UpdateSubscribeResult, error)

type UnsafeProxyPoolServiceServer 

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

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

type UpdateSubscribeResult 

type UpdateSubscribeResult struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Total  uint32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	Add    uint32 `protobuf:"varint,4,opt,name=add,proto3" json:"add,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSubscribeResult) Descriptor deprecated 

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

Deprecated: Use UpdateSubscribeResult.ProtoReflect.Descriptor instead.

func (*UpdateSubscribeResult) GetAdd 

func (x *UpdateSubscribeResult) GetAdd() uint32

func (*UpdateSubscribeResult) GetMsg 

func (x *UpdateSubscribeResult) GetMsg() string

func (*UpdateSubscribeResult) GetStatus 

func (x *UpdateSubscribeResult) GetStatus() uint32

func (*UpdateSubscribeResult) GetTotal 

func (x *UpdateSubscribeResult) GetTotal() uint32

func (*UpdateSubscribeResult) ProtoMessage 

func (*UpdateSubscribeResult) ProtoMessage()

func (*UpdateSubscribeResult) ProtoReflect 

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

func (*UpdateSubscribeResult) Reset 

func (x *UpdateSubscribeResult) Reset()

func (*UpdateSubscribeResult) String 

func (x *UpdateSubscribeResult) String() string

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.