rpc

Documentation

Index

• Variables
• func InitClient(addr string, srv Service) error
• func ReadMsg(conn net.Conn) ([]byte, error)
• type Client
  • func (c *Client) Invoke(ctx context.Context, req *message.Request) (*message.Response, error)
  • func (c *Client) Send(data []byte) ([]byte, error)
• type Proxy
• type Server
  • func NewServer() *Server
  • func (s *Server) Invoke(ctx context.Context, req *message.Request) (*message.Response, error)
  • func (s *Server) Register(srv Service)
  • func (s *Server) Start(addr string) error
• type Service
• type UserServiceImpl
  • func (u *UserServiceImpl) GetUserByID(ctx context.Context, req *testdata.GetUserByIDReq) (*testdata.GetUserByIDResp, error)

Variables

var (
	ErrServiceIsNil  = errors.New("[rpc] service 不能为nil")
	ErrStructPtrOnly = errors.New("[rpc] service 只能传入结构体指针")
)

Functions

func InitClient

func InitClient(addr string, srv Service) error

func ReadMsg

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

Types

type Client

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

func (*Client) Invoke

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

func (*Client) Send

func (c *Client) Send(data []byte) ([]byte, error)

type Proxy

type Proxy interface {
	Invoke(ctx context.Context, req *message.Request) (*message.Response, 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) Register

func (s *Server) Register(srv Service)

func (*Server) Start

func (s *Server) Start(addr string) error

type Service

type Service interface {
	Name() string
}

type UserServiceImpl

type UserServiceImpl struct {
	testdata.UserService
}

func (*UserServiceImpl) GetUserByID

func (u *UserServiceImpl) GetUserByID(ctx context.Context, req *testdata.GetUserByIDReq) (*testdata.GetUserByIDResp, error)