comms

Oct 31, 2015

Changes in this version

+ type InitFunc func(conn net.Conn) (Stopper, shared.EthereumApi, error)

+ type Stopper interface

+ Stop func()

Jun 23, 2015

Changes in this version

+ var DefaultHttpRpcApis = strings.Join([]string{ ... }, ",")

+ var DefaultInProcApis = shared.AllApis

+ var DefaultIpcApis = shared.AllApis

+ var ErrClosed = PipeError — windows/amd64

+ func NewHttpClient(cfg HttpConfig, c codec.Codec) *httpClient

+ func NewIpcClient(cfg IpcConfig, codec codec.Codec) (*ipcClient, error)

+ func StartHttp(cfg HttpConfig, codec codec.Codec, api shared.EthereumApi) error

+ func StartIpc(cfg IpcConfig, codec codec.Codec, offeredApi shared.EthereumApi) error

+ func StopHttp()

+ type EthereumClient interface

+ Close func()

+ Recv func() (interface{}, error)

+ Send func(interface{}) error

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

+ func ClientFromEndpoint(endpoint string, c codec.Codec) (EthereumClient, error)

+ type HttpConfig struct

+ CorsDomain string

+ ListenAddress string

+ ListenPort uint

+ type InProcClient struct

+ func NewInProcClient(codec codec.Codec) *InProcClient

+ func (self *InProcClient) Close()

+ func (self *InProcClient) Initialize(offeredApi shared.EthereumApi)

+ func (self *InProcClient) Recv() (interface{}, error)

+ func (self *InProcClient) Send(req interface{}) error

+ func (self *InProcClient) SupportedModules() (map[string]string, error)

+ type IpcConfig struct

+ Endpoint string

+ type PipeAddr string — windows/amd64

+ func (a PipeAddr) Network() string

+ func (a PipeAddr) String() string

+ type PipeConn struct — windows/amd64

+ func Dial(address string) (*PipeConn, error)

+ func DialTimeout(address string, timeout time.Duration) (*PipeConn, error)

+ func (c *PipeConn) Close() error

+ func (c *PipeConn) LocalAddr() net.Addr

+ func (c *PipeConn) Read(b []byte) (int, error)

+ func (c *PipeConn) RemoteAddr() net.Addr

+ func (c *PipeConn) SetDeadline(t time.Time) error

+ func (c *PipeConn) SetReadDeadline(t time.Time) error

+ func (c *PipeConn) SetWriteDeadline(t time.Time) error

+ func (c *PipeConn) Write(b []byte) (int, error)

+ type PipeError struct — windows/amd64

+ func (e PipeError) Error() string

+ func (e PipeError) Temporary() bool

+ func (e PipeError) Timeout() bool

+ type PipeListener struct — windows/amd64

+ func Listen(address string) (*PipeListener, error)

+ func (l *PipeListener) Accept() (net.Conn, error)

+ func (l *PipeListener) AcceptPipe() (*PipeConn, error)

+ func (l *PipeListener) Addr() net.Addr

+ func (l *PipeListener) Close() error