ethws

Documentation

Index

• type Config
• type Error
• type EthereumWS
  • func New(conf Config) *EthereumWS
  • func (ws *EthereumWS) SendRequest(r Request) (<-chan Response, error)
  • func (ws *EthereumWS) State()
• type Request
  • func (r *Request) Marshal() ([]byte, error)
• type Response
  • func (r *Response) Error() error
• type State
• type StateObject

Types

type Config

type Config struct {
	Retry time.Duration
	WSUrl string
}

type Error

type Error struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type EthereumWS

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

func New

func New(conf Config) *EthereumWS

create new ethereum websocket

func (*EthereumWS) SendRequest

func (ws *EthereumWS) SendRequest(r Request) (<-chan Response, error)

send an request to ethereum network

func (*EthereumWS) State

func (ws *EthereumWS) State()

start state machine

type Request

type Request struct {
	ID      int64         `json:"id"`
	Method  string        `json:"method"`
	Params  []interface{} `json:"params"`
	JsonRPC string        `json:"jsonrpc"`
}

func (*Request) Marshal

func (r *Request) Marshal() ([]byte, error)

type Response

type Response struct {
	JsonRPC  string      `json:"jsonrpc"`
	RPCError *Error      `json:"error,omitempty"`
	Result   interface{} `json:"result"`
	ID       int64       `json:"id"`
	// contains filtered or unexported fields
}

func (*Response) Error

func (r *Response) Error() error

type State

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

type StateObject

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