rpc

package

Go to main page

Versions in this module

v1

v1.9.2

Aug 13, 2019

Changes in this version

+ var DefaultHTTPTimeouts = HTTPTimeouts

type Client

+ func ClientFromContext(ctx context.Context) (*Client, bool)

+ func DialIO(ctx context.Context, in io.Reader, out io.Writer) (*Client, error)

+ func (c *Client) Notify(ctx context.Context, method string, args ...interface{}) error

+ func (c *Client) RegisterName(name string, receiver interface{}) error

+ type Conn interface

+ SetWriteDeadline func(time.Time) error

+ type ConnRemoteAddr interface

+ RemoteAddr func() string

+ type HTTPTimeouts struct

+ IdleTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

type ServerCodec

+ Read func() (msgs []*jsonrpcMessage, isBatch bool, err error)

type Subscription

+ func (s *Subscription) MarshalJSON() ([]byte, error)

v1.8.8

May 14, 2018

Changes in this version

type Client

+ func DialHTTPWithClient(endpoint string, client *http.Client) (*Client, error)

+ func DialStdIO(ctx context.Context) (*Client, error)

+ func (c *Client) Subscribe(ctx context.Context, namespace string, channel interface{}, ...) (*ClientSubscription, error)

type Server

+ func StartHTTPEndpoint(endpoint string, apis []API, modules []string, cors []string, vhosts []string) (net.Listener, *Server, error)

+ func StartIPCEndpoint(ipcEndpoint string, apis []API) (net.Listener, *Server, error)

+ func StartWSEndpoint(endpoint string, apis []API, modules []string, wsOrigins []string, ...) (net.Listener, *Server, error)

type ServerCodec

+ func NewCodec(rwc io.ReadWriteCloser, encode, decode func(v interface{}) error) ServerCodec

+ type StdIOConn struct

+ func (io StdIOConn) Close() error

+ func (io StdIOConn) LocalAddr() net.Addr

+ func (io StdIOConn) Read(b []byte) (n int, err error)

+ func (io StdIOConn) RemoteAddr() net.Addr

+ func (io StdIOConn) SetDeadline(t time.Time) error

+ func (io StdIOConn) SetReadDeadline(t time.Time) error

+ func (io StdIOConn) SetWriteDeadline(t time.Time) error

+ func (io StdIOConn) Write(b []byte) (n int, err error)

v1.7.0

Sep 14, 2017

Changes in this version

+ const EarliestBlockNumber

type Client

+ func (c *Client) ShhSubscribe(ctx context.Context, channel interface{}, args ...interface{}) (*ClientSubscription, error)

v1.6.0

Apr 14, 2017

Changes in this version

+ const MetadataApi

+ var ErrClientQuit = errors.New("client is closed")

+ var ErrNoResult = errors.New("no result in JSON-RPC response")

+ var ErrSubscriptionNotFound = errors.New("subscription not found")

+ var ErrSubscriptionQueueOverflow = errors.New("subscription queue overflow")

+ type BatchElem struct

+ Args []interface{}

+ Error error

+ Method string

+ Result interface{}

type Client

+ func Dial(rawurl string) (*Client, error)

+ func DialContext(ctx context.Context, rawurl string) (*Client, error)

+ func DialHTTP(endpoint string) (*Client, error)

+ func DialIPC(ctx context.Context, endpoint string) (*Client, error)

+ func DialInProc(handler *Server) *Client

+ func DialWebsocket(ctx context.Context, endpoint, origin string) (*Client, error)

+ func (c *Client) BatchCall(b []BatchElem) error

+ func (c *Client) BatchCallContext(ctx context.Context, b []BatchElem) error

+ func (c *Client) Call(result interface{}, method string, args ...interface{}) error

+ func (c *Client) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error

+ func (c *Client) EthSubscribe(ctx context.Context, channel interface{}, args ...interface{}) (*ClientSubscription, error)

+ type ClientSubscription struct

+ func (sub *ClientSubscription) Err() <-chan error

+ func (sub *ClientSubscription) Unsubscribe()

+ type Error interface

+ Error func() string

+ ErrorCode func() int

