serverv1

package
v0.0.0-...-63b82f0 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2025 License: MIT Imports: 18 Imported by: 0

Documentation

Overview

Package serverv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package serverv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ServerManageerService_GetHTTPRouterList_FullMethodName   = "/gatewayapis.server.v1.ServerManageerService/GetHTTPRouterList"
	ServerManageerService_GetHTTPRouter_FullMethodName       = "/gatewayapis.server.v1.ServerManageerService/GetHTTPRouter"
	ServerManageerService_PostOrPutHTTPRouter_FullMethodName = "/gatewayapis.server.v1.ServerManageerService/PostOrPutHTTPRouter"
	ServerManageerService_DeleteHTTPRouter_FullMethodName    = "/gatewayapis.server.v1.ServerManageerService/DeleteHTTPRouter"
)
View Source 
const (
	ServerRegisterService_PostRegistServiceInstance_FullMethodName = "/gatewayapis.server.v1.ServerRegisterService/PostRegistServiceInstance"
	ServerRegisterService_PostRegistHTTPRouters_FullMethodName     = "/gatewayapis.server.v1.ServerRegisterService/PostRegistHTTPRouters"
	ServerRegisterService_PostRegistGRPCMethods_FullMethodName     = "/gatewayapis.server.v1.ServerRegisterService/PostRegistGRPCMethods"
)

Variables

View Source 
var File_gatewayapis_server_v1_defined_proto protoreflect.FileDescriptor
View Source 
var File_gatewayapis_server_v1_manager_proto protoreflect.FileDescriptor
View Source 
var File_gatewayapis_server_v1_register_proto protoreflect.FileDescriptor
View Source 
var ServerManageerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gatewayapis.server.v1.ServerManageerService",
	HandlerType: (*ServerManageerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetHTTPRouterList",
			Handler:    _ServerManageerService_GetHTTPRouterList_Handler,
		},
		{
			MethodName: "GetHTTPRouter",
			Handler:    _ServerManageerService_GetHTTPRouter_Handler,
		},
		{
			MethodName: "PostOrPutHTTPRouter",
			Handler:    _ServerManageerService_PostOrPutHTTPRouter_Handler,
		},
		{
			MethodName: "DeleteHTTPRouter",
			Handler:    _ServerManageerService_DeleteHTTPRouter_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gatewayapis/server/v1/manager.proto",
}

ServerManageerService_ServiceDesc is the grpc.ServiceDesc for ServerManageerService 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 ServerRegisterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gatewayapis.server.v1.ServerRegisterService",
	HandlerType: (*ServerRegisterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PostRegistServiceInstance",
			Handler:    _ServerRegisterService_PostRegistServiceInstance_Handler,
		},
		{
			MethodName: "PostRegistHTTPRouters",
			Handler:    _ServerRegisterService_PostRegistHTTPRouters_Handler,
		},
		{
			MethodName: "PostRegistGRPCMethods",
			Handler:    _ServerRegisterService_PostRegistGRPCMethods_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gatewayapis/server/v1/register.proto",
}

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

Functions

func RegisterServerManageerServiceHandler 

func RegisterServerManageerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterServerManageerServiceHandler registers the http handlers for service ServerManageerService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterServerManageerServiceHandlerClient 

func RegisterServerManageerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ServerManageerServiceClient) error

RegisterServerManageerServiceHandlerClient registers the http handlers for service ServerManageerService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ServerManageerServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ServerManageerServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ServerManageerServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterServerManageerServiceHandlerFromEndpoint 

func RegisterServerManageerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterServerManageerServiceHandlerFromEndpoint is same as RegisterServerManageerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterServerManageerServiceHandlerServer 

func RegisterServerManageerServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ServerManageerServiceServer) error

RegisterServerManageerServiceHandlerServer registers the http handlers for service ServerManageerService to "mux". UnaryRPC :call ServerManageerServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterServerManageerServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterServerManageerServiceServer 

func RegisterServerManageerServiceServer(s grpc.ServiceRegistrar, srv ServerManageerServiceServer)

func RegisterServerRegisterServiceHandler 

func RegisterServerRegisterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterServerRegisterServiceHandler registers the http handlers for service ServerRegisterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterServerRegisterServiceHandlerClient 

func RegisterServerRegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ServerRegisterServiceClient) error

