serverv1

package
v0.0.0-...-a9153d3 Latest Latest
Warning

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

Go to latest
Published: Mar 3, 2024 License: MIT Imports: 16 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.

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.

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.

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.

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 (*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 (*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 (*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 (*PostRegistGRPCMethodsRequest) Reset

func (x *PostRegistGRPCMethodsRequest) Reset()

func (*PostRegistGRPCMethodsRequest) 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 (*PostRegistGRPCMethodsResponse) Reset

func (x *PostRegistGRPCMethodsResponse) Reset()

func (*PostRegistGRPCMethodsResponse) 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 (*PostRegistHTTPRoutersRequest) Reset

func (x *PostRegistHTTPRoutersRequest) Reset()

func (*PostRegistHTTPRoutersRequest) 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 (*PostRegistHTTPRoutersResponse) Reset

func (x *PostRegistHTTPRoutersResponse) Reset()

func (*PostRegistHTTPRoutersResponse) 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 (*PostRegistServiceInstanceRequest) ProtoMessage

func (*PostRegistServiceInstanceRequest) ProtoMessage()

func (*PostRegistServiceInstanceRequest) ProtoReflect

func (*PostRegistServiceInstanceRequest) Reset

func (*PostRegistServiceInstanceRequest) 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 (*PostRegistServiceInstanceResponse) Reset

func (*PostRegistServiceInstanceResponse) 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.

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.

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.

func (UnimplementedServerManageerServiceServer) DeleteHTTPRouter

func (UnimplementedServerManageerServiceServer) GetHTTPRouter

func (UnimplementedServerManageerServiceServer) GetHTTPRouterList

func (UnimplementedServerManageerServiceServer) PostOrPutHTTPRouter

type UnimplementedServerRegisterServiceServer

type UnimplementedServerRegisterServiceServer struct {
}

UnimplementedServerRegisterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServerRegisterServiceServer) PostRegistGRPCMethods

func (UnimplementedServerRegisterServiceServer) PostRegistHTTPRouters

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.

Jump to

Keyboard shortcuts

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