Documentation ¶
Overview ¶
Package websocket provides a websocket interface as a data ingestion mechanism
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.