gosr

Mar 11, 2020

Changes in this version

type Client

+ CallWithoutReply func(serviceMethod, args interface{}) error

Dec 12, 2019

Changes in this version

+ type CodecAdapter struct

+ func (p CodecAdapter) ReadRequestHeader(req *Request) error

+ func (p CodecAdapter) ReadResponseHeader(rsp *Response) error

type ResponseWriter

+ func (p *ResponseWriter) Free()

Dec 9, 2019

Changes in this version

+ var ErrTimeout = errors.New("timeout")

+ func NewBlockReadWriteCloser() io.ReadWriteCloser

+ func NewTestConn() (local, remote net.Conn)

type Client

+ CallWithNoReply func(serviceMethod, args interface{}) error

+ type Dual interface

+ Client func() Client

+ func NewDualWithCodec(codec DualCodec, handlers *HandlerManager, ctx interface{}) Dual

+ type DualCodec interface

+ Close func() error

+ GetSeq func(*Request) (seq interface{})

+ ReadHeader func(*DualHeader) error

+ ReadRequestBody func(req *Request, args interface{}) error

+ ReadResponseBody func(resp *Response, reply interface{}) error

+ WriteRequest func(*Request, interface{}) error

+ WriteResponse func(*Response, interface{}) error

+ type DualHeader struct

+ Context interface{}

+ Error error

+ IsRequest bool

+ Seq interface{}

+ ServiceMethod interface{}

+ func (p *DualHeader) ToRequest(request *Request)

+ func (p *DualHeader) ToResponse(response *Response)

+ type HandlerManager struct

+ func NewHandlerManager() *HandlerManager

+ func (p *HandlerManager) Register(serviceMethod interface{}, rcvr interface{}) error

+ type ResponseWriter struct

+ func (p *ResponseWriter) Reply(reply interface{}) error

+ type Server interface

+ ReadFunction func(*ServerFunction) error

+ Serve func()

+ ServeRequest func() error

+ SetContext func(interface{})

+ func NewServerWithCodec(handlerManager *HandlerManager, codec ServerCodec, ctx interface{}) Server

+ type ServerCodec interface

+ ReadRequestBody func(req *Request, args interface{}) error

+ ReadRequestHeader func(req *Request) error

+ WriteResponse func(resp *Response, reply interface{}) error

+ type ServerFunction struct

+ func (p *ServerFunction) Call()

Nov 18, 2019

Changes in this version

type Client

+ CallAsync func(serviceMethod, args, reply interface{}, cb func(*Call))

Nov 18, 2019

Changes in this version

type Call

+ Context interface{}

Oct 12, 2019

Changes in this version

+ type Call struct

+ Args interface{}

+ Done chan *Call

+ Error error

+ Reply interface{}

+ ServiceMethod interface{}

type Client

+ func NewClientWithCodec(codec ClientCodec) Client

+ Close func() error

+ Go func(serviceMethod, args interface{}, reply interface{}, done chan *Call) *Call

+ Wait func()

+ type ClientCodec interface

+ Close func() error

+ GetSeq func(req *Request) (seq interface{})

+ ReadResponseBody func(resp *Response, reply interface{}) error

+ ReadResponseHeader func(*Response) error

+ WriteRequest func(req *Request, args interface{}) error

type Error

+ var ErrClosed Error = fmt.Errorf("[gosr] closed")

+ var ErrTimeOut Error = fmt.Errorf("[gosr] timeout")

+ type Request struct

+ Context interface{}

+ Seq interface{}

+ ServiceMethod interface{}

+ type Response struct

+ Context interface{}

+ Error error

+ Seq interface{}

+ ServiceMethod interface{}

Oct 9, 2019

Changes in this version

+ type Client interface

+ AsyncCall func(req interface{}) (resp <-chan interface{}, err error)

+ Call func(req interface{}) (resp interface{}, err error)

+ Err func() error

+ GetCodec func() Codec

+ IsClosed func() bool

+ SetErr func(err error)

+ func NewClient(codec Codec, timeout time.Duration) Client

+ type Codec interface

+ BuildMessage func(data interface{}) (Message, error)

+ Close func() error

+ RecvMessage func() (Message, error)

+ SendMessage func(Message) error

+ type Error error

+ var ErrorClosed Error = fmt.Errorf("[gosr] closed")

+ var ErrorTimeOut Error = fmt.Errorf("[gosr] timeout")

+ func Errof(format string, args ...interface{}) Error

+ type Message interface

+ Data func() interface{}

+ Seq func() interface{}