ethereum

Documentation

Index

• type EthChain
  • func NewEthChain(config chains.ChainConfig, streamer Streamer, router Router) EthChain
  • func (ec EthChain) Start() error
• type Router
  • func NewRouter(keybase *keybase.Keypair) Router
  • func (er Router) Route(eventData types.EventData) error
• type Streamer
  • func NewStreamer(websocketURL string) Streamer
  • func (es Streamer) Start(logs chan<- types.EventData, errs chan<- error)

Types

type EthChain

type EthChain struct {
	Config   chains.ChainConfig // The config of this chain
	Streamer Streamer           // The streamer of this chain
	Router   Router             // The router of this chain
}

EthChain streams the Ethereum blockchain and routes tx data packets

func NewEthChain

func NewEthChain(config chains.ChainConfig, streamer Streamer, router Router) EthChain

NewEthChain initializes a new instance of EthChain

func (EthChain) Start

func (ec EthChain) Start() error

Start starts the chain's Streamer and Router

type Router

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

Router packages raw event data as Packets and relays them to the bridge

func NewRouter

func NewRouter(keybase *keybase.Keypair) Router

NewRouter initializes a new instance of Router

func (Router) Route

func (er Router) Route(eventData types.EventData) error

Route packages tx data as a packet and relays it to the bridge

type Streamer

type Streamer struct {
	WebsocketURL string
	// contains filtered or unexported fields
}

Streamer streams the Ethereum blockchain for application events

func NewStreamer

func NewStreamer(websocketURL string) Streamer

NewStreamer initializes a new instance of Streamer

func (Streamer) Start

func (es Streamer) Start(logs chan<- types.EventData, errs chan<- error)

Start initializes filtered subscriptions to each registered application