Skip to content
This repository was archived by the owner on Mar 19, 2024. It is now read-only.
This repository was archived by the owner on Mar 19, 2024. It is now read-only.

Create new Polling function to poll AN GetExecutionDataByBlockID API instead of gcp streamer #32

Description

@koko1123

Description

This is the intermediate step for streaming the execution data

Definition of Done

The polling implementation has some extra requirements, it should:

  • Contain the same mechanism for polling as GCP streamer, i.e should poll for the next block is missing, until it finds it, no exponential backoff etc.
  • Gracefully recover from losing connection to the upstream AN
  • Convert and store the files just as the gcp streamer's output function did and mainatain the streamer's queue
  • Use the same catchup block logic as the gcp streamer

Metadata

Metadata

Assignees

Labels

Type

No type
No fields configured for issues without a type.

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions