muxrpc

Documentation

Overview

muxrpc document

muxrpc project muxrpc.go

Index

• type Conn
  • func New(c io.ReadWriteCloser, ...) *Conn
  • func (mx *Conn) Call(method string, reply interface{}, args ...interface{}) error
  • func (mx *Conn) DeregisterReturn(req int32)
  • func (mx *Conn) Handle() error
  • func (mx *Conn) RegisterReturn(req int32, h func(*codec.Packet))
  • func (mx *Conn) Send(p *codec.Packet) error
  • func (mx *Conn) Source(method string, reply func(p *codec.Packet), args ...interface{}) error
• type Request

Types

type Conn

type Conn struct {
	Done chan struct{}
	// contains filtered or unexported fields
}

func New

func New(c io.ReadWriteCloser, handlers map[string]func(conn *Conn, req int32, args json.RawMessage)) *Conn

func (*Conn) Call

func (mx *Conn) Call(method string, reply interface{}, args ...interface{}) error

func (*Conn) DeregisterReturn

func (mx *Conn) DeregisterReturn(req int32)

func (*Conn) Handle

func (mx *Conn) Handle() error

func (*Conn) RegisterReturn

func (mx *Conn) RegisterReturn(req int32, h func(*codec.Packet))

func (*Conn) Send

func (mx *Conn) Send(p *codec.Packet) error

func (*Conn) Source

func (mx *Conn) Source(method string, reply func(p *codec.Packet), args ...interface{}) error

type Request

type Request struct {
	Name []string      `json:"name"`
	Args []interface{} `json:"args"`
	Type string        `json:"type,omitempty"`
}