zrpc

package module

v0.0.0-...-804e331 Latest Latest Go to latest Published: Jul 29, 2022 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	*rpc.Client
}

func NewClient(conn io.ReadWriteCloser, opt *Options) *Client

NewClient Create a new rpc client

func (c *Client) AsyncCall(serviceMethod string, args interface{}, reply interface{}) chan *rpc.Call

AsyncCall asynchronously calls the rpc function and returns a channel of *rpc.Call

func (c *Client) Call(serviceMethod string, args interface{}, reply interface{}) error

Call synchronously calls the rpc function

type Options struct {
	SerializeType serialize.Type
	CompressType  compress.Type
}

type Server struct {
	*rpc.Server
	// contains filtered or unexported fields
}

func NewServer(o *Options) *Server

func (s *Server) Accept(lis net.Listener)

func (s *Server) Register(rcvr interface{}) error

func (s *Server) RegisterName(name string, rcvr interface{}) error

RegisterName is like Register but uses the provided name for the type instead of the receiver's concrete type.

func (s *Server) ServeCodec(codec rpc.ServerCodec)

func (s *Server) ServeRequest(codec rpc.ServerCodec) error

ServeRequest is like ServeCodec but synchronously serves a single request. It does not close the codec upon completion.