rpc

Documentation

Overview

Package rpc is a generated GoMock package.

Index

• Variables
• func CtxWithOneway(ctx context.Context) context.Context
• func ReadMsg(conn net.Conn) ([]byte, error)
• type Client
  • func NewClient(network, addr string, opts ...ClientOption) (*Client, error)
  • func (c *Client) InitService(service Service) error
  • func (c *Client) Invoke(ctx context.Context, req *message.Request) (*message.Response, error)
  • func (c *Client) Send(ctx context.Context, data []byte) ([]byte, error)
• type ClientOption
  • func ClientWithSerializer(sl serialize.Serializer) ClientOption
• type GetByIDReq
• type GetByIDResp
• type MockProxy
  • func NewMockProxy(ctrl *gomock.Controller) *MockProxy
  • func (m *MockProxy) EXPECT() *MockProxyMockRecorder
  • func (m *MockProxy) Invoke(arg0 context.Context, arg1 *message.Request) (*message.Response, error)
• type MockProxyMockRecorder
  • func (mr *MockProxyMockRecorder) Invoke(arg0, arg1 interface{}) *gomock.Call
• type Proxy
• type Server
  • func NewServer() *Server
  • func (s *Server) Invoke(ctx context.Context, req *message.Request) (*message.Response, error)
  • func (s *Server) RegisterSerializer(sl serialize.Serializer)
  • func (s *Server) RegisterService(service Service)
  • func (s *Server) Start(network, address string) error
• type Service
• type UserService
  • func (s UserService) Name() string
• type UserServiceServer
  • func (s *UserServiceServer) GetByID(ctx context.Context, req *GetByIDReq) (*GetByIDResp, error)
  • func (s *UserServiceServer) GetByIDProto(ctx context.Context, req *gen.GetByIDReq) (*gen.GetByIDResp, error)
  • func (s *UserServiceServer) Name() string

Variables

var (
	ErrServiceNil       = errors.New("rpc: nil service is not supported")
	ErrServiceWrongType = errors.New("rpc: only first-level pointer to struct is supported")
)

Functions

func CtxWithOneway

func CtxWithOneway(ctx context.Context) context.Context

func ReadMsg

func ReadMsg(conn net.Conn) ([]byte, error)

Types

type Client

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

func NewClient

func NewClient(network, addr string, opts ...ClientOption) (*Client, error)

func (*Client) InitService

func (c *Client) InitService(service Service) error

func (*Client) Invoke

func (c *Client) Invoke(ctx context.Context, req *message.Request) (*message.Response, error)

func (*Client) Send

func (c *Client) Send(ctx context.Context, data []byte) ([]byte, error)

type ClientOption

type ClientOption func(client *Client)

func ClientWithSerializer

func ClientWithSerializer(sl serialize.Serializer) ClientOption

type GetByIDReq

type GetByIDReq struct {
	ID int
}

type GetByIDResp

type GetByIDResp struct {
	Msg string
}

type MockProxy

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

MockProxy is a mock of Proxy interface.

func NewMockProxy

func NewMockProxy(ctrl *gomock.Controller) *MockProxy

NewMockProxy creates a new mock instance.

func (*MockProxy) EXPECT

func (m *MockProxy) EXPECT() *MockProxyMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProxy) Invoke

func (m *MockProxy) Invoke(arg0 context.Context, arg1 *message.Request) (*message.Response, error)

Invoke mocks base method.

type MockProxyMockRecorder

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

MockProxyMockRecorder is the mock recorder for MockProxy.

func (*MockProxyMockRecorder) Invoke

func (mr *MockProxyMockRecorder) Invoke(arg0, arg1 interface{}) *gomock.Call

Invoke indicates an expected call of Invoke.

type Proxy

type Proxy interface {
	Invoke(ctx context.Context, req *message.Request) (resp *message.Response, err error)
}

type Server

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

func NewServer

func NewServer() *Server

func (*Server) Invoke

func (s *Server) Invoke(ctx context.Context, req *message.Request) (*message.Response, error)

func (*Server) RegisterSerializer

func (s *Server) RegisterSerializer(sl serialize.Serializer)

func (*Server) RegisterService

func (s *Server) RegisterService(service Service)

func (*Server) Start

func (s *Server) Start(network, address string) error

type Service

type Service interface {
	Name() string
}

type UserService

type UserService struct {
	GetByID func(ctx context.Context, req *GetByIDReq) (*GetByIDResp, error)

	GetByIDProto func(ctx context.Context, req *gen.GetByIDReq) (*gen.GetByIDResp, error)
}

func (UserService) Name

func (s UserService) Name() string

type UserServiceServer

type UserServiceServer struct {
	Msg string
	Err error
}

func (*UserServiceServer) GetByID

func (s *UserServiceServer) GetByID(ctx context.Context, req *GetByIDReq) (*GetByIDResp, error)

func (*UserServiceServer) GetByIDProto

func (s *UserServiceServer) GetByIDProto(ctx context.Context, req *gen.GetByIDReq) (*gen.GetByIDResp, error)

func (*UserServiceServer) Name

func (s *UserServiceServer) Name() string