Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mock

package

Go to main page

Versions in this module

v0

v0.12.0

Dec 10, 2024

v0.11.3

Sep 11, 2024

v0.11.3-genericstreaming

Oct 23, 2024

v0.11.3-genericstream

Oct 23, 2024

v0.11.3-generic-streaming

Nov 18, 2024

v0.11.2

Sep 11, 2024

v0.11.1

Sep 10, 2024

v0.11.0

Sep 9, 2024

Changes in this version

+ var File_pbapi_proto protoreflect.FileDescriptor

+ func NewInvoker(handler Mock, opts ...server.Option) server.Invoker

+ func NewServer(handler Mock, opts ...server.Option) server.Server

+ func NewServiceInfo() *kitex.ServiceInfo

+ func NewServiceInfoForClient() *kitex.ServiceInfo

+ func NewServiceInfoForStreamClient() *kitex.ServiceInfo

+ func RegisterService(svr server.Server, handler Mock, opts ...server.RegisterOption) error

+ type BidirectionalStreamingTestArgs struct

+ Req *MockReq

+ func (p *BidirectionalStreamingTestArgs) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *BidirectionalStreamingTestArgs) FastWrite(buf []byte) (n int)

+ func (p *BidirectionalStreamingTestArgs) GetFirstArgument() interface{}

+ func (p *BidirectionalStreamingTestArgs) GetReq() *MockReq

+ func (p *BidirectionalStreamingTestArgs) IsSetReq() bool

+ func (p *BidirectionalStreamingTestArgs) Marshal(out []byte) ([]byte, error)

+ func (p *BidirectionalStreamingTestArgs) Size() (n int)

+ func (p *BidirectionalStreamingTestArgs) Unmarshal(in []byte) error

+ type BidirectionalStreamingTestResult struct

+ Success *MockResp

+ func (p *BidirectionalStreamingTestResult) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *BidirectionalStreamingTestResult) FastWrite(buf []byte) (n int)

+ func (p *BidirectionalStreamingTestResult) GetResult() interface{}

+ func (p *BidirectionalStreamingTestResult) GetSuccess() *MockResp

+ func (p *BidirectionalStreamingTestResult) IsSetSuccess() bool

+ func (p *BidirectionalStreamingTestResult) Marshal(out []byte) ([]byte, error)

+ func (p *BidirectionalStreamingTestResult) SetSuccess(x interface{})

+ func (p *BidirectionalStreamingTestResult) Size() (n int)

+ func (p *BidirectionalStreamingTestResult) Unmarshal(in []byte) error

+ type Client interface

+ BidirectionalStreamingTest func(ctx context.Context, callOptions ...callopt.Option) (stream Mock_BidirectionalStreamingTestClient, err error)

+ ClientStreamingTest func(ctx context.Context, callOptions ...callopt.Option) (stream Mock_ClientStreamingTestClient, err error)

+ ServerStreamingTest func(ctx context.Context, Req *MockReq, callOptions ...callopt.Option) (stream Mock_ServerStreamingTestClient, err error)

+ UnaryTest func(ctx context.Context, Req *MockReq, callOptions ...callopt.Option) (r *MockResp, err error)

+ func MustNewClient(destService string, opts ...client.Option) Client

+ func NewClient(destService string, opts ...client.Option) (Client, error)

+ type ClientStreamingTestArgs struct

+ Req *MockReq

+ func (p *ClientStreamingTestArgs) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *ClientStreamingTestArgs) FastWrite(buf []byte) (n int)

+ func (p *ClientStreamingTestArgs) GetFirstArgument() interface{}

+ func (p *ClientStreamingTestArgs) GetReq() *MockReq

+ func (p *ClientStreamingTestArgs) IsSetReq() bool

+ func (p *ClientStreamingTestArgs) Marshal(out []byte) ([]byte, error)

+ func (p *ClientStreamingTestArgs) Size() (n int)

+ func (p *ClientStreamingTestArgs) Unmarshal(in []byte) error

+ type ClientStreamingTestResult struct

+ Success *MockResp

+ func (p *ClientStreamingTestResult) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *ClientStreamingTestResult) FastWrite(buf []byte) (n int)

+ func (p *ClientStreamingTestResult) GetResult() interface{}

+ func (p *ClientStreamingTestResult) GetSuccess() *MockResp

+ func (p *ClientStreamingTestResult) IsSetSuccess() bool

+ func (p *ClientStreamingTestResult) Marshal(out []byte) ([]byte, error)

+ func (p *ClientStreamingTestResult) SetSuccess(x interface{})

+ func (p *ClientStreamingTestResult) Size() (n int)

+ func (p *ClientStreamingTestResult) Unmarshal(in []byte) error

+ type Mock interface

+ BidirectionalStreamingTest func(stream Mock_BidirectionalStreamingTestServer) (err error)

+ ClientStreamingTest func(stream Mock_ClientStreamingTestServer) (err error)

+ ServerStreamingTest func(req *MockReq, stream Mock_ServerStreamingTestServer) (err error)

+ UnaryTest func(ctx context.Context, req *MockReq) (res *MockResp, err error)

+ type MockReq struct

+ Message string

+ var BidirectionalStreamingTestArgs_Req_DEFAULT *MockReq

+ var ClientStreamingTestArgs_Req_DEFAULT *MockReq

