grpccompat

packagemodule

v0.0.0-...-1f5426fLatest Latest

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

Go to latest Published: Jul 14, 2025 License:MITImports:13Imported by:0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/storj/drpc

README ¶

package grpccompat

import "storj.io/drpc/internal/grpccompat"

package grpccompat holds compatability tests for grpc.

Documentation¶

Overview¶

Package grpccompat holds compatibility tests for grpc.

Index¶

Constants¶

This section is empty.

Variables¶

View Source

var File_service_protoprotoreflect.FileDescriptor

View Source

var Service_ServiceDesc =grpc.ServiceDesc{ServiceName: "service.Service",HandlerType: (*ServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "Method1",Handler:    _Service_Method1_Handler,},},Streams: []grpc.StreamDesc{{StreamName:    "Method2",Handler:       _Service_Method2_Handler,ClientStreams:true,},{StreamName:    "Method3",Handler:       _Service_Method3_Handler,ServerStreams:true,},{StreamName:    "Method4",Handler:       _Service_Method4_Handler,ServerStreams:true,ClientStreams:true,},},Metadata: "service.proto",}

Service_ServiceDesc is the grpc.ServiceDesc for Service service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

Functions¶

funcDRPCRegisterService ¶

func DRPCRegisterService(muxdrpc.Mux, implDRPCServiceServer)error

funcRegisterServiceServer ¶

func RegisterServiceServer(sgrpc.ServiceRegistrar, srvServiceServer)

Types¶

typeDRPCServiceClient ¶

type DRPCServiceClient interface {DRPCConn()drpc.ConnMethod1(ctxcontext.Context, in *In) (*Out,error)Method2(ctxcontext.Context) (DRPCService_Method2Client,error)Method3(ctxcontext.Context, in *In) (DRPCService_Method3Client,error)Method4(ctxcontext.Context) (DRPCService_Method4Client,error)}

funcNewDRPCServiceClient ¶

func NewDRPCServiceClient(ccdrpc.Conn)DRPCServiceClient

typeDRPCServiceDescription ¶

type DRPCServiceDescription struct{}

func (DRPCServiceDescription)Method ¶

func (DRPCServiceDescription) Method(nint) (string,drpc.Encoding,drpc.Receiver, interface{},bool)

func (DRPCServiceDescription)NumMethods ¶

func (DRPCServiceDescription) NumMethods()int

typeDRPCServiceServer ¶

type DRPCServiceServer interface {Method1(context.Context, *In) (*Out,error)Method2(DRPCService_Method2Stream)errorMethod3(*In,DRPCService_Method3Stream)errorMethod4(DRPCService_Method4Stream)error}

typeDRPCServiceUnimplementedServer ¶

type DRPCServiceUnimplementedServer struct{}

func (*DRPCServiceUnimplementedServer)Method1 ¶

func (s *DRPCServiceUnimplementedServer) Method1(context.Context, *In) (*Out,error)

func (*DRPCServiceUnimplementedServer)Method2 ¶

func (s *DRPCServiceUnimplementedServer) Method2(DRPCService_Method2Stream)error

func (*DRPCServiceUnimplementedServer)Method3 ¶

func (s *DRPCServiceUnimplementedServer) Method3(*In,DRPCService_Method3Stream)error

func (*DRPCServiceUnimplementedServer)Method4 ¶

func (s *DRPCServiceUnimplementedServer) Method4(DRPCService_Method4Stream)error

typeDRPCService_Method1Stream ¶

type DRPCService_Method1Stream interface {drpc.StreamSendAndClose(*Out)error}

typeDRPCService_Method2Client ¶

type DRPCService_Method2Client interface {drpc.StreamSend(*In)errorCloseAndRecv() (*Out,error)}

typeDRPCService_Method2Stream ¶

type DRPCService_Method2Stream interface {drpc.StreamSendAndClose(*Out)errorRecv() (*In,error)}

typeDRPCService_Method3Client ¶

type DRPCService_Method3Client interface {drpc.StreamRecv() (*Out,error)}

typeDRPCService_Method3Stream ¶

type DRPCService_Method3Stream interface {drpc.StreamSend(*Out)error}

typeDRPCService_Method4Client ¶

type DRPCService_Method4Client interface {drpc.StreamSend(*In)errorRecv() (*Out,error)}

typeDRPCService_Method4Stream ¶

type DRPCService_Method4Stream interface {drpc.StreamSend(*Out)errorRecv() (*In,error)}

typeIn ¶

