rpc

Documentation

Index

• Variables
• func ClientWithCompressor(compressor compress.Compressor) clientOption
• func ClientWithSerializer(s serialize.Serializer) clientOption
• func ContextWithOneway(ctx context.Context) context.Context
• func IsOneWayContext(ctx context.Context) bool
• func ReadMsg(conn net.Conn) ([]byte, error)
• type Client
  • func NewClient(addr string, opts ...clientOption) *Client
  • func (c *Client) Invoke(ctx context.Context, req *message.Request) (*message.Response, 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) RegisterCompressor(compressor compress.Compressor)
  • func (s *Server) RegisterSerializer(serializer serialize.Serializer)
  • func (s *Server) Start(addr string) error
• type Service
• type UserServiceImpl
  • func (u *UserServiceImpl) GetUserByID(ctx context.Context, req *testdata.GetUserByIDReq) (*testdata.GetUserByIDResp, error)
  • func (u *UserServiceImpl) GetUserByIDProto(ctx context.Context, req *gen.GetUserByIdReq) (*gen.GetUserByIdResp, error)
• type UserServiceTimeOut
  • func (u *UserServiceTimeOut) GetUserByID(ctx context.Context, req *testdata.GetUserByIDReq) (*testdata.GetUserByIDResp, error)
  • func (u *UserServiceTimeOut) Name() string

Variables

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

Functions

func ClientWithCompressor

func ClientWithCompressor(compressor compress.Compressor) clientOption

func ClientWithSerializer

func ClientWithSerializer(s serialize.Serializer) clientOption

func ContextWithOneway

func ContextWithOneway(ctx context.Context) context.Context

func IsOneWayContext

func IsOneWayContext(ctx context.Context) bool

func ReadMsg

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

Types

type Client

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

func NewClient

func NewClient(addr string, opts ...clientOption) *Client

func (*Client) Invoke

func (c *Client) Invoke(ctx context.Context, req *message.Request) (*message.Response, 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) RegisterCompressor

func (s *Server) RegisterCompressor(compressor compress.Compressor)

func (*Server) RegisterSerializer

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

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)

func (*UserServiceImpl) GetUserByIDProto

func (u *UserServiceImpl) GetUserByIDProto(ctx context.Context, req *gen.GetUserByIdReq) (*gen.GetUserByIdResp, error)

type UserServiceTimeOut

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

func (*UserServiceTimeOut) GetUserByID

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

func (*UserServiceTimeOut) Name

func (u *UserServiceTimeOut) Name() string