cocainetest

Documentation

Overview

Example

var handler cocaine.EventHandler // check type

handler = func(ctx context.Context, req cocaine.Request, resp cocaine.Response) {
	inp, _ := req.Read(ctx)

	resp.Write(inp)
	resp.ErrorMsg(100, "testerrormessage")
	resp.Close()
}

mockRequest := NewRequest()
mockRequest.Write([]byte("PING"))

mockResponse := NewResponse()

handler(context.Background(), mockRequest, mockResponse)

fmt.Printf("data: %s error: %d %s \n",
	mockResponse.Bytes(), mockResponse.Err.Code, mockResponse.Err.Msg)

Output:

data: PING error: 100 testerrormessage

Index

• type CocaineError
• type Request
  • func NewRequest() *Request
  • func (r *Request) Read(ctx context.Context) (chunk []byte, err error)
  • func (r *Request) Write(p []byte) (int, error)
• type Response
  • func NewResponse() *Response
  • func (r *Response) Close() error
  • func (r *Response) ErrorMsg(code int, msg string) error
  • func (r *Response) ZeroCopyWrite(data []byte) error

Examples

• Package

Types

type CocaineError

type CocaineError struct {
	Msg  string
	Code int
}

type Request

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

func NewRequest

func NewRequest() *Request

func (*Request) Read

func (r *Request) Read(ctx context.Context) (chunk []byte, err error)

func (*Request) Write

func (r *Request) Write(p []byte) (int, error)

type Response

type Response struct {
	*bytes.Buffer

	Err *CocaineError
	// contains filtered or unexported fields
}

func NewResponse

func NewResponse() *Response

func (*Response) Close

func (r *Response) Close() error

func (*Response) ErrorMsg

func (r *Response) ErrorMsg(code int, msg string) error

func (*Response) ZeroCopyWrite

func (r *Response) ZeroCopyWrite(data []byte) error