RegisterServerRegisterServiceHandlerClient registers the http handlers for service ServerRegisterService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ServerRegisterServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ServerRegisterServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ServerRegisterServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterServerRegisterServiceHandlerFromEndpoint 

func RegisterServerRegisterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterServerRegisterServiceHandlerFromEndpoint is same as RegisterServerRegisterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterServerRegisterServiceHandlerServer 

func RegisterServerRegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ServerRegisterServiceServer) error

RegisterServerRegisterServiceHandlerServer registers the http handlers for service ServerRegisterService to "mux". UnaryRPC :call ServerRegisterServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterServerRegisterServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterServerRegisterServiceServer 

func RegisterServerRegisterServiceServer(s grpc.ServiceRegistrar, srv ServerRegisterServiceServer)

Types

type DeleteHTTPRouterRequest 

type DeleteHTTPRouterRequest struct {

	// 服务名称
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// 方法
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// 挂载地址
	ServePath string `protobuf:"bytes,3,opt,name=servePath,proto3" json:"servePath,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteHTTPRouterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteHTTPRouterRequest.ProtoReflect.Descriptor instead.

func (*DeleteHTTPRouterRequest) GetMethod 

func (x *DeleteHTTPRouterRequest) GetMethod() string

func (*DeleteHTTPRouterRequest) GetServePath 

func (x *DeleteHTTPRouterRequest) GetServePath() string

func (*DeleteHTTPRouterRequest) GetService 

func (x *DeleteHTTPRouterRequest) GetService() string

func (*DeleteHTTPRouterRequest) ProtoMessage 

func (*DeleteHTTPRouterRequest) ProtoMessage()

func (*DeleteHTTPRouterRequest) ProtoReflect 

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

func (*DeleteHTTPRouterRequest) Reset 

func (x *DeleteHTTPRouterRequest) Reset()

func (*DeleteHTTPRouterRequest) String 

func (x *DeleteHTTPRouterRequest) String() string

type DeleteHTTPRouterResponse 

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

func (*DeleteHTTPRouterResponse) Descriptor deprecated 

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

Deprecated: Use DeleteHTTPRouterResponse.ProtoReflect.Descriptor instead.

func (*DeleteHTTPRouterResponse) ProtoMessage 

func (*DeleteHTTPRouterResponse) ProtoMessage()

func (*DeleteHTTPRouterResponse) ProtoReflect 

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

func (*DeleteHTTPRouterResponse) Reset 

func (x *DeleteHTTPRouterResponse) Reset()

func (*DeleteHTTPRouterResponse) String 

func (x *DeleteHTTPRouterResponse) String() string

type GRPCMethod 

type GRPCMethod struct {

	// 服务名称
	// Service names include the package names, in the form of <package>.<service>.
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// 方法名称
	MethodName     string `protobuf:"bytes,2,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	IsClientStream bool   `protobuf:"varint,3,opt,name=isClientStream,proto3" json:"isClientStream,omitempty"`
	IsServerStream bool   `protobuf:"varint,4,opt,name=isServerStream,proto3" json:"isServerStream,omitempty"`
	// contains filtered or unexported fields
}

GRPC路由 GRPC方法

func (*GRPCMethod) Descriptor deprecated 

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

Deprecated: Use GRPCMethod.ProtoReflect.Descriptor instead.

func (*GRPCMethod) GetIsClientStream 

func (x *GRPCMethod) GetIsClientStream() bool

func (*GRPCMethod) GetIsServerStream 

func (x *GRPCMethod) GetIsServerStream() bool

func (*GRPCMethod) GetMethodName 

func (x *GRPCMethod) GetMethodName() string

func (*GRPCMethod) GetServiceName 

func (x *GRPCMethod) GetServiceName() string

func (*GRPCMethod) ProtoMessage 

func (*GRPCMethod) ProtoMessage()

func (*GRPCMethod) ProtoReflect 

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

func (*GRPCMethod) Reset 

func (x *GRPCMethod) Reset()

func (*GRPCMethod) String 

func (x *GRPCMethod) String() string

type GetHTTPRouterListRequest 

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

func (*GetHTTPRouterListRequest) Descriptor deprecated 

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

Deprecated: Use GetHTTPRouterListRequest.ProtoReflect.Descriptor instead.

func (*GetHTTPRouterListRequest) ProtoMessage 

func (*GetHTTPRouterListRequest) ProtoMessage()