+ var ServerStreamingTestArgs_Req_DEFAULT *MockReq

+ var UnaryTestArgs_Req_DEFAULT *MockReq

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

+ func (*MockReq) ProtoMessage()

+ func (x *MockReq) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

+ func (x *MockReq) FastWrite(buf []byte) (offset int)

+ func (x *MockReq) GetMessage() string

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

+ func (x *MockReq) Reset()

+ func (x *MockReq) Size() (n int)

+ func (x *MockReq) String() string

+ type MockResp struct

+ Message string

+ var BidirectionalStreamingTestResult_Success_DEFAULT *MockResp

+ var ClientStreamingTestResult_Success_DEFAULT *MockResp

+ var ServerStreamingTestResult_Success_DEFAULT *MockResp

+ var UnaryTestResult_Success_DEFAULT *MockResp

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

+ func (*MockResp) ProtoMessage()

+ func (x *MockResp) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

+ func (x *MockResp) FastWrite(buf []byte) (offset int)

+ func (x *MockResp) GetMessage() string

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

+ func (x *MockResp) Reset()

+ func (x *MockResp) Size() (n int)

+ func (x *MockResp) String() string

+ type Mock_BidirectionalStreamingTestClient interface

+ Recv func() (*MockResp, error)

+ Send func(*MockReq) error

+ type Mock_BidirectionalStreamingTestServer interface

+ Recv func() (*MockReq, error)

+ Send func(*MockResp) error

+ type Mock_ClientStreamingTestClient interface

+ CloseAndRecv func() (*MockResp, error)

+ Send func(*MockReq) error

+ type Mock_ClientStreamingTestServer interface

+ Recv func() (*MockReq, error)

+ SendAndClose func(*MockResp) error

+ type Mock_ServerStreamingTestClient interface

+ Recv func() (*MockResp, error)

+ type Mock_ServerStreamingTestServer interface

+ Send func(*MockResp) error

+ type ServerStreamingTestArgs struct

+ Req *MockReq

+ func (p *ServerStreamingTestArgs) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *ServerStreamingTestArgs) FastWrite(buf []byte) (n int)

+ func (p *ServerStreamingTestArgs) GetFirstArgument() interface{}

+ func (p *ServerStreamingTestArgs) GetReq() *MockReq

+ func (p *ServerStreamingTestArgs) IsSetReq() bool

+ func (p *ServerStreamingTestArgs) Marshal(out []byte) ([]byte, error)

+ func (p *ServerStreamingTestArgs) Size() (n int)

+ func (p *ServerStreamingTestArgs) Unmarshal(in []byte) error

+ type ServerStreamingTestResult struct

+ Success *MockResp

+ func (p *ServerStreamingTestResult) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *ServerStreamingTestResult) FastWrite(buf []byte) (n int)

+ func (p *ServerStreamingTestResult) GetResult() interface{}

+ func (p *ServerStreamingTestResult) GetSuccess() *MockResp

+ func (p *ServerStreamingTestResult) IsSetSuccess() bool

+ func (p *ServerStreamingTestResult) Marshal(out []byte) ([]byte, error)

+ func (p *ServerStreamingTestResult) SetSuccess(x interface{})

+ func (p *ServerStreamingTestResult) Size() (n int)

+ func (p *ServerStreamingTestResult) Unmarshal(in []byte) error

+ type StreamClient interface

+ BidirectionalStreamingTest func(ctx context.Context, callOptions ...streamcall.Option) (stream Mock_BidirectionalStreamingTestClient, err error)

+ ClientStreamingTest func(ctx context.Context, callOptions ...streamcall.Option) (stream Mock_ClientStreamingTestClient, err error)

+ ServerStreamingTest func(ctx context.Context, Req *MockReq, callOptions ...streamcall.Option) (stream Mock_ServerStreamingTestClient, err error)

+ func MustNewStreamClient(destService string, opts ...streamclient.Option) StreamClient

+ func NewStreamClient(destService string, opts ...streamclient.Option) (StreamClient, error)

+ type UnaryTestArgs struct

+ Req *MockReq

+ func (p *UnaryTestArgs) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *UnaryTestArgs) FastWrite(buf []byte) (n int)

+ func (p *UnaryTestArgs) GetFirstArgument() interface{}

+ func (p *UnaryTestArgs) GetReq() *MockReq

+ func (p *UnaryTestArgs) IsSetReq() bool

+ func (p *UnaryTestArgs) Marshal(out []byte) ([]byte, error)

+ func (p *UnaryTestArgs) Size() (n int)

+ func (p *UnaryTestArgs) Unmarshal(in []byte) error

+ type UnaryTestResult struct

+ Success *MockResp

+ func (p *UnaryTestResult) FastRead(buf []byte, _type int8, number int32) (n int, err error)

+ func (p *UnaryTestResult) FastWrite(buf []byte) (n int)

+ func (p *UnaryTestResult) GetResult() interface{}

+ func (p *UnaryTestResult) GetSuccess() *MockResp

+ func (p *UnaryTestResult) IsSetSuccess() bool

+ func (p *UnaryTestResult) Marshal(out []byte) ([]byte, error)

+ func (p *UnaryTestResult) SetSuccess(x interface{})

+ func (p *UnaryTestResult) Size() (n int)

+ func (p *UnaryTestResult) Unmarshal(in []byte) error