fakehttp

Documentation

Index

• Constants
• func RegisterVar(name string, value func(request *Request) string)
• type PushID
  • func Bytes2PushID(b []byte, c conn.Conn) *PushID
  • func GetPushID(c conn.Conn) *PushID
  • func (p *PushID) Ack()
  • func (p *PushID) CancelWaitingAck()
  • func (p *PushID) ToBytes() []byte
  • func (p *PushID) WaitAck() <-chan struct{}
• type Request
  • func NewRequest(conn conn.Conn, data []byte) (req *Request, err error)
  • func (r *Request) Buffers() net.Buffers
  • func (r *Request) GetReqId() uint32
  • func (r *Request) GetVar(name string) string
  • func (r *Request) IsPushAck() (yes bool, err error)
  • func (r *Request) SetReqId(req uint32)
• type Response
  • func NewResponseWithFailed(request *Request, err error) *Response
  • func NewResponseWithPush(conn conn.Conn, pushId []byte, data []byte) *Response
  • func NewResponseWithStream(data []byte) *Response
  • func NewResponseWithSuccess(request *Request, data []byte) *Response
  • func (r *Response) Data() []byte
  • func (r *Response) ReqId() uint32
  • func (r *Response) Status() byte
  • func (r *Response) Write() error

Constants

const (
	Success   byte   = 0
	Failed    byte   = 1
	PushReqId uint32 = 1
)

const (
	ReqIDLen = 4
)

Functions

func RegisterVar

func RegisterVar(name string, value func(request *Request) string)

Types

type PushID

type PushID struct {
	Value uint32
	// contains filtered or unexported fields
}

func Bytes2PushID

func Bytes2PushID(b []byte, c conn.Conn) *PushID

func GetPushID

func GetPushID(c conn.Conn) *PushID

func (*PushID) Ack

func (p *PushID) Ack()

func (*PushID) CancelWaitingAck

func (p *PushID) CancelWaitingAck()

func (*PushID) ToBytes

func (p *PushID) ToBytes() []byte

func (*PushID) WaitAck

func (p *PushID) WaitAck() <-chan struct{}

type Request

type Request struct {
	Conn   conn.Conn
	ReqId  []byte
	Header map[string]string
	Data   []byte
}

func NewRequest

func NewRequest(conn conn.Conn, data []byte) (req *Request, err error)

func (*Request) Buffers

func (r *Request) Buffers() net.Buffers

func (*Request) GetReqId

func (r *Request) GetReqId() uint32

func (*Request) GetVar

func (r *Request) GetVar(name string) string

func (*Request) IsPushAck

func (r *Request) IsPushAck() (yes bool, err error)

func (*Request) SetReqId

func (r *Request) SetReqId(req uint32)

type Response

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

func NewResponseWithFailed

func NewResponseWithFailed(request *Request, err error) *Response

func NewResponseWithPush

func NewResponseWithPush(conn conn.Conn, pushId []byte, data []byte) *Response

func NewResponseWithStream

func NewResponseWithStream(data []byte) *Response

func NewResponseWithSuccess

func NewResponseWithSuccess(request *Request, data []byte) *Response

func (*Response) Data

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

func (*Response) ReqId

func (r *Response) ReqId() uint32

func (*Response) Status

func (r *Response) Status() byte

func (*Response) Write

func (r *Response) Write() error