jsonrpc

Documentation

Index

• Variables
• func Dial(endpoint string) *rpc.Client
• type Client
  • func NewClient(endpoint string) *Client
  • func (c *Client) Call(serviceMethod string, args interface{}, reply interface{}) error
  • func (c *Client) Close() error
  • func (c *Client) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call

Variables

var Handle = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
	switch r.Method {
	case "POST":
		ch := make(chan error, 1)
		conn := &struct {
			io.ReadCloser
			io.Writer
		}{r.Body, w}
		rpc.ServeCodec(&scodec{ch, org.NewServerCodec(conn)})
		<-ch
	default:
		w.Header().Set("Content-Type", "text/plain; charset=utf-8")
		w.WriteHeader(http.StatusMethodNotAllowed)
		io.WriteString(w, "405 POST only\n")
	}
})

Handle ...

Functions

func Dial

func Dial(endpoint string) *rpc.Client

Dial ...

Types

type Client

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

Client ...

func NewClient

func NewClient(endpoint string) *Client

NewClient ...

func (*Client) Call

func (c *Client) Call(serviceMethod string, args interface{}, reply interface{}) error

Call ...

func (*Client) Close

func (c *Client) Close() error

Close ...

func (*Client) Go

func (c *Client) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call

Go ...