notrest

package

v0.0.0-...-3d20607 Latest Latest Go to latest Published: Oct 4, 2017 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

Repository

github.com/byte-mug/gocom

Links

Open Source Insights

Documentation ¶

Index ¶

func ReleaseRequest(r *Request)
func ReleaseResponse(r *Response)
type Client
- func NewARClient(cli *semirpc.ARClient) *Client
- func NewClient(cli semirpc.ClientCodec) *Client
type ErrorHandler
type Handler
type Header
type Request
- func AckquireRequest() *Request
type Response
- func AckquireResponse() *Response
type Server
- func (s *Server) Serve(sc semirpc.ServerCodec) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ReleaseRequest ¶

func ReleaseRequest(r *Request)

func ReleaseResponse ¶

func ReleaseResponse(r *Response)

Types ¶

type Client ¶

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

func NewARClient ¶

func NewARClient(cli *semirpc.ARClient) *Client

func NewClient ¶

func NewClient(cli semirpc.ClientCodec) *Client

func (*Client) Close ¶

func (c *Client) Close() error

func (*Client) Do ¶

func (c *Client) Do(req *Request, resp *Response) error

func (*Client) DoAsyncSupport ¶

func (c *Client) DoAsyncSupport(req *Request, resp *Response, errch chan error)

func (*Client) DoTimeout ¶

func (c *Client) DoTimeout(req *Request, resp *Response, timeout <-chan time.Time) error

type ErrorHandler ¶

type ErrorHandler func(e semirpc.ServerError, req *Request, resp *Response)

type Handler ¶

type Handler func(req *Request, resp *Response)

type Header ¶

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

func (*Header) Body ¶

func (r *Header) Body() *bytebufferpool.ByteBuffer

func (r *Header) GetHeader(k []byte) []byte

func (r *Header) GetHeaderK(k string) []byte

func (r *Header) Reset()

func (r *Header) SetHeader(k, v []byte)

func (r *Header) SetHeaderKV(k, v string)

func (r *Header) SetIntHeader(k string, i int)

type Request ¶

type Request struct {
	Header
	// contains filtered or unexported fields
}

func AckquireRequest ¶

func AckquireRequest() *Request

func (*Request) Method ¶

func (r *Request) Method() []byte

func (*Request) Path ¶

func (r *Request) Path() []byte

func (*Request) ReadReq ¶

func (r *Request) ReadReq(rd *bufio.Reader) error

func (*Request) Reset ¶

func (r *Request) Reset()

func (*Request) SetMethod ¶

func (r *Request) SetMethod(k []byte)

func (*Request) SetMethodStr ¶

func (r *Request) SetMethodStr(k string)

func (*Request) SetPath ¶

func (r *Request) SetPath(k []byte)

func (*Request) SetPathStr ¶

func (r *Request) SetPathStr(k string)

func (*Request) WriteReq ¶

func (r *Request) WriteReq(wd *bufio.Writer) error

type Response ¶

type Response struct {
	Header
	// contains filtered or unexported fields
}

func AckquireResponse ¶

func AckquireResponse() *Response

func (*Response) Code ¶

func (r *Response) Code() int

func (*Response) ReadResp ¶

func (r *Response) ReadResp(rd *bufio.Reader) error

func (*Response) Reason ¶

func (r *Response) Reason() []byte

func (*Response) Reset ¶

func (r *Response) Reset()

func (*Response) SetCode ¶

func (r *Response) SetCode(i int)

func (*Response) SetReason ¶

func (r *Response) SetReason(b []byte)

func (*Response) SetReasonStr ¶

func (r *Response) SetReasonStr(b string)

func (*Response) Status ¶

func (r *Response) Status(code int)

func (*Response) WriteResp ¶

func (r *Response) WriteResp(wd *bufio.Writer) error

type Server ¶

type Server struct {
	semirpc.Server
	PerformHandler Handler
	PerformErrorhn ErrorHandler
	// contains filtered or unexported fields
}

func (*Server) Serve ¶

func (s *Server) Serve(sc semirpc.ServerCodec) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
route

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func ReleaseRequest ¶

func ReleaseResponse ¶

Types ¶

type Client ¶

func NewARClient ¶

func NewClient ¶

func (*Client) Close ¶

func (*Client) Do ¶

func (*Client) DoAsyncSupport ¶

func (*Client) DoTimeout ¶

type ErrorHandler ¶

type Handler ¶

type Header ¶

func (*Header) Body ¶

func (*Header) GetHeader ¶

func (*Header) GetHeaderK ¶

func (*Header) Reset ¶

func (*Header) SetHeader ¶

func (*Header) SetHeaderKV ¶

func (*Header) SetIntHeader ¶

type Request ¶

func AckquireRequest ¶

func (*Request) Method ¶

func (*Request) Path ¶

func (*Request) ReadReq ¶

func (*Request) Reset ¶

func (*Request) SetMethod ¶

func (*Request) SetMethodStr ¶

func (*Request) SetPath ¶

func (*Request) SetPathStr ¶

func (*Request) WriteReq ¶

type Response ¶

func AckquireResponse ¶

func (*Response) Code ¶

func (*Response) ReadResp ¶

func (*Response) Reason ¶

func (*Response) Reset ¶

func (*Response) SetCode ¶

func (*Response) SetReason ¶

func (*Response) SetReasonStr ¶

func (*Response) Status ¶

func (*Response) WriteResp ¶

type Server ¶

func (*Server) Serve ¶

Source Files ¶

Directories ¶