Versions in this module Expand all Collapse all v0 v0.0.1 Jun 23, 2020 Changes in this version + type Relayer struct + func NewRelayer(sourceAddresses []string, mergerAddr string, maxSourceLatency time.Duration, ...) *Relayer + func (r *Relayer) BuildPipeline(startBlock uint64, blockStore dstore.Store) + func (r *Relayer) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error) + func (r *Relayer) Drift() time.Duration + func (r *Relayer) PollSourceHeadUntilReady(readyStartBlock chan uint64, maxSourceLatency time.Duration, ...) + func (r *Relayer) SetupBlockStreamServer(bufferSize int) + func (r *Relayer) StartListening(bufferSize int) error + func (r *Relayer) StartRelayingBlocks(startBlockReady chan uint64, blockStore dstore.Store, ...)
Go to main page