Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrConnectionClosed = errors.New("connection closed")
Functions ¶
This section is empty.
Types ¶
type Conn ¶
type Conn struct { RH *RegistryHandler // contains filtered or unexported fields }
func (*Conn) AttachToMux ¶
type JsonRPCError ¶
type JsonRPCRequest ¶
type JsonRPCResponse ¶
type JsonRPCResponse struct { ID uint64 `json:"id"` JSONRPC string `json:"jsonrpc"` Error *JsonRPCError `json:"error,omitempty"` Result json.RawMessage `json:"result"` }
type JsonRPCSend ¶
type JsonRPCSend struct { JsonRPCRequest RespCH chan Response }
type LockedResponseMap ¶
type LockedResponseMap struct { Map map[uint64]ResponseStore L sync.RWMutex }
type RegistryHandler ¶
type ResponseStore ¶
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
func NewSession ¶
func NewSession() *Session
type SessionRequest ¶
type SessionRequest struct {
// contains filtered or unexported fields
}
func (*SessionRequest) Arguments ¶
func (sR *SessionRequest) Arguments() []interface{}
type SessionResponse ¶
type SessionResponse struct { ID uint64 SessionContext context.Context RespCh chan JsonRPCResponse }
func (*SessionResponse) Send ¶
func (sR *SessionResponse) Send(data io.ReadCloser, err error) error
Click to show internal directories.
Click to hide internal directories.