func (*GetHTTPRouterListRequest) ProtoReflect 

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

func (*GetHTTPRouterListRequest) Reset 

func (x *GetHTTPRouterListRequest) Reset()

func (*GetHTTPRouterListRequest) String 

func (x *GetHTTPRouterListRequest) String() string

type GetHTTPRouterListResponse 

type GetHTTPRouterListResponse struct {
	Routers []*HTTPRouter `protobuf:"bytes,1,rep,name=routers,proto3" json:"routers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHTTPRouterListResponse) Descriptor deprecated 

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

Deprecated: Use GetHTTPRouterListResponse.ProtoReflect.Descriptor instead.

func (*GetHTTPRouterListResponse) GetRouters 

func (x *GetHTTPRouterListResponse) GetRouters() []*HTTPRouter

func (*GetHTTPRouterListResponse) ProtoMessage 

func (*GetHTTPRouterListResponse) ProtoMessage()

func (*GetHTTPRouterListResponse) ProtoReflect 

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

func (*GetHTTPRouterListResponse) Reset 

func (x *GetHTTPRouterListResponse) Reset()

func (*GetHTTPRouterListResponse) String 

func (x *GetHTTPRouterListResponse) String() string

type GetHTTPRouterRequest 

type GetHTTPRouterRequest struct {

	// 服务名称
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// 方法
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// 挂载地址
	ServePath string `protobuf:"bytes,3,opt,name=servePath,proto3" json:"servePath,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHTTPRouterRequest) Descriptor deprecated 

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

Deprecated: Use GetHTTPRouterRequest.ProtoReflect.Descriptor instead.

func (*GetHTTPRouterRequest) GetMethod 

func (x *GetHTTPRouterRequest) GetMethod() string

func (*GetHTTPRouterRequest) GetServePath 

func (x *GetHTTPRouterRequest) GetServePath() string

func (*GetHTTPRouterRequest) GetService 

func (x *GetHTTPRouterRequest) GetService() string

func (*GetHTTPRouterRequest) ProtoMessage 

func (*GetHTTPRouterRequest) ProtoMessage()

func (*GetHTTPRouterRequest) ProtoReflect 

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

func (*GetHTTPRouterRequest) Reset 

func (x *GetHTTPRouterRequest) Reset()

func (*GetHTTPRouterRequest) String 

func (x *GetHTTPRouterRequest) String() string

type GetHTTPRouterResponse 

type GetHTTPRouterResponse struct {
	Error int32       `protobuf:"varint,1,opt,name=error,proto3" json:"error,omitempty"`
	Msg   string      `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Data  *HTTPRouter `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHTTPRouterResponse) Descriptor deprecated 

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

Deprecated: Use GetHTTPRouterResponse.ProtoReflect.Descriptor instead.

func (*GetHTTPRouterResponse) GetData 

func (x *GetHTTPRouterResponse) GetData() *HTTPRouter

func (*GetHTTPRouterResponse) GetError 

func (x *GetHTTPRouterResponse) GetError() int32

func (*GetHTTPRouterResponse) GetMsg 

func (x *GetHTTPRouterResponse) GetMsg() string

func (*GetHTTPRouterResponse) ProtoMessage 

func (*GetHTTPRouterResponse) ProtoMessage()

func (*GetHTTPRouterResponse) ProtoReflect 

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

func (*GetHTTPRouterResponse) Reset 

func (x *GetHTTPRouterResponse) Reset()

func (*GetHTTPRouterResponse) String 

func (x *GetHTTPRouterResponse) String() string

type HTTPRouter 

type HTTPRouter struct {

	// 服务名称
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// 方法
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// 远端path，即服务内地址
	RemotePath string `protobuf:"bytes,3,opt,name=remotePath,proto3" json:"remotePath,omitempty"`
	// 挂载地址
	ServePath string `protobuf:"bytes,4,opt,name=servePath,proto3" json:"servePath,omitempty"`
	// 是否只允许内部应用访问
	IsPrivate bool `protobuf:"varint,5,opt,name=isPrivate,proto3" json:"isPrivate,omitempty"`
	// 是否需要鉴权后才能访问
	NeedAuthorized bool `protobuf:"varint,6,opt,name=needAuthorized,proto3" json:"needAuthorized,omitempty"`
	// 公共缓存
	PublicCache bool `protobuf:"varint,7,opt,name=publicCache,proto3" json:"publicCache,omitempty"`
	// 缓存过期时间
	CacheExpire int32 `protobuf:"varint,8,opt,name=cacheExpire,proto3" json:"cacheExpire,omitempty"`
	// 客户端到服务请求可传递的请求头
	DirectThroughRequestHeaders []string `protobuf:"bytes,9,rep,name=directThroughRequestHeaders,proto3" json:"directThroughRequestHeaders,omitempty"`
	// 服务到客户端返回可传递的响应头
	DirectThroughResponseHeaders []string `protobuf:"bytes,10,rep,name=directThroughResponseHeaders,proto3" json:"directThroughResponseHeaders,omitempty"`
	// 是否启用
	Enable bool `protobuf:"varint,11,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

HTTP路由注册

func (*HTTPRouter) Descriptor deprecated 

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

Deprecated: Use HTTPRouter.ProtoReflect.Descriptor instead.

func (*HTTPRouter) GetCacheExpire 

func (x *HTTPRouter) GetCacheExpire() int32

func (*HTTPRouter) GetDirectThroughRequestHeaders 

func (x *HTTPRouter) GetDirectThroughRequestHeaders() []string

func (*HTTPRouter) GetDirectThroughResponseHeaders 

func (x *HTTPRouter) GetDirectThroughResponseHeaders() []string

func (*HTTPRouter) GetEnable 

func (x *HTTPRouter) GetEnable() bool

func (*HTTPRouter) GetIsPrivate 

func (x *HTTPRouter) GetIsPrivate() bool

func (*HTTPRouter) GetMethod 

func (x *HTTPRouter) GetMethod() string

func (*HTTPRouter) GetNeedAuthorized 

func (x *HTTPRouter) GetNeedAuthorized() bool

func (*HTTPRouter) GetPublicCache 

func (x *HTTPRouter) GetPublicCache() bool

func (*HTTPRouter) GetRemotePath 

func (x *HTTPRouter) GetRemotePath() string

func (*HTTPRouter) GetServePath 

func (x *HTTPRouter) GetServePath() string

func (*HTTPRouter) GetService 

func (x *HTTPRouter) GetService() string

func (*HTTPRouter) ProtoMessage 

func (*HTTPRouter) ProtoMessage()

func (*HTTPRouter) ProtoReflect 

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

func (*HTTPRouter) Reset 

func (x *HTTPRouter) Reset()

func (*HTTPRouter) String 

func (x *HTTPRouter) String() string

type PostOrPutHTTPRouterRequest 

type PostOrPutHTTPRouterRequest struct {
	Router *HTTPRouter `protobuf:"bytes,1,opt,name=router,proto3" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*PostOrPutHTTPRouterRequest) Descriptor deprecated 

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

Deprecated: Use PostOrPutHTTPRouterRequest.ProtoReflect.Descriptor instead.

func (*PostOrPutHTTPRouterRequest) GetRouter 

func (x *PostOrPutHTTPRouterRequest) GetRouter() *HTTPRouter

func (*PostOrPutHTTPRouterRequest) ProtoMessage 

func (*PostOrPutHTTPRouterRequest) ProtoMessage()

func (*PostOrPutHTTPRouterRequest) ProtoReflect 

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

func (*PostOrPutHTTPRouterRequest) Reset 

func (x *PostOrPutHTTPRouterRequest) Reset()

func (*PostOrPutHTTPRouterRequest) String 

func (x *PostOrPutHTTPRouterRequest) String() string

type PostOrPutHTTPRouterResponse 

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

func (*PostOrPutHTTPRouterResponse) Descriptor deprecated 

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

Deprecated: Use PostOrPutHTTPRouterResponse.ProtoReflect.Descriptor instead.

func (*PostOrPutHTTPRouterResponse) ProtoMessage 

func (*PostOrPutHTTPRouterResponse) ProtoMessage()

func (*PostOrPutHTTPRouterResponse) ProtoReflect 

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

func (*PostOrPutHTTPRouterResponse) Reset 

func (x *PostOrPutHTTPRouterResponse) Reset()

func (*PostOrPutHTTPRouterResponse) String 

func (x *PostOrPutHTTPRouterResponse) String() string

type PostRegistGRPCMethodsRequest 

type PostRegistGRPCMethodsRequest struct {
	Methods []*GRPCMethod `protobuf:"bytes,1,rep,name=methods,proto3" json:"methods,omitempty"`
	// contains filtered or unexported fields
}

func (*PostRegistGRPCMethodsRequest) Descriptor deprecated 

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

Deprecated: Use PostRegistGRPCMethodsRequest.ProtoReflect.Descriptor instead.

func (*PostRegistGRPCMethodsRequest) FormGRPCServer 

func (x *PostRegistGRPCMethodsRequest) FormGRPCServer(server interface {
	GetServiceInfo() map[string]grpc.ServiceInfo
})

func (*PostRegistGRPCMethodsRequest) GetMethods 

func (x *PostRegistGRPCMethodsRequest) GetMethods() []*GRPCMethod

func (*PostRegistGRPCMethodsRequest) ProtoMessage 

func (*PostRegistGRPCMethodsRequest) ProtoMessage()

func (*PostRegistGRPCMethodsRequest) ProtoReflect 

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

func (*PostRegistGRPCMethodsRequest) Reset 

func (x *PostRegistGRPCMethodsRequest) Reset()

func (*PostRegistGRPCMethodsRequest) String 

func (x *PostRegistGRPCMethodsRequest) String() string

type PostRegistGRPCMethodsResponse 

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

func (*PostRegistGRPCMethodsResponse) Descriptor deprecated 

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

Deprecated: Use PostRegistGRPCMethodsResponse.ProtoReflect.Descriptor instead.

func (*PostRegistGRPCMethodsResponse) ProtoMessage 

func (*PostRegistGRPCMethodsResponse) ProtoMessage()

func (*PostRegistGRPCMethodsResponse) ProtoReflect 

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

func (*PostRegistGRPCMethodsResponse) Reset 

func (x *PostRegistGRPCMethodsResponse) Reset()

func (*PostRegistGRPCMethodsResponse) String 

func (x *PostRegistGRPCMethodsResponse) String() string

type PostRegistHTTPRoutersRequest 

type PostRegistHTTPRoutersRequest struct {
	Routers []*HTTPRouter `protobuf:"bytes,1,rep,name=routers,proto3" json:"routers,omitempty"`
	// contains filtered or unexported fields
}

func (*PostRegistHTTPRoutersRequest) Descriptor deprecated 

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

Deprecated: Use PostRegistHTTPRoutersRequest.ProtoReflect.Descriptor instead.

func (*PostRegistHTTPRoutersRequest) FromGinEngine 

func (x *PostRegistHTTPRoutersRequest) FromGinEngine(e *gin.Engine)

func (*PostRegistHTTPRoutersRequest) GetRouters 

func (x *PostRegistHTTPRoutersRequest) GetRouters() []*HTTPRouter

func (*PostRegistHTTPRoutersRequest) ProtoMessage 

func (*PostRegistHTTPRoutersRequest) ProtoMessage()

func (*PostRegistHTTPRoutersRequest) ProtoReflect 

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

func (*PostRegistHTTPRoutersRequest) Reset 

func (x *PostRegistHTTPRoutersRequest) Reset()

func (*PostRegistHTTPRoutersRequest) String 

func (x *PostRegistHTTPRoutersRequest) String() string

type PostRegistHTTPRoutersResponse 

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

func (*PostRegistHTTPRoutersResponse) Descriptor deprecated 

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

Deprecated: Use PostRegistHTTPRoutersResponse.ProtoReflect.Descriptor instead.

func (*PostRegistHTTPRoutersResponse) ProtoMessage 

func (*PostRegistHTTPRoutersResponse) ProtoMessage()

func (*PostRegistHTTPRoutersResponse) ProtoReflect 

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

func (*PostRegistHTTPRoutersResponse) Reset 

func (x *PostRegistHTTPRoutersResponse) Reset()

func (*PostRegistHTTPRoutersResponse) String 

func (x *PostRegistHTTPRoutersResponse) String() string

type PostRegistServiceInstanceRequest 

type PostRegistServiceInstanceRequest struct {
	Instance *ServiceInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*PostRegistServiceInstanceRequest) Descriptor deprecated 

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

Deprecated: Use PostRegistServiceInstanceRequest.ProtoReflect.Descriptor instead.

func (*PostRegistServiceInstanceRequest) GetInstance 

func (x *PostRegistServiceInstanceRequest) GetInstance() *ServiceInstance

func (*PostRegistServiceInstanceRequest) ProtoMessage 

func (*PostRegistServiceInstanceRequest) ProtoMessage()

func (*PostRegistServiceInstanceRequest) ProtoReflect 

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

func (*PostRegistServiceInstanceRequest) Reset 

func (x *PostRegistServiceInstanceRequest) Reset()

func (*PostRegistServiceInstanceRequest) String 

func (x *PostRegistServiceInstanceRequest) String() string

type PostRegistServiceInstanceResponse 

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

func (*PostRegistServiceInstanceResponse) Descriptor deprecated 

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

Deprecated: Use PostRegistServiceInstanceResponse.ProtoReflect.Descriptor instead.

func (*PostRegistServiceInstanceResponse) ProtoMessage 

func (*PostRegistServiceInstanceResponse) ProtoMessage()

func (*PostRegistServiceInstanceResponse) ProtoReflect 

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

func (*PostRegistServiceInstanceResponse) Reset 

func (x *PostRegistServiceInstanceResponse) Reset()

func (*PostRegistServiceInstanceResponse) String 

func (x *PostRegistServiceInstanceResponse) String() string

type ServerManageerServiceClient 

type ServerManageerServiceClient interface {
	// 获取可管理的所有HTTP路由
	GetHTTPRouterList(ctx context.Context, in *GetHTTPRouterListRequest, opts ...grpc.CallOption) (*GetHTTPRouterListResponse, error)
	// 查询路由
	GetHTTPRouter(ctx context.Context, in *GetHTTPRouterRequest, opts ...grpc.CallOption) (*GetHTTPRouterResponse, error)
	// 创建或者更新路由
	PostOrPutHTTPRouter(ctx context.Context, in *PostOrPutHTTPRouterRequest, opts ...grpc.CallOption) (*PostOrPutHTTPRouterResponse, error)
	// 删除路由
	DeleteHTTPRouter(ctx context.Context, in *DeleteHTTPRouterRequest, opts ...grpc.CallOption) (*DeleteHTTPRouterResponse, error)
}

ServerManageerServiceClient is the client API for ServerManageerService 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 NewServerManageerServiceClient 

func NewServerManageerServiceClient(cc grpc.ClientConnInterface) ServerManageerServiceClient

type ServerManageerServiceServer 

type ServerManageerServiceServer interface {
	// 获取可管理的所有HTTP路由
	GetHTTPRouterList(context.Context, *GetHTTPRouterListRequest) (*GetHTTPRouterListResponse, error)
	// 查询路由
	GetHTTPRouter(context.Context, *GetHTTPRouterRequest) (*GetHTTPRouterResponse, error)
	// 创建或者更新路由
	PostOrPutHTTPRouter(context.Context, *PostOrPutHTTPRouterRequest) (*PostOrPutHTTPRouterResponse, error)
	// 删除路由
	DeleteHTTPRouter(context.Context, *DeleteHTTPRouterRequest) (*DeleteHTTPRouterResponse, error)
	// contains filtered or unexported methods
}

ServerManageerServiceServer is the server API for ServerManageerService service. All implementations must embed UnimplementedServerManageerServiceServer for forward compatibility.

服务管理端

type ServerRegisterServiceClient 

type ServerRegisterServiceClient interface {
	// 注册服务实例
	PostRegistServiceInstance(ctx context.Context, in *PostRegistServiceInstanceRequest, opts ...grpc.CallOption) (*PostRegistServiceInstanceResponse, error)
	// 注册服务HTTP路由
	PostRegistHTTPRouters(ctx context.Context, in *PostRegistHTTPRoutersRequest, opts ...grpc.CallOption) (*PostRegistHTTPRoutersResponse, error)
	// 注册服务GRPC方法
	PostRegistGRPCMethods(ctx context.Context, in *PostRegistGRPCMethodsRequest, opts ...grpc.CallOption) (*PostRegistGRPCMethodsResponse, error)
}

ServerRegisterServiceClient is the client API for ServerRegisterService 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 NewServerRegisterServiceClient 

func NewServerRegisterServiceClient(cc grpc.ClientConnInterface) ServerRegisterServiceClient

type ServerRegisterServiceServer 

type ServerRegisterServiceServer interface {
	// 注册服务实例
	PostRegistServiceInstance(context.Context, *PostRegistServiceInstanceRequest) (*PostRegistServiceInstanceResponse, error)
	// 注册服务HTTP路由
	PostRegistHTTPRouters(context.Context, *PostRegistHTTPRoutersRequest) (*PostRegistHTTPRoutersResponse, error)
	// 注册服务GRPC方法
	PostRegistGRPCMethods(context.Context, *PostRegistGRPCMethodsRequest) (*PostRegistGRPCMethodsResponse, error)
	// contains filtered or unexported methods
}

ServerRegisterServiceServer is the server API for ServerRegisterService service. All implementations must embed UnimplementedServerRegisterServiceServer for forward compatibility.

服务注册方

type Service 

type Service struct {

	// 服务名称 同时作为ID使用
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// 服务描述
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// 服务路由前缀
	RoutePrefix string `protobuf:"bytes,3,opt,name=route_prefix,json=routePrefix,proto3" json:"route_prefix,omitempty"`
	// contains filtered or unexported fields
}

服务

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetDescription 

func (x *Service) GetDescription() string

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetRoutePrefix 

func (x *Service) GetRoutePrefix() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type ServiceInstance 

type ServiceInstance struct {

	// 实例ID
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// 实例名称
	InstanceName string `protobuf:"bytes,2,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// 服务名称
	ServiceName string `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// contains filtered or unexported fields
}

服务实例

func (*ServiceInstance) Descriptor deprecated 

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

Deprecated: Use ServiceInstance.ProtoReflect.Descriptor instead.

func (*ServiceInstance) GetInstanceId 

func (x *ServiceInstance) GetInstanceId() string

func (*ServiceInstance) GetInstanceName 

func (x *ServiceInstance) GetInstanceName() string

func (*ServiceInstance) GetServiceName 

func (x *ServiceInstance) GetServiceName() string

func (*ServiceInstance) ProtoMessage 

func (*ServiceInstance) ProtoMessage()

func (*ServiceInstance) ProtoReflect 

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

func (*ServiceInstance) Reset 

func (x *ServiceInstance) Reset()

func (*ServiceInstance) String 

func (x *ServiceInstance) String() string

type UnimplementedServerManageerServiceServer 

type UnimplementedServerManageerServiceServer struct{}

UnimplementedServerManageerServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedServerManageerServiceServer) DeleteHTTPRouter 

