Documentation
¶
Index ¶
- type 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, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Relayer ¶
func NewRelayer ¶
func (*Relayer) BuildPipeline ¶
func (*Relayer) Check ¶
func (r *Relayer) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)
func (*Relayer) PollSourceHeadUntilReady ¶
func (*Relayer) SetupBlockStreamServer ¶
func (*Relayer) StartListening ¶
Click to show internal directories.
Click to hide internal directories.