websocket

Documentation

Overview

Package websocket provides a websocket interface as a data ingestion mechanism

Index

• func ConsumeWebsocketsEvents(config *config.EthConfig, websocketURL string, replicaCodec *goavro.Codec, ...)

Functions

func ConsumeWebsocketsEvents

func ConsumeWebsocketsEvents(config *config.EthConfig, websocketURL string, replicaCodec *goavro.Codec, ethClient *ethclient.Client, gcpStorageClient *storage.Client, binaryLocalPath, replicaBucket, proofChain string)

ConsumeWebsocketsEvents is the primary consumer of websocket events from an websocket endpoint