drpc_e2e

May 20, 2023

Changes in this version

type MockRequest

+ func (m *MockRequest) CloneMessageVT() proto.Message

+ func (this *MockRequest) EqualMessageVT(thatMsg proto.Message) bool

type MockResponse

+ func (m *MockResponse) CloneMessageVT() proto.Message

+ func (this *MockResponse) EqualMessageVT(thatMsg proto.Message) bool

Dec 2, 2022

Changes in this version

type MockRequest

+ func (m *MockRequest) CloneGenericVT() proto.Message

+ func (m *MockRequest) CloneVT() *MockRequest

type MockResponse

+ func (m *MockResponse) CloneGenericVT() proto.Message

+ func (m *MockResponse) CloneVT() *MockResponse

Oct 12, 2022

Changes in this version

+ func NewSRPCEndToEndHandler(impl SRPCEndToEndServer, serviceID string) srpc.Handler

type SRPCEndToEndClient

+ func NewSRPCEndToEndClientWithServiceID(cc srpc.Client, serviceID string) SRPCEndToEndClient

Jul 8, 2022

Changes in this version

+ const SRPCEndToEndServiceID

+ func SRPCRegisterEndToEnd(mux srpc.Mux, impl SRPCEndToEndServer) error

type MockRequest

+ func (this *MockRequest) EqualVT(that *MockRequest) bool

type MockResponse

+ func (this *MockResponse) EqualVT(that *MockResponse) bool

+ type SRPCEndToEndClient interface

+ Mock func(ctx context.Context, in *MockRequest) (*MockResponse, error)

+ SRPCClient func() srpc.Client

+ func NewSRPCEndToEndClient(cc srpc.Client) SRPCEndToEndClient

+ type SRPCEndToEndHandler struct

+ func (SRPCEndToEndHandler) GetMethodIDs() []string

+ func (SRPCEndToEndHandler) GetServiceID() string

+ func (SRPCEndToEndHandler) InvokeMethod_Mock(impl SRPCEndToEndServer, strm srpc.Stream) error

+ func (d *SRPCEndToEndHandler) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)

+ type SRPCEndToEndServer interface

+ Mock func(context.Context, *MockRequest) (*MockResponse, error)

+ type SRPCEndToEndUnimplementedServer struct

+ func (s *SRPCEndToEndUnimplementedServer) Mock(context.Context, *MockRequest) (*MockResponse, error)

+ type SRPCEndToEnd_MockStream interface

+ SendAndClose func(*MockResponse) error

Jun 3, 2022

Changes in this version

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_github_com_aperturerobotics_bifrost_stream_drpc_e2e_e2e_proto protoreflect.FileDescriptor

type MockRequest

+ func (m *MockRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *MockRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *MockRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *MockRequest) SizeVT() (n int)

+ func (m *MockRequest) UnmarshalVT(dAtA []byte) error

+ func (x *MockRequest) ProtoReflect() protoreflect.Message

type MockResponse

+ func (m *MockResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *MockResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *MockResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *MockResponse) SizeVT() (n int)

+ func (m *MockResponse) UnmarshalVT(dAtA []byte) error

+ func (x *MockResponse) ProtoReflect() protoreflect.Message

Jan 25, 2022

Changes in this version

+ const ProtocolID

+ func DRPCRegisterEndToEnd(mux drpc.Mux, impl DRPCEndToEndServer) error

+ func RegisterEndToEndServer(s *grpc.Server, srv EndToEndServer)

+ type DRPCEndToEndClient interface

+ DRPCConn func() drpc.Conn

+ Mock func(ctx context.Context, in *MockRequest) (*MockResponse, error)

+ func NewDRPCEndToEndClient(cc drpc.Conn) DRPCEndToEndClient

+ type DRPCEndToEndDescription struct

+ func (DRPCEndToEndDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

+ func (DRPCEndToEndDescription) NumMethods() int

+ type DRPCEndToEndServer interface

+ Mock func(context.Context, *MockRequest) (*MockResponse, error)

+ type DRPCEndToEndUnimplementedServer struct

+ func (s *DRPCEndToEndUnimplementedServer) Mock(context.Context, *MockRequest) (*MockResponse, error)

+ type DRPCEndToEnd_MockStream interface

+ SendAndClose func(*MockResponse) error

+ type EndToEndClient interface

+ Mock func(ctx context.Context, in *MockRequest, opts ...grpc.CallOption) (*MockResponse, error)

+ func NewEndToEndClient(cc grpc.ClientConnInterface) EndToEndClient

+ type EndToEndServer interface

+ Mock func(context.Context, *MockRequest) (*MockResponse, error)

+ type MockRequest struct

+ Body string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MockRequest) Descriptor() ([]byte, []int)

+ func (*MockRequest) ProtoMessage()

+ func (m *MockRequest) GetBody() string

+ func (m *MockRequest) Reset()

+ func (m *MockRequest) String() string

+ func (m *MockRequest) XXX_DiscardUnknown()

+ func (m *MockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MockRequest) XXX_Merge(src proto.Message)

+ func (m *MockRequest) XXX_Size() int

+ func (m *MockRequest) XXX_Unmarshal(b []byte) error

+ type MockResponse struct

+ ReqBody string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MockResponse) Descriptor() ([]byte, []int)

+ func (*MockResponse) ProtoMessage()

+ func (m *MockResponse) GetReqBody() string

+ func (m *MockResponse) Reset()

+ func (m *MockResponse) String() string

+ func (m *MockResponse) XXX_DiscardUnknown()

+ func (m *MockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MockResponse) XXX_Merge(src proto.Message)

+ func (m *MockResponse) XXX_Size() int

+ func (m *MockResponse) XXX_Unmarshal(b []byte) error

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) Mock(ctx context.Context, req *MockRequest) (*MockResponse, error)

+ func (s *Server) Register(mux drpc.Mux) error

+ type UnimplementedEndToEndServer struct

+ func (*UnimplementedEndToEndServer) Mock(ctx context.Context, req *MockRequest) (*MockResponse, error)