func (UnimplementedServerManageerServiceServer) DeleteHTTPRouter(context.Context, *DeleteHTTPRouterRequest) (*DeleteHTTPRouterResponse, error)

func (UnimplementedServerManageerServiceServer) GetHTTPRouter 

func (UnimplementedServerManageerServiceServer) GetHTTPRouter(context.Context, *GetHTTPRouterRequest) (*GetHTTPRouterResponse, error)

func (UnimplementedServerManageerServiceServer) GetHTTPRouterList 

func (UnimplementedServerManageerServiceServer) GetHTTPRouterList(context.Context, *GetHTTPRouterListRequest) (*GetHTTPRouterListResponse, error)

func (UnimplementedServerManageerServiceServer) PostOrPutHTTPRouter 

func (UnimplementedServerManageerServiceServer) PostOrPutHTTPRouter(context.Context, *PostOrPutHTTPRouterRequest) (*PostOrPutHTTPRouterResponse, error)

type UnimplementedServerRegisterServiceServer 

type UnimplementedServerRegisterServiceServer struct{}

UnimplementedServerRegisterServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedServerRegisterServiceServer) PostRegistGRPCMethods 

func (UnimplementedServerRegisterServiceServer) PostRegistGRPCMethods(context.Context, *PostRegistGRPCMethodsRequest) (*PostRegistGRPCMethodsResponse, error)

func (UnimplementedServerRegisterServiceServer) PostRegistHTTPRouters 

func (UnimplementedServerRegisterServiceServer) PostRegistHTTPRouters(context.Context, *PostRegistHTTPRoutersRequest) (*PostRegistHTTPRoutersResponse, error)

func (UnimplementedServerRegisterServiceServer) PostRegistServiceInstance 

func (UnimplementedServerRegisterServiceServer) PostRegistServiceInstance(context.Context, *PostRegistServiceInstanceRequest) (*PostRegistServiceInstanceResponse, error)

type UnsafeServerManageerServiceServer 

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

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

type UnsafeServerRegisterServiceServer 

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

UnsafeServerRegisterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServerRegisterServiceServer 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.