rpc

Jul 11, 2017

Changes in this version

type Client

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

May 4, 2017

Changes in this version

+ const EarliestBlockNumber

Nov 15, 2016

Changes in this version

+ 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 HexBytes []byte

+ func (b *HexBytes) UnmarshalJSON(input []byte) error

+ func (b HexBytes) MarshalJSON() ([]byte, error)

+ 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

Jun 6, 2016

Changes in this version

+ const JSONRPCVersion

+ const MetadataApi

Apr 19, 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)

Jun 30, 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)

May 12, 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

+ 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 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

+ 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

+ type GetStorageAtArgs struct

+ Address string

+ BlockNumber int64

+ Key string

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

type GetTxCountArgs

+ BlockNumber int64

+ 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

+ Nonce *big.Int

+ 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 RpcErrorResponse

+ Id interface{}

+ Jsonrpc string

type RpcRequest

+ Id interface{}

+ Jsonrpc string

type RpcSuccessResponse

+ Id interface{}

+ Jsonrpc string

+ 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

+ Topics []string

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

Feb 22, 2015

Changes in this version

type EthereumApi

+ func (self *EthereumApi) AllLogs(args *FilterOptions, reply *interface{}) error

type Log

+ Number uint64

Feb 20, 2015

Changes in this version

+ const ErrorArguments

+ const ErrorDecodeArgs

+ const ErrorNotImplemented

+ const ErrorParseRequest

+ const ErrorUnknown

+ func NewErrorResponseWithError(msg string, err error) error

+ type DbArgs struct

+ Database string

+ Key string

+ Value string

type EthereumApi

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

+ func (p *EthereumApi) Accounts(reply *interface{}) error

+ func (p *EthereumApi) BlockNumber(reply *interface{}) error

+ func (p *EthereumApi) Call(args *NewTxArgs, reply *interface{}) error

+ func (p *EthereumApi) CompileSerpent(script string, reply *interface{}) error

+ func (p *EthereumApi) DbGet(args *DbArgs, reply *interface{}) error

+ func (p *EthereumApi) DbPut(args *DbArgs, reply *interface{}) error

+ func (p *EthereumApi) GetCodeAt(args *GetCodeAtArgs, reply *interface{}) error

+ func (p *EthereumApi) GetCompilers(reply *interface{}) error

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

+ func (p *EthereumApi) GetStateAt(args *GetStateArgs, reply *interface{}) error

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

+ func (p *EthereumApi) NewWhisperFilter(args *xeth.Options, reply *interface{}) error

+ func (p *EthereumApi) NewWhisperIdentity(reply *interface{}) error

+ func (p *EthereumApi) SetMining(shouldmine bool, reply *interface{}) error

+ func (p *EthereumApi) Sha3(args *Sha3Args, reply *interface{}) error

+ func (p *EthereumApi) WhisperMessages(id int, reply *interface{}) error

+ func (p *EthereumApi) WhisperPost(args *WhisperMessageArgs, reply *interface{}) error

+ func (self *EthereumApi) FilterChanged(id int, reply *interface{}) error

+ func (self *EthereumApi) Logs(id int, reply *interface{}) error

+ func (self *EthereumApi) MessagesChanged(id int, reply *interface{}) error

+ func (self *EthereumApi) NewFilter(args *FilterOptions, reply *interface{}) error

+ func (self *EthereumApi) NewFilterString(args string, reply *interface{}) error

+ func (self *EthereumApi) Register(args string, reply *interface{}) error

+ func (self *EthereumApi) UninstallFilter(id int, reply *interface{}) error

+ func (self *EthereumApi) Unregister(args string, reply *interface{}) error

+ func (self *EthereumApi) WatchTx(args string, reply *interface{}) error

+ type FilterChangedArgs struct

+ type FilterOptions struct

+ Address interface{}

+ Earliest int64

+ Latest int64

+ Max int

+ Skip int

+ Topic []string

type GetBalanceArgs

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

type GetBlockArgs

+ func (obj *GetBlockArgs) UnmarshalJSON(b []byte) (err error)

+ type GetCodeAtArgs struct

+ Address string

+ func (obj *GetCodeAtArgs) UnmarshalJSON(b []byte) (err error)

+ type GetStateArgs struct

+ Address string

+ Key string

+ func (obj *GetStateArgs) UnmarshalJSON(b []byte) (err error)

type GetStorageArgs

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

type GetTxCountArgs

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

+ type JsonWrapper struct

+ func (self JsonWrapper) ParseRequestBody(req *http.Request) (RpcRequest, error)

+ func (self JsonWrapper) Send(writer io.Writer, v interface{}) (n int, err error)

+ type Log struct

+ Address string

+ Data string

+ Topic []string

type NewTxArgs

+ Data string

+ From string

+ To string

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

type PushTxArgs

+ func (obj *PushTxArgs) UnmarshalJSON(b []byte) (err error)

+ 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

+ func (req *RpcRequest) ToBoolArgs() (bool, error)

+ func (req *RpcRequest) ToCompileArgs() (string, error)

+ func (req *RpcRequest) ToDbGetArgs() (*DbArgs, error)

+ func (req *RpcRequest) ToDbPutArgs() (*DbArgs, error)

+ func (req *RpcRequest) ToFilterArgs() (*FilterOptions, error)

+ func (req *RpcRequest) ToFilterChangedArgs() (int, error)

+ func (req *RpcRequest) ToFilterStringArgs() (string, error)

+ func (req *RpcRequest) ToGetBalanceArgs() (*GetBalanceArgs, error)

+ func (req *RpcRequest) ToGetBlockArgs() (*GetBlockArgs, error)

+ func (req *RpcRequest) ToGetCodeAtArgs() (*GetCodeAtArgs, error)

+ func (req *RpcRequest) ToGetStateArgs() (*GetStateArgs, error)

+ func (req *RpcRequest) ToGetTxCountArgs() (*GetTxCountArgs, error)

+ func (req *RpcRequest) ToIdArgs() (int, error)

+ func (req *RpcRequest) ToNewTxArgs() (*NewTxArgs, error)

+ func (req *RpcRequest) ToPushTxArgs() (*PushTxArgs, error)

+ func (req *RpcRequest) ToRegisterArgs() (string, error)

+ func (req *RpcRequest) ToSha3Args() (*Sha3Args, error)

+ func (req *RpcRequest) ToStorageAtArgs() (*GetStorageArgs, error)

+ func (req *RpcRequest) ToUninstallFilterArgs() (int, error)

+ func (req *RpcRequest) ToWatchTxArgs() (string, error)

+ func (req *RpcRequest) ToWhisperFilterArgs() (*xeth.Options, error)

+ func (req *RpcRequest) ToWhisperHasIdentityArgs() (string, error)

+ func (req *RpcRequest) ToWhisperPostArgs() (*WhisperMessageArgs, error)

+ type RpcServer interface

+ Start func()

+ Stop func()

+ type RpcSuccessResponse struct

+ ID interface{}

+ JsonRpc string

+ Result interface{}

+ type Sha3Args struct

+ Data string

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

+ type WhisperMessageArgs struct

+ From string

+ Payload string

+ Priority uint32

+ To string

+ Topic []string

+ Ttl uint32

Dec 21, 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