Documentation
¶
Index ¶
- func GetProtoForMethod(packageName, serviceName string, method protoreflect.MethodDescriptor) (string, error)
- func PrintBuilder(b builder.Builder) (string, error)
- func PrintEnum(enumType protoreflect.EnumDescriptor) (string, error)
- func PrintFile(msgType *desc.FileDescriptor) (string, error)
- func PrintMessage(msgType protoreflect.MessageDescriptor) (string, error)
- type Options
- type ReflectionManager
- func (s *ReflectionManager) ExecuteMethod(ctx context.Context, method protoreflect.MethodDescriptor, ...) (err error)
- func (s *ReflectionManager) Init() (func(), error)
- func (s *ReflectionManager) ResolveMethod(service, methodName string) (protoreflect.MethodDescriptor, error)
- func (s *ReflectionManager) ResolveService(service string) (protoreflect.ServiceDescriptor, error)
- func (s *ReflectionManager) ResolveServices() ([]protoreflect.ServiceDescriptor, error)
- type ReflectionOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetProtoForMethod ¶
func GetProtoForMethod(packageName, serviceName string, method protoreflect.MethodDescriptor) (string, error)
func PrintEnum ¶
func PrintEnum(enumType protoreflect.EnumDescriptor) (string, error)
func PrintMessage ¶
func PrintMessage(msgType protoreflect.MessageDescriptor) (string, error)
Types ¶
type Options ¶
type Options func(*ReflectionManager)
func WithProtocol ¶
func WithProtocol(protocol bufcurl.ReflectProtocol) Options
type ReflectionManager ¶
type ReflectionManager struct {
URL string
Protocol string
Headers []string
// contains filtered or unexported fields
}
func NewReflectionManager ¶
func NewReflectionManager(url string, ops ...Options) *ReflectionManager
func (*ReflectionManager) ExecuteMethod ¶
func (s *ReflectionManager) ExecuteMethod( ctx context.Context, method protoreflect.MethodDescriptor, input rxgo.Observable, output rx.ItemSink, ) (err error)
func (*ReflectionManager) Init ¶
func (s *ReflectionManager) Init() (func(), error)
func (*ReflectionManager) ResolveMethod ¶
func (s *ReflectionManager) ResolveMethod(service, methodName string) (protoreflect.MethodDescriptor, error)
func (*ReflectionManager) ResolveService ¶
func (s *ReflectionManager) ResolveService(service string) (protoreflect.ServiceDescriptor, error)
func (*ReflectionManager) ResolveServices ¶
func (s *ReflectionManager) ResolveServices() ([]protoreflect.ServiceDescriptor, error)
type ReflectionOptions ¶
type ReflectionOptions struct {
Protocol bufcurl.ReflectProtocol
Headers []string
}
Source Files
Click to show internal directories.
Click to hide internal directories.