http

Documentation

Index

• func Matcher(p rpc.ReadPeeker) bool
• type Builder
  • func (Builder) NewClient(s rpc.Stream, opts data.Map) rpc.ClientCodec
  • func (Builder) NewServer(s rpc.Stream, opts data.Map) rpc.ServerCodec
• type ClientCodec
  • func (c *ClientCodec) DecodeHead(head *rpc.ResponseHead) (err error)
  • func (c *ClientCodec) DecodeResult(result *rpc.Result) error
  • func (c *ClientCodec) DiscardResult() (err error)
  • func (c *ClientCodec) Encode(req *rpc.Request) (err error)
• type ServerCodec
  • func (c *ServerCodec) DecodeArgs(args []interface{}) error
  • func (c *ServerCodec) DecodeHead(head *rpc.RequestHead) (err error)
  • func (c *ServerCodec) DiscardArgs() error
  • func (c *ServerCodec) Encode(resp *rpc.Response) (err error)

Functions

func Matcher

func Matcher(p rpc.ReadPeeker) bool

Matcher is an HTTP Matcher.

Types

type Builder

type Builder struct {
}

func (Builder) NewClient

func (Builder) NewClient(s rpc.Stream, opts data.Map) rpc.ClientCodec

func (Builder) NewServer

func (Builder) NewServer(s rpc.Stream, opts data.Map) rpc.ServerCodec

type ClientCodec

type ClientCodec struct {
	rpc.Stream
	// contains filtered or unexported fields
}

func (*ClientCodec) DecodeHead

func (c *ClientCodec) DecodeHead(head *rpc.ResponseHead) (err error)

func (*ClientCodec) DecodeResult

func (c *ClientCodec) DecodeResult(result *rpc.Result) error

func (*ClientCodec) DiscardResult

func (c *ClientCodec) DiscardResult() (err error)

func (*ClientCodec) Encode

func (c *ClientCodec) Encode(req *rpc.Request) (err error)

Encode send request to RPC server. For example

POST /Test.Hello HTTP/1.1
AUXO-RPC-ID: 5a3a470453d38640fa000001
Content-Length: 8

["auxo"]

type ServerCodec

type ServerCodec struct {
	rpc.Stream
	// contains filtered or unexported fields
}

func (*ServerCodec) DecodeArgs

func (c *ServerCodec) DecodeArgs(args []interface{}) error

func (*ServerCodec) DecodeHead

func (c *ServerCodec) DecodeHead(head *rpc.RequestHead) (err error)

func (*ServerCodec) DiscardArgs

func (c *ServerCodec) DiscardArgs() error

func (*ServerCodec) Encode

func (c *ServerCodec) Encode(resp *rpc.Response) (err error)

Encode send response to RPC client. For example

HTTP/1.1 200 OK Content-Length: 24 Auxo-Rpc-Id: 5a3a470453d38640fa000001 Connection: Keep-Alive Content-Type: application/json; charset=UTF-8 Date: Thu, 21 Dec 2017 11:18:52 CST Server: auxo-rpc

{"value":"Hello, auxo"}