duplex

type Channel struct {
	*Peer
	// contains filtered or unexported fields
}

type Codec struct {
	Name   string
	Encode func(obj interface{}) ([]byte, error)
	Decode func(frame []byte, obj interface{}) error
}

type Error struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

type Message struct {
	Type    string      `json:"type"`
	Method  string      `json:"method,omitempty"`
	Payload interface{} `json:"payload,omitempty"`
	Error   *Error      `json:"error,omitempty"`
	Id      int         `json:"id,omitempty"`
	More    bool        `json:"more,omitempty"`
	Ext     interface{} `json:"ext,omitempty"`
}

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

type RPC struct {
	sync.Mutex
	// contains filtered or unexported fields
}