grpc

Documentation

Index

• type MockClientConn
  • func NewMockClientConn(ch string) *MockClientConn
  • func (m *MockClientConn) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
  • func (m *MockClientConn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
  • func (m *MockClientConn) SetCaller(caller *mock.Wallet) *MockClientConn

Types

type MockClientConn

type MockClientConn struct {
	// contains filtered or unexported fields
}

func NewMockClientConn

func NewMockClientConn(ch string) *MockClientConn

func (*MockClientConn) Invoke

func (m *MockClientConn) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error

Invoke performs a unary RPC and returns after the response is received into reply.

func (*MockClientConn) NewStream

func (m *MockClientConn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

NewStream begins a streaming RPC.

func (*MockClientConn) SetCaller

func (m *MockClientConn) SetCaller(caller *mock.Wallet) *MockClientConn