rpc

package

Go to main page

Versions in this module

v1

v1.8.18

Nov 14, 2018

v1.8.13

Jul 31, 2018

Changes in this version

+ var DefaultHTTPTimeouts = HTTPTimeouts

+ type HTTPTimeouts struct

+ IdleTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

v1.8.12

Jul 4, 2018

v1.8.11

Jun 12, 2018

v1.8.10

May 30, 2018

v1.8.8

May 14, 2018

v1.8.5

Apr 23, 2018

Changes in this version

type Client

+ func DialStdIO(ctx context.Context) (*Client, 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 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.8.3

Mar 26, 2018

Changes in this version

type ServerCodec

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

v1.8.0

Feb 14, 2018

Changes in this version

type Client

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

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

v1.7.0

Sep 14, 2017

Changes in this version

type Client

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

v1.6.5

Jun 1, 2017

v1.6.4

Jun 1, 2017

Changes in this version

+ const EarliestBlockNumber

v1.6.0

Apr 14, 2017

v1.5.8

Feb 1, 2017

v1.5.1

Nov 16, 2016

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

v1.4.5

May 24, 2016

v1.4.3

May 10, 2016

v1.4.2

May 9, 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.3.3

Jan 5, 2016

v1.2.3

Oct 21, 2015

v1.0.5

Sep 9, 2015

v1.0.2

Aug 20, 2015

v1.0.0

Jul 29, 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.32

Jun 23, 2015

v0.9.26

May 28, 2015

v0.9.21

May 15, 2015

Changes in this version

+ type NewSigArgs struct

+ Data string

+ From string

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

+ type NotAvailableError struct

+ Method string

+ Reason string

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

+ func (e *NotAvailableError) Error() string

v0.9.17

May 8, 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 NewTxArgs

+ BlockNumber int64

+ Data string

+ From string

+ Nonce *big.Int

+ To string

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

+ 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