manager

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
  • func WithProtocol(protocol bufcurl.ReflectProtocol) Options
• type ReflectionManager
  • func NewReflectionManager(url string, ops ...Options) *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

Functions

func GetProtoForMethod

func GetProtoForMethod(packageName, serviceName string, method protoreflect.MethodDescriptor) (string, error)

func PrintBuilder

func PrintBuilder(b builder.Builder) (string, error)

func PrintEnum

func PrintEnum(enumType protoreflect.EnumDescriptor) (string, error)

func PrintFile

func PrintFile(msgType *desc.FileDescriptor) (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
}