attic/

Oct 16, 2024

Changes in this version

+ const DefaultDebugPath

+ const DefaultRPCPath

+ var DefaultNetServer = NewNetServer()

+ var ErrIsShutdown = errors.New("connection is shut down")

+ func Accept(lis net.Listener)

+ func HandleHTTP()

+ func Register(rcvr any) error

+ func RegisterName(name string, rcvr any) error

+ func ServeCodec(codec ServerCodec)

+ func ServeConn(conn io.ReadWriteCloser)

+ func ServeRequest(codec ServerCodec) error

+ type Call struct

+ Args any

+ Done chan *Call

+ Error error

+ Reply any

+ ServiceMethod string

+ type ClientCodec interface

+ Close func() error

+ ReadResponseBody func(any) error

+ ReadResponseHeader func(*Response) error

+ WriteRequest func(*Request, any) error

+ type NetClient struct

+ func Dial(network, address string) (*NetClient, error)

+ func DialHTTP(network, address string) (*NetClient, error)

+ func DialHTTPPath(network, address, path string) (*NetClient, error)

+ func NewNetClient(conn io.ReadWriteCloser) *NetClient

+ func NewNetClientWithCodec(codec ClientCodec) *NetClient

+ func (client *NetClient) Call(serviceMethod string, args any, reply any) error

+ func (client *NetClient) Close() error

+ func (client *NetClient) Go(serviceMethod string, args any, reply any, done chan *Call) *Call

+ type NetServer struct

+ func NewNetServer() *NetServer

+ func (server *NetServer) Accept(lis net.Listener)

+ func (server *NetServer) HandleHTTP(rpcPath, debugPath string)

+ func (server *NetServer) Register(rcvr any) error

+ func (server *NetServer) RegisterName(name string, rcvr any) error

+ func (server *NetServer) ServeCodec(codec ServerCodec)

+ func (server *NetServer) ServeConn(conn io.ReadWriteCloser)

+ func (server *NetServer) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (server *NetServer) ServeRequest(codec ServerCodec) error

+ type Request struct

+ Seq uint64

+ ServiceMethod string

+ func (z *Request) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Request) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Request) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Request) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Request) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Request) Msgsize() (s int)

+ type Response struct

+ Error string

+ Seq uint64

+ ServiceMethod string

+ func (z *Response) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Response) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Response) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ func (z Response) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Response) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Response) Msgsize() (s int)

+ type ServerCodec interface

+ Close func() error

+ ReadRequestBody func(any) error

+ ReadRequestHeader func(*Request) error

+ WriteResponse func(*Response, any) error

+ type ServerError string

+ func (e ServerError) Error() string