Versions in this module Expand all Collapse all v1 v1.21.0 Jul 1, 2024 Changes in this version + func IsErrTransient(err error) bool + func RegisterFiles(fds ...*desc.FileDescriptor) + type FieldWalker struct + func NewFieldWalker() *FieldWalker + func (fw *FieldWalker) Walk(md *desc.MessageDescriptor, walkFn func(*desc.FieldDescriptor)) + type GrpcReflectVersion int + const GrpcReflectAuto + const GrpcReflectV1Alpha + func ParseGrpcReflectVersion(s string) GrpcReflectVersion + type MsgFormat int + const JSON + const Text + func ParseMsgFormat(s string) MsgFormat + func (f MsgFormat) String() string + type ServiceCaller struct + func NewServiceCaller(connFact *rpc.GrpcConnFactory, inMsgFormat, outMsgFormat MsgFormat, ...) *ServiceCaller + func (sc *ServiceCaller) CallClientStream(ctx context.Context, serviceTarget string, methodDesc *desc.MethodDescriptor, ...) ([]byte, error) + func (sc *ServiceCaller) CallStream(ctx context.Context, serviceTarget string, methodDesc *desc.MethodDescriptor, ...) (chan []byte, chan error) + type ServiceMeta struct + File *desc.FileDescriptor + Methods []*desc.MethodDescriptor + Name string + type ServiceMetaData interface + GetAdditionalFiles func() ([]*desc.FileDescriptor, error) + GetServiceMetaDataList func(context.Context) (ServiceMetaList, error) + func NewServiceMetaData(cfg *ServiceMetaDataConfig) ServiceMetaData + func NewServiceMetadataProto(protoPath, protoImports []string) ServiceMetaData + type ServiceMetaDataConfig struct + ConnFact *rpc.GrpcConnFactory + Deadline int + ProtoImports []string + ReflectVersion GrpcReflectVersion + Target string + type ServiceMetaList []*ServiceMeta + func (l ServiceMetaList) Files() []*desc.FileDescriptor
Go to main page