+ type ID string

+ func NewID() ID

type Notifier

+ func (n *Notifier) Closed() <-chan interface{}

+ func (n *Notifier) CreateSubscription() *Subscription

+ func (n *Notifier) Notify(id ID, data interface{}) error

type Server

+ func (srv *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (srv *Server) ServeListener(l net.Listener) error

+ func (srv *Server) WebsocketHandler(allowedOrigins []string) http.Handler

type Subscription

+ func (s *Subscription) Err() <-chan error

v1.4.5

May 24, 2016

Changes in this version

+ const DefaultHTTPApis

+ const DefaultIPCApis

+ const LatestBlockNumber

+ const PendingBlockNumber

+ var ErrNotificationNotFound = errors.New("notification not found")

+ var ErrNotificationsUnsupported = errors.New("notifications not supported")

+ func CreateIPCListener(endpoint string) (net.Listener, error)

+ func NewHTTPServer(corsString string, srv *Server) *http.Server

+ func NewWSServer(allowedOrigins string, handler *Server) *http.Server

+ func SupportedModules(client Client) (map[string]string, error)

+ type API struct

+ Namespace string

+ Public bool

+ Service interface{}

+ Version string

+ type BlockNumber int64

+ func (bn *BlockNumber) Int64() int64

+ func (bn *BlockNumber) UnmarshalJSON(data []byte) error

+ type Client interface

+ Close func()

+ Recv func(msg interface{}) error

+ Send func(req interface{}) error

+ SupportedModules func() (map[string]string, error)

+ func NewHTTPClient(endpoint string) (Client, error)

+ func NewIPCClient(endpoint string) (Client, error)

+ func NewInProcRPCClient(handler *Server) Client

+ func NewWSClient(endpoint string) (Client, error)

+ type CodecOption int

+ const OptionMethodInvocation

+ const OptionSubscriptions

+ type HexNumber big.Int

+ func NewHexNumber(val interface{}) *HexNumber

+ func (h *HexNumber) BigInt() *big.Int

+ func (h *HexNumber) Int() int

+ func (h *HexNumber) Int64() int64

+ func (h *HexNumber) MarshalJSON() ([]byte, error)

+ func (h *HexNumber) Uint() uint

+ func (h *HexNumber) Uint64() uint64

+ func (h *HexNumber) UnmarshalJSON(input []byte) error

+ type JSONErrResponse struct

+ Error JSONError

+ Id interface{}

+ Version string

+ type JSONError struct

+ Code int

+ Data interface{}

+ Message string

+ type JSONRequest struct

+ Id json.RawMessage

+ Method string

+ Payload json.RawMessage

+ Version string

+ type JSONSuccessResponse struct

+ Id interface{}

+ Result interface{}

+ Version string

+ type Notifier interface

+ NewSubscription func(UnsubscribeCallback) (Subscription, error)

+ Unsubscribe func(id string) error

+ func NotifierFromContext(ctx context.Context) (Notifier, bool)

+ type RPCError interface

+ Code func() int

+ Error func() string

+ type RPCService struct

+ func (s *RPCService) Modules() map[string]string

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) RegisterName(name string, rcvr interface{}) error

+ func (s *Server) ServeCodec(codec ServerCodec, options CodecOption)

+ func (s *Server) ServeSingleRequest(codec ServerCodec, options CodecOption)

+ func (s *Server) Stop()

+ type ServerCodec interface

+ Close func()

+ Closed func() <-chan interface{}

+ CreateErrorResponse func(interface{}, RPCError) interface{}

+ CreateErrorResponseWithInfo func(id interface{}, err RPCError, info interface{}) interface{}

+ CreateNotification func(string, interface{}) interface{}

+ CreateResponse func(interface{}, interface{}) interface{}

+ ParseRequestArguments func([]reflect.Type, interface{}) ([]reflect.Value, RPCError)

+ ReadRequestHeaders func() ([]rpcRequest, bool, RPCError)

+ Write func(interface{}) error

+ func NewJSONCodec(rwc io.ReadWriteCloser) ServerCodec

+ type Subscription interface

+ Cancel func() error

+ ID func() string