type In struct {Inint64  `protobuf:"varint,1,opt,name=in,proto3" json:"in,omitempty"`Buf []byte `protobuf:"bytes,2,opt,name=buf,proto3" json:"buf,omitempty"`Opt *int64 `protobuf:"varint,3,opt,name=opt,proto3,oneof" json:"opt,omitempty"`// contains filtered or unexported fields}

func (*In)Descriptordeprecated

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

Deprecated: Use In.ProtoReflect.Descriptor instead.

func (*In)GetBuf ¶

func (x *In) GetBuf() []byte

func (*In)GetIn ¶

func (x *In) GetIn()int64

func (*In)GetOpt ¶

func (x *In) GetOpt()int64

func (*In)ProtoMessage ¶

func (*In) ProtoMessage()

func (*In)ProtoReflect ¶

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

func (*In)Reset ¶

func (x *In) Reset()

func (*In)String ¶

func (x *In) String()string

typeOut ¶

type Out struct {Outint64  `protobuf:"varint,1,opt,name=out,proto3" json:"out,omitempty"`Buf []byte `protobuf:"bytes,2,opt,name=buf,proto3" json:"buf,omitempty"`Opt *int64 `protobuf:"varint,3,opt,name=opt,proto3,oneof" json:"opt,omitempty"`// contains filtered or unexported fields}

func (*Out)Descriptordeprecated

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

Deprecated: Use Out.ProtoReflect.Descriptor instead.

func (*Out)GetBuf ¶

func (x *Out) GetBuf() []byte

func (*Out)GetOpt ¶

func (x *Out) GetOpt()int64

func (*Out)GetOut ¶

func (x *Out) GetOut()int64

func (*Out)ProtoMessage ¶

func (*Out) ProtoMessage()

func (*Out)ProtoReflect ¶

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

func (*Out)Reset ¶

func (x *Out) Reset()

func (*Out)String ¶

func (x *Out) String()string

typeServiceClient ¶

type ServiceClient interface {Method1(ctxcontext.Context, in *In, opts ...grpc.CallOption) (*Out,error)Method2(ctxcontext.Context, opts ...grpc.CallOption) (Service_Method2Client,error)Method3(ctxcontext.Context, in *In, opts ...grpc.CallOption) (Service_Method3Client,error)Method4(ctxcontext.Context, opts ...grpc.CallOption) (Service_Method4Client,error)}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

funcNewServiceClient ¶

func NewServiceClient(ccgrpc.ClientConnInterface)ServiceClient

typeServiceServer ¶

type ServiceServer interface {Method1(context.Context, *In) (*Out,error)Method2(Service_Method2Server)errorMethod3(*In,Service_Method3Server)errorMethod4(Service_Method4Server)error// contains filtered or unexported methods}

ServiceServer is the server API for Service service.All implementations must embed UnimplementedServiceServerfor forward compatibility

typeService_Method2Client ¶

type Service_Method2Client interface {Send(*In)errorCloseAndRecv() (*Out,error)grpc.ClientStream}

typeService_Method2Server ¶

type Service_Method2Server interface {SendAndClose(*Out)errorRecv() (*In,error)grpc.ServerStream}

typeService_Method3Client ¶

type Service_Method3Client interface {Recv() (*Out,error)grpc.ClientStream}

typeService_Method3Server ¶

type Service_Method3Server interface {Send(*Out)errorgrpc.ServerStream}

typeService_Method4Client ¶

type Service_Method4Client interface {Send(*In)errorRecv() (*Out,error)grpc.ClientStream}

typeService_Method4Server ¶

type Service_Method4Server interface {Send(*Out)errorRecv() (*In,error)grpc.ServerStream}

typeUnimplementedServiceServer ¶

type UnimplementedServiceServer struct {}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer)Method1 ¶

func (UnimplementedServiceServer) Method1(context.Context, *In) (*Out,error)

func (UnimplementedServiceServer)Method2 ¶

func (UnimplementedServiceServer) Method2(Service_Method2Server)error

func (UnimplementedServiceServer)Method3 ¶

func (UnimplementedServiceServer) Method3(*In,Service_Method3Server)error

func (UnimplementedServiceServer)Method4 ¶

func (UnimplementedServiceServer) Method4(Service_Method4Server)error

typeUnsafeServiceServer ¶

type UnsafeServiceServer interface {// contains filtered or unexported methods}

UnsafeServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to ServiceServer willresult in compilation errors.

Source Files¶

View all Source files

?	: This menu
/	: Search site
f orF	: Jump to
y orY	: Canonical URL

Movatterモバイル変換

Details

Repository

Links

README¶

package grpccompat

Documentation¶

Overview¶

Index¶

Constants¶

Variables¶

Functions¶

funcDRPCRegisterService¶

funcRegisterServiceServer¶

Types¶

typeDRPCServiceClient¶

funcNewDRPCServiceClient¶

typeDRPCServiceDescription¶

func (DRPCServiceDescription)Method¶

func (DRPCServiceDescription)NumMethods¶

typeDRPCServiceServer¶

typeDRPCServiceUnimplementedServer¶

func (*DRPCServiceUnimplementedServer)Method1¶

func (*DRPCServiceUnimplementedServer)Method2¶

func (*DRPCServiceUnimplementedServer)Method3¶

func (*DRPCServiceUnimplementedServer)Method4¶

typeDRPCService_Method1Stream¶

typeDRPCService_Method2Client¶

typeDRPCService_Method2Stream¶

typeDRPCService_Method3Client¶

typeDRPCService_Method3Stream¶

typeDRPCService_Method4Client¶

typeDRPCService_Method4Stream¶

typeIn¶

func (*In)Descriptordeprecated

func (*In)GetBuf¶

func (*In)GetIn¶

func (*In)GetOpt¶

func (*In)ProtoMessage¶

func (*In)ProtoReflect¶

func (*In)Reset¶

func (*In)String¶

typeOut¶