Structs

A client request for continuously streaming transaction outputs with proofs

A client request for continuously streaming transactions with proofs

A client request for fetching all available epoch ending ledger infos.

A client request for fetching all states at a specified version.

A client request for fetching all transaction outputs with proofs.

A client request for fetching all transactions with proofs.

Messages used by the data streaming client for communication with the streaming service. The streaming service will respond to the client request through the given response_sender.

The streaming service client that talks to the streaming service.

The component that enables listening to requests from streaming service clients (e.g., state sync).

A client request for terminating a stream and providing payload feedback.

Enums

The feedback for a given notification.

The data streaming request from the client.

Traits

The streaming client used by state sync to fetch data from the Aptos network to synchronize local state.

Functions

This method returns a (StreamingServiceClient, StreamingServiceListener) pair that can be used to allow clients to make requests to the streaming service.

Type Definitions