+ Notify func(data interface{}) error

+ type UnsubscribeCallback func(id string)

v1.2.3

Oct 21, 2015

v1.0.2

Aug 20, 2015

v0

v0.9.38

Jul 9, 2015

Changes in this version

+ type Xeth struct

+ func NewXeth(client comms.EthereumClient) *Xeth

+ func (self *Xeth) Call(method string, params []interface{}) (map[string]interface{}, error)

v0.9.26

May 28, 2015

v0.9.21

May 15, 2015

Changes in this version

+ func JSONRPC(pipe *xeth.XEth) http.Handler

+ func NewDecodeParamError(errstr string) error

+ func NewHashesRes(hs []common.Hash) []string

+ func NewValidationError(param string, msg string) error

+ func RpcResponse(api *EthereumApi, request *RpcRequest) *interface

+ func Start(pipe *xeth.XEth, config RpcConfig) error

+ func Stop() error

+ type BlockFilterArgs struct

+ Address []string

+ Earliest int64

+ Latest int64

+ Max int

+ Skip int

+ Topics [][]string

+ func (args *BlockFilterArgs) UnmarshalJSON(b []byte) (err error)

+ type BlockNumArg struct

+ BlockNumber int64

+ func (args *BlockNumArg) UnmarshalJSON(b []byte) (err error)

+ type BlockNumIndexArgs struct

+ BlockNumber int64

+ Index int64

+ func (args *BlockNumIndexArgs) UnmarshalJSON(b []byte) (err error)

+ type BlockRes struct

+ BlockHash *hexdata

+ BlockNumber *hexnum

+ Difficulty *hexnum

+ ExtraData *hexdata

+ GasLimit *hexnum

+ GasUsed *hexnum

+ LogsBloom *hexdata

+ Miner *hexdata

+ Nonce *hexdata

+ ParentHash *hexdata

+ Sha3Uncles *hexdata

+ Size *hexnum

+ StateRoot *hexdata

+ TotalDifficulty *hexnum

+ TransactionRoot *hexdata

+ Transactions []*TransactionRes

+ Uncles []*UncleRes

+ UnixTimestamp *hexnum

+ func NewBlockRes(block *types.Block, fullTx bool) *BlockRes

+ func (b *BlockRes) MarshalJSON() ([]byte, error)

+ type CallArgs struct

+ BlockNumber int64

+ Data string

+ From string

+ Gas *big.Int

+ GasPrice *big.Int

+ To string

+ Value *big.Int

+ func (args *CallArgs) UnmarshalJSON(b []byte) (err error)

+ type CompileArgs struct

+ Source string

+ func (args *CompileArgs) UnmarshalJSON(b []byte) (err error)

+ type DbArgs struct

+ Database string

+ Key string

+ Value []byte

+ func (args *DbArgs) UnmarshalJSON(b []byte) (err error)

+ type DbHexArgs struct

+ Database string

+ Key string

+ Value []byte

+ func (args *DbHexArgs) UnmarshalJSON(b []byte) (err error)

+ type DecodeParamError struct

+ func (e *DecodeParamError) Error() string

type EthereumApi

+ func NewEthereumApi(xeth *xeth.XEth) *EthereumApi

+ func (api *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) error

+ type FilterIdArgs struct

+ Id int

+ func (args *FilterIdArgs) UnmarshalJSON(b []byte) (err error)

+ type FilterStringArgs struct

+ Word string

+ func (args *FilterStringArgs) UnmarshalJSON(b []byte) (err error)

type GetBalanceArgs

+ BlockNumber int64

+ func (args *GetBalanceArgs) UnmarshalJSON(b []byte) (err error)

+ type GetBlockByHashArgs struct

+ BlockHash string

+ IncludeTxs bool

+ func (args *GetBlockByHashArgs) UnmarshalJSON(b []byte) (err error)

+ type GetBlockByNumberArgs struct

+ BlockNumber int64

+ IncludeTxs bool

+ func (args *GetBlockByNumberArgs) UnmarshalJSON(b []byte) (err error)

+ type GetDataArgs struct

+ Address string

+ BlockNumber int64

+ func (args *GetDataArgs) UnmarshalJSON(b []byte) (err error)

type GetStorageArgs

+ BlockNumber int64

+ func (args *GetStorageArgs) UnmarshalJSON(b []byte) (err error)

+ type GetStorageAtArgs struct

+ Address string

+ BlockNumber int64

+ Key string

+ func (args *GetStorageAtArgs) UnmarshalJSON(b []byte) (err error)

type GetTxCountArgs

+ BlockNumber int64

+ func (args *GetTxCountArgs) UnmarshalJSON(b []byte) (err error)

+ type HashArgs struct

+ Hash string

+ func (args *HashArgs) UnmarshalJSON(b []byte) (err error)

+ type HashIndexArgs struct

+ Hash string

+ Index int64

+ func (args *HashIndexArgs) UnmarshalJSON(b []byte) (err error)

+ type InsufficientParamsError struct

+ func NewInsufficientParamsError(have int, want int) *InsufficientParamsError

+ func (e *InsufficientParamsError) Error() string

+ type InvalidTypeError struct

+ func NewInvalidTypeError(method, msg string) *InvalidTypeError

+ func (e *InvalidTypeError) Error() string

+ type Jeth struct

+ func NewJeth(ethApi *EthereumApi, toVal func(interface{}) otto.Value, re *jsre.JSRE) *Jeth

+ func (self *Jeth) Send(call otto.FunctionCall) (response otto.Value)

+ type LogRes struct

+ Address *hexdata

+ BlockHash *hexdata

+ BlockNumber *hexnum

+ Data *hexdata

+ LogIndex *hexnum

+ Topics []*hexdata

+ TransactionHash *hexdata

+ TransactionIndex *hexnum

+ func NewLogRes(log *state.Log) LogRes

+ func NewLogsRes(logs state.Logs) (ls []LogRes)

+ type NewSigArgs struct

+ Data string

+ From string

+ func (args *NewSigArgs) UnmarshalJSON(b []byte) (err error)

type NewTxArgs

+ BlockNumber int64

+ Data string

+ From string

+ Nonce *big.Int

+ To string

+ func (args *NewTxArgs) UnmarshalJSON(b []byte) (err error)

+ type NotAvailableError struct

+ Method string

+ Reason string

+ func NewNotAvailableError(method string, reason string) *NotAvailableError

+ func (e *NotAvailableError) Error() string

+ type NotImplementedError struct

+ Method string

+ func NewNotImplementedError(method string) *NotImplementedError

+ func (e *NotImplementedError) Error() string

+ type RpcConfig struct

+ CorsDomain string

+ ListenAddress string

+ ListenPort uint

+ type RpcErrorObject struct

+ Code int

+ Message string

+ type RpcErrorResponse struct

+ Error *RpcErrorObject

+ Id interface{}

+ Jsonrpc string

+ type RpcRequest struct

+ Id interface{}

+ Jsonrpc string

+ Method string

+ Params json.RawMessage

+ type RpcSuccessResponse struct

+ Id interface{}

+ Jsonrpc string

+ Result interface{}

+ type Sha3Args struct

+ Data string

+ func (args *Sha3Args) UnmarshalJSON(b []byte) (err error)

+ type SourceArgs struct

+ Source string

+ func (args *SourceArgs) UnmarshalJSON(b []byte) (err error)

+ type SubmitWorkArgs struct

+ Digest string

+ Header string

+ Nonce uint64

+ func (args *SubmitWorkArgs) UnmarshalJSON(b []byte) (err error)

+ type TransactionRes struct

+ BlockHash *hexdata

+ BlockNumber *hexnum

+ From *hexdata

+ Gas *hexnum

+ GasPrice *hexnum

+ Hash *hexdata

+ Input *hexdata

+ Nonce *hexnum

+ To *hexdata

+ TxIndex *hexnum

+ Value *hexnum

+ func NewTransactionRes(tx *types.Transaction) *TransactionRes

+ type UncleRes struct

+ BlockHash *hexdata

+ BlockNumber *hexnum

+ Difficulty *hexnum

+ ExtraData *hexdata

+ GasLimit *hexnum

+ GasUsed *hexnum

+ LogsBloom *hexdata

+ Miner *hexdata

+ Nonce *hexdata

+ ParentHash *hexdata

+ ReceiptHash *hexdata

+ Sha3Uncles *hexdata

+ StateRoot *hexdata

+ TransactionRoot *hexdata

+ UnixTimestamp *hexnum

+ func NewUncleRes(h *types.Header) *UncleRes

+ type ValidationError struct

+ ParamName string

+ func (e *ValidationError) Error() string

+ type WhisperFilterArgs struct

+ From string

+ To string

+ Topics [][]string

+ func (args *WhisperFilterArgs) UnmarshalJSON(b []byte) (err error)

+ type WhisperIdentityArgs struct

+ Identity string

+ func (args *WhisperIdentityArgs) UnmarshalJSON(b []byte) (err error)

+ type WhisperMessageArgs struct

+ From string

+ Payload string

+ Priority uint32

+ To string

+ Topics []string

+ Ttl uint32

+ func (args *WhisperMessageArgs) UnmarshalJSON(b []byte) (err error)

v0.7.11

Dec 24, 2014

Changes in this version

+ var JSON jsonWrapper

+ func NewErrorResponse(msg string) error

+ func NewSuccessRes(object JsonResponse) string

+ type BalanceRes struct

+ Address string

+ Balance string

+ type BlockResponse struct

+ type ErrorResponse struct

+ Error bool

+ ErrorText string

+ type EthereumApi struct

+ func (p *EthereumApi) Create(args *NewTxArgs, reply *string) error

+ func (p *EthereumApi) GetBalanceAt(args *GetBalanceArgs, reply *string) error

+ func (p *EthereumApi) GetBlock(args *GetBlockArgs, reply *string) error

+ func (p *EthereumApi) GetCoinbase(args *interface{}, reply *string) error

+ func (p *EthereumApi) GetIsListening(args *interface{}, reply *string) error

+ func (p *EthereumApi) GetIsMining(args *interface{}, reply *string) error

+ func (p *EthereumApi) GetKey(args interface{}, reply *string) error

+ func (p *EthereumApi) GetPeerCount(args *interface{}, reply *string) error

+ func (p *EthereumApi) GetStorageAt(args *GetStorageArgs, reply *string) error

+ func (p *EthereumApi) GetTxCountAt(args *GetTxCountArgs, reply *string) error

+ func (p *EthereumApi) PushTx(args *PushTxArgs, reply *string) error

+ func (p *EthereumApi) Test(args *GetBlockArgs, reply *string) error

+ func (p *EthereumApi) Transact(args *NewTxArgs, reply *string) error

+ type GetBalanceArgs struct

+ Address string

+ type GetBlockArgs struct

+ BlockNumber int

+ Hash string

+ type GetCoinbaseRes struct

+ Coinbase string

+ type GetListeningRes struct

+ IsListening bool

+ type GetMiningRes struct

+ IsMining bool

+ type GetPeerCountRes struct

+ PeerCount int

+ type GetStorageArgs struct

+ Address string

+ Key string

+ type GetStorageAtRes struct

+ Address string

+ Key string

+ Value string

+ type GetTxCountArgs struct

+ Address string

+ type GetTxCountRes struct

+ Nonce int

+ type JsonArgs interface

+ type JsonResponse interface

+ type JsonRpcServer struct

+ func NewJsonRpcServer(pipe *xeth.JSXEth, port int) (*JsonRpcServer, error)

+ func (s *JsonRpcServer) Start()

+ func (s *JsonRpcServer) Stop()

+ type Message struct

+ Args []interface{}

+ Call string

+ Data interface{}

+ Id int

+ func (self *Message) Arguments() *ethutil.Value

+ type NewTxArgs struct

+ Body string

+ Gas string

+ GasPrice string

+ Init string

+ Recipient string

+ Sec string

+ Value string

+ type PushTxArgs struct

+ Tx string

+ type SuccessRes struct

+ Error bool

+ Result JsonResponse

+ type TestRes struct

+ Answer int

+ type TxResponse struct

+ Hash string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL