triple_reflection

package
v3.2.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-triple. DO NOT EDIT.

Source: reflection.proto

Index

Constants

View Source 
const (
	// ServerReflectionName is the fully-qualified name of the ServerReflection service.
	ServerReflectionName = "grpc.reflection.v1alpha.ServerReflection"
)
View Source 
const (
	// ServerReflectionServerReflectionInfoProcedure is the fully-qualified name of the ServerReflection's ServerReflectionInfo RPC.
	ServerReflectionServerReflectionInfoProcedure = "/grpc.reflection.v1alpha.ServerReflection/ServerReflectionInfo"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

Variables

View Source 
var File_reflection_proto protoreflect.FileDescriptor
View Source 
var ServerReflection_ClientInfo = client.ClientInfo{
	InterfaceName: "grpc.reflection.v1alpha.ServerReflection",
	MethodNames:   []string{"ServerReflectionInfo"},
	ConnectionInjectFunc: func(dubboCliRaw interface{}, conn *client.Connection) {
		dubboCli := dubboCliRaw.(*ServerReflectionImpl)
		dubboCli.conn = conn
	},
}
View Source 
var ServerReflection_ServiceInfo = server.ServiceInfo{
	InterfaceName: "grpc.reflection.v1alpha.ServerReflection",
	ServiceType:   (*ServerReflectionHandler)(nil),
	Methods: []server.MethodInfo{
		{
			Name: "ServerReflectionInfo",
			Type: constant.CallBidiStream,
			StreamInitFunc: func(baseStream interface{}) interface{} {
				return &ServerReflectionServerReflectionInfoServer{baseStream.(*triple_protocol.BidiStream)}
			},
			MethodFunc: func(ctx context.Context, args []interface{}, handler interface{}) (interface{}, error) {
				stream := args[0].(ServerReflection_ServerReflectionInfoServer)
				if err := handler.(ServerReflectionHandler).ServerReflectionInfo(ctx, stream); err != nil {
					return nil, err
				}
				return nil, nil
			},
		},
	},
}

Functions

func RegisterServerReflectionHandler 

func RegisterServerReflectionHandler(srv *server.Server, hdlr ServerReflectionHandler, opts ...server.ServiceOption) error

func SetConsumerService 

func SetConsumerService(srv common.RPCService)

func SetProviderService 

func SetProviderService(srv common.RPCService)

Types

type ErrorResponse 

type ErrorResponse struct {

	// This field uses the error codes defined in grpc::StatusCode.
	ErrorCode    int32  `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

The error code and error message sent by the server when an error occurs.

func (*ErrorResponse) Descriptor deprecated 

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

Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.

func (*ErrorResponse) GetErrorCode 

func (x *ErrorResponse) GetErrorCode() int32

func (*ErrorResponse) GetErrorMessage 

func (x *ErrorResponse) GetErrorMessage() string

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) ProtoReflect 

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

func (*ErrorResponse) Reset 

func (x *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (x *ErrorResponse) String() string

type ExtensionNumberResponse 

type ExtensionNumberResponse struct {

	// Full name of the base type, including the package name. The format
	// is <package>.<type>
	BaseTypeName    string  `protobuf:"bytes,1,opt,name=base_type_name,json=baseTypeName,proto3" json:"base_type_name,omitempty"`
	ExtensionNumber []int32 `protobuf:"varint,2,rep,packed,name=extension_number,json=extensionNumber,proto3" json:"extension_number,omitempty"`
	// contains filtered or unexported fields
}

A list of extension numbers sent by the server answering all_extension_numbers_of_type request.

func (*ExtensionNumberResponse) Descriptor deprecated 

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

Deprecated: Use ExtensionNumberResponse.ProtoReflect.Descriptor instead.

func (*ExtensionNumberResponse) GetBaseTypeName 

func (x *ExtensionNumberResponse) GetBaseTypeName() string

func (*ExtensionNumberResponse) GetExtensionNumber 

func (x *ExtensionNumberResponse) GetExtensionNumber() []int32

func (*ExtensionNumberResponse) ProtoMessage 

func (*ExtensionNumberResponse) ProtoMessage()

func (*ExtensionNumberResponse) ProtoReflect 

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

func (*ExtensionNumberResponse) Reset 

func (x *ExtensionNumberResponse) Reset()

func (*ExtensionNumberResponse) String 

func (x *ExtensionNumberResponse) String() string

type ExtensionRequest 

type ExtensionRequest struct {

	// Fully-qualified type name. The format should be <package>.<type>
	ContainingType  string `protobuf:"bytes,1,opt,name=containing_type,json=containingType,proto3" json:"containing_type,omitempty"`
	ExtensionNumber int32  `protobuf:"varint,2,opt,name=extension_number,json=extensionNumber,proto3" json:"extension_number,omitempty"`
	// contains filtered or unexported fields
}

The type name and extension number sent by the client when requesting file_containing_extension.

func (*ExtensionRequest) Descriptor deprecated 

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

Deprecated: Use ExtensionRequest.ProtoReflect.Descriptor instead.

func (*ExtensionRequest) GetContainingType 

func (x *ExtensionRequest) GetContainingType() string

func (*ExtensionRequest) GetExtensionNumber 

func (x *ExtensionRequest) GetExtensionNumber() int32

func (*ExtensionRequest) ProtoMessage 

func (*ExtensionRequest) ProtoMessage()

func (*ExtensionRequest) ProtoReflect 

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

func (*ExtensionRequest) Reset 

func (x *ExtensionRequest) Reset()

func (*ExtensionRequest) String 

func (x *ExtensionRequest) String() string

type FileDescriptorResponse 

type FileDescriptorResponse struct {

	// Serialized FileDescriptorProto messages. We avoid taking a dependency on
	// descriptor.proto, which uses proto2 only features, by making them opaque
	// bytes instead.
	FileDescriptorProto [][]byte `protobuf:"bytes,1,rep,name=file_descriptor_proto,json=fileDescriptorProto,proto3" json:"file_descriptor_proto,omitempty"`
	// contains filtered or unexported fields
}

Serialized FileDescriptorProto messages sent by the server answering a file_by_filename, file_containing_symbol, or file_containing_extension request.

func (*FileDescriptorResponse) Descriptor deprecated 

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

Deprecated: Use FileDescriptorResponse.ProtoReflect.Descriptor instead.

func (*FileDescriptorResponse) GetFileDescriptorProto 

func (x *FileDescriptorResponse) GetFileDescriptorProto() [][]byte

func (*FileDescriptorResponse) ProtoMessage 

func (*FileDescriptorResponse) ProtoMessage()

func (*FileDescriptorResponse) ProtoReflect 

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

func (*FileDescriptorResponse) Reset 

func (x *FileDescriptorResponse) Reset()

func (*FileDescriptorResponse) String 

func (x *FileDescriptorResponse) String() string

type ListServiceResponse 

type ListServiceResponse struct {

	// The information of each service may be expanded in the future, so we use
	// ServiceResponse message to encapsulate it.
	Service []*ServiceResponse `protobuf:"bytes,1,rep,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

A list of ServiceResponse sent by the server answering list_services request.

func (*ListServiceResponse) Descriptor deprecated 

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

Deprecated: Use ListServiceResponse.ProtoReflect.Descriptor instead.

func (*ListServiceResponse) GetService 

func (x *ListServiceResponse) GetService() []*ServiceResponse

func (*ListServiceResponse) ProtoMessage 

func (*ListServiceResponse) ProtoMessage()

func (*ListServiceResponse) ProtoReflect 

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

func (*ListServiceResponse) Reset 

func (x *ListServiceResponse) Reset()

func (*ListServiceResponse) String 

func (x *ListServiceResponse) String() string

type ServerReflection 

type ServerReflection interface {
	ServerReflectionInfo(ctx context.Context, opts ...client.CallOption) (ServerReflection_ServerReflectionInfoClient, error)
}

ServerReflection is a client for the grpc.reflection.v1alpha.ServerReflection service.

func NewServerReflection 

func NewServerReflection(cli *client.Client, opts ...client.ReferenceOption) (ServerReflection, error)

NewServerReflection constructs a client for the grpc.reflection.v1alpha.ServerReflection service.

type ServerReflectionHandler 

type ServerReflectionHandler interface {
	ServerReflectionInfo(context.Context, ServerReflection_ServerReflectionInfoServer) error
}

ServerReflectionHandler is an implementation of the grpc.reflection.v1alpha.ServerReflection service.

type ServerReflectionImpl 

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

ServerReflectionImpl implements ServerReflection.

func (*ServerReflectionImpl) ServerReflectionInfo 

func (c *ServerReflectionImpl) ServerReflectionInfo(ctx context.Context, opts ...client.CallOption) (ServerReflection_ServerReflectionInfoClient, error)

type ServerReflectionRequest 

type ServerReflectionRequest struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// To use reflection service, the client should set one of the following
	// fields in message_request. The server distinguishes requests by their
	// defined field and then handles them using corresponding methods.
	//
	// Types that are assignable to MessageRequest:
	//
	//	*ServerReflectionRequest_FileByFilename
	//	*ServerReflectionRequest_FileContainingSymbol
	//	*ServerReflectionRequest_FileContainingExtension
	//	*ServerReflectionRequest_AllExtensionNumbersOfType
	//	*ServerReflectionRequest_ListServices
	MessageRequest isServerReflectionRequest_MessageRequest `protobuf_oneof:"message_request"`
	// contains filtered or unexported fields
}

The message sent by the client when calling ServerReflectionInfo method.

func (*ServerReflectionRequest) Descriptor deprecated 

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

Deprecated: Use ServerReflectionRequest.ProtoReflect.Descriptor instead.

func (*ServerReflectionRequest) GetAllExtensionNumbersOfType 

func (x *ServerReflectionRequest) GetAllExtensionNumbersOfType() string

func (*ServerReflectionRequest) GetFileByFilename 

func (x *ServerReflectionRequest) GetFileByFilename() string

func (*ServerReflectionRequest) GetFileContainingExtension 

func (x *ServerReflectionRequest) GetFileContainingExtension() *ExtensionRequest

func (*ServerReflectionRequest) GetFileContainingSymbol 

func (x *ServerReflectionRequest) GetFileContainingSymbol() string

func (*ServerReflectionRequest) GetHost 

func (x *ServerReflectionRequest) GetHost() string

func (*ServerReflectionRequest) GetListServices 

func (x *ServerReflectionRequest) GetListServices() string

func (*ServerReflectionRequest) GetMessageRequest 

func (m *ServerReflectionRequest) GetMessageRequest() isServerReflectionRequest_MessageRequest

func (*ServerReflectionRequest) ProtoMessage 

func (*ServerReflectionRequest) ProtoMessage()

func (*ServerReflectionRequest) ProtoReflect 

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

func (*ServerReflectionRequest) Reset 

func (x *ServerReflectionRequest) Reset()

func (*ServerReflectionRequest) String 

func (x *ServerReflectionRequest) String() string

type ServerReflectionRequest_AllExtensionNumbersOfType 

type ServerReflectionRequest_AllExtensionNumbersOfType struct {
	// Finds the tag numbers used by all known extensions of extendee_type, and
	// appends them to ExtensionNumberResponse in an undefined order.
	// Its corresponding method is best-effort: it's not guaranteed that the
	// reflection service will implement this method, and it's not guaranteed
	// that this method will provide all extensions. Returns
	// StatusCode::UNIMPLEMENTED if it's not implemented.
	// This field should be a fully-qualified type name. The format is
	// <package>.<type>
	AllExtensionNumbersOfType string `protobuf:"bytes,6,opt,name=all_extension_numbers_of_type,json=allExtensionNumbersOfType,proto3,oneof"`
}

type ServerReflectionRequest_FileByFilename 

type ServerReflectionRequest_FileByFilename struct {
	// Find a proto file by the file name.
	FileByFilename string `protobuf:"bytes,3,opt,name=file_by_filename,json=fileByFilename,proto3,oneof"`
}

type ServerReflectionRequest_FileContainingExtension 

type ServerReflectionRequest_FileContainingExtension struct {
	// Find the proto file which defines an extension extending the given
	// message type with the given field number.
	FileContainingExtension *ExtensionRequest `protobuf:"bytes,5,opt,name=file_containing_extension,json=fileContainingExtension,proto3,oneof"`
}

type ServerReflectionRequest_FileContainingSymbol 

type ServerReflectionRequest_FileContainingSymbol struct {
	// Find the proto file that declares the given fully-qualified symbol name.
	// This field should be a fully-qualified symbol name
	// (e.g. <package>.<service>[.<method>] or <package>.<type>).
	FileContainingSymbol string `protobuf:"bytes,4,opt,name=file_containing_symbol,json=fileContainingSymbol,proto3,oneof"`
}

type ServerReflectionRequest_ListServices 

type ServerReflectionRequest_ListServices struct {
	// List the full names of registered services. The content will not be
	// checked.
	ListServices string `protobuf:"bytes,7,opt,name=list_services,json=listServices,proto3,oneof"`
}

type ServerReflectionResponse 

type ServerReflectionResponse struct {
	ValidHost       string                   `protobuf:"bytes,1,opt,name=valid_host,json=validHost,proto3" json:"valid_host,omitempty"`
	OriginalRequest *ServerReflectionRequest `protobuf:"bytes,2,opt,name=original_request,json=originalRequest,proto3" json:"original_request,omitempty"`
	// The server sets one of the following fields according to the
	// message_request in the request.
	//
	// Types that are assignable to MessageResponse:
	//
	//	*ServerReflectionResponse_FileDescriptorResponse
	//	*ServerReflectionResponse_AllExtensionNumbersResponse
	//	*ServerReflectionResponse_ListServicesResponse
	//	*ServerReflectionResponse_ErrorResponse
	MessageResponse isServerReflectionResponse_MessageResponse `protobuf_oneof:"message_response"`
	// contains filtered or unexported fields
}

The message sent by the server to answer ServerReflectionInfo method.

func (*ServerReflectionResponse) Descriptor deprecated 

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

Deprecated: Use ServerReflectionResponse.ProtoReflect.Descriptor instead.

func (*ServerReflectionResponse) GetAllExtensionNumbersResponse 

func (x *ServerReflectionResponse) GetAllExtensionNumbersResponse() *ExtensionNumberResponse

func (*ServerReflectionResponse) GetErrorResponse 

func (x *ServerReflectionResponse) GetErrorResponse() *ErrorResponse

func (*ServerReflectionResponse) GetFileDescriptorResponse 

func (x *ServerReflectionResponse) GetFileDescriptorResponse() *FileDescriptorResponse

func (*ServerReflectionResponse) GetListServicesResponse 

func (x *ServerReflectionResponse) GetListServicesResponse() *ListServiceResponse

func (*ServerReflectionResponse) GetMessageResponse 

func (m *ServerReflectionResponse) GetMessageResponse() isServerReflectionResponse_MessageResponse

func (*ServerReflectionResponse) GetOriginalRequest 

func (x *ServerReflectionResponse) GetOriginalRequest() *ServerReflectionRequest

func (*ServerReflectionResponse) GetValidHost 

func (x *ServerReflectionResponse) GetValidHost() string

func (*ServerReflectionResponse) ProtoMessage 

func (*ServerReflectionResponse) ProtoMessage()

func (*ServerReflectionResponse) ProtoReflect 

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

func (*ServerReflectionResponse) Reset 

func (x *ServerReflectionResponse) Reset()

func (*ServerReflectionResponse) String 

func (x *ServerReflectionResponse) String() string

type ServerReflectionResponse_AllExtensionNumbersResponse 

type ServerReflectionResponse_AllExtensionNumbersResponse struct {
	// This message is used to answer all_extension_numbers_of_type requests.
	AllExtensionNumbersResponse *ExtensionNumberResponse `protobuf:"bytes,5,opt,name=all_extension_numbers_response,json=allExtensionNumbersResponse,proto3,oneof"`
}

type ServerReflectionResponse_ErrorResponse 

type ServerReflectionResponse_ErrorResponse struct {
	// This message is used when an error occurs.
	ErrorResponse *ErrorResponse `protobuf:"bytes,7,opt,name=error_response,json=errorResponse,proto3,oneof"`
}

type ServerReflectionResponse_FileDescriptorResponse 

type ServerReflectionResponse_FileDescriptorResponse struct {
	// This message is used to answer file_by_filename, file_containing_symbol,
	// file_containing_extension requests with transitive dependencies.
	// As the repeated label is not allowed in oneof fields, we use a
	// FileDescriptorResponse message to encapsulate the repeated fields.
	// The reflection service is allowed to avoid sending FileDescriptorProtos
	// that were previously sent in response to earlier requests in the stream.
	FileDescriptorResponse *FileDescriptorResponse `protobuf:"bytes,4,opt,name=file_descriptor_response,json=fileDescriptorResponse,proto3,oneof"`
}

type ServerReflectionResponse_ListServicesResponse 

type ServerReflectionResponse_ListServicesResponse struct {
	// This message is used to answer list_services requests.
	ListServicesResponse *ListServiceResponse `protobuf:"bytes,6,opt,name=list_services_response,json=listServicesResponse,proto3,oneof"`
}

type ServerReflectionServerReflectionInfoClient 

type ServerReflectionServerReflectionInfoClient struct {
	*triple_protocol.BidiStreamForClient
}

func (*ServerReflectionServerReflectionInfoClient) Recv 

func (cli *ServerReflectionServerReflectionInfoClient) Recv() (*ServerReflectionResponse, error)

func (*ServerReflectionServerReflectionInfoClient) Send 

func (cli *ServerReflectionServerReflectionInfoClient) Send(msg *ServerReflectionRequest) error

type ServerReflectionServerReflectionInfoServer 

type ServerReflectionServerReflectionInfoServer struct {
	*triple_protocol.BidiStream
}

func (ServerReflectionServerReflectionInfoServer) Recv 

func (srv ServerReflectionServerReflectionInfoServer) Recv() (*ServerReflectionRequest, error)

func (*ServerReflectionServerReflectionInfoServer) Send 

func (srv *ServerReflectionServerReflectionInfoServer) Send(msg *ServerReflectionResponse) error

type ServerReflection_ServerReflectionInfoClient 

type ServerReflection_ServerReflectionInfoClient interface {
	Spec() triple_protocol.Spec
	Peer() triple_protocol.Peer
	Send(*ServerReflectionRequest) error
	RequestHeader() http.Header
	CloseRequest() error
	Recv() (*ServerReflectionResponse, error)
	ResponseHeader() http.Header
	ResponseTrailer() http.Header
	CloseResponse() error
}

type ServerReflection_ServerReflectionInfoServer 

type ServerReflection_ServerReflectionInfoServer interface {
	Send(*ServerReflectionResponse) error
	Recv() (*ServerReflectionRequest, error)
	Spec() triple_protocol.Spec
	Peer() triple_protocol.Peer
	RequestHeader() http.Header
	ResponseHeader() http.Header
	ResponseTrailer() http.Header
	Conn() triple_protocol.StreamingHandlerConn
}

type ServiceResponse 

type ServiceResponse struct {

	// Full name of a registered service, including its package name. The format
	// is <package>.<service>
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

The information of a single service used by ListServiceResponse to answer list_services request.

func (*ServiceResponse) Descriptor deprecated 

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

Deprecated: Use ServiceResponse.ProtoReflect.Descriptor instead.

func (*ServiceResponse) GetName 

func (x *ServiceResponse) GetName() string

func (*ServiceResponse) ProtoMessage 

func (*ServiceResponse) ProtoMessage()

func (*ServiceResponse) ProtoReflect 

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

func (*ServiceResponse) Reset 

func (x *ServiceResponse) Reset()

func (*ServiceResponse) String 

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