From 49e4f71a1e304a122c72bb8a8838ad7600d5d134 Mon Sep 17 00:00:00 2001 From: Janez Podhostnik Date: Wed, 21 Aug 2024 17:23:12 +0200 Subject: [PATCH] cleanup unnecesary changes --- protobuf/flow/access/access.proto | 210 ++++++------- .../flow/entities/block_execution_data.proto | 53 ++-- protobuf/flow/entities/block_header.proto | 3 +- protobuf/flow/entities/collection.proto | 3 +- protobuf/flow/entities/event.proto | 4 +- protobuf/flow/entities/execution_result.proto | 3 +- .../flow/executiondata/executiondata.proto | 212 +++++++------ protobuf/go/flow/access/access.pb.go | 36 +-- protobuf/go/flow/access/access_grpc.pb.go | 254 +++++++--------- .../flow/entities/block_execution_data.pb.go | 53 ++-- .../go/flow/entities/node_version_info.pb.go | 120 ++++++-- .../go/flow/executiondata/executiondata.pb.go | 45 ++- .../executiondata/executiondata_grpc.pb.go | 280 ++++++++---------- 13 files changed, 601 insertions(+), 675 deletions(-) diff --git a/protobuf/flow/access/access.proto b/protobuf/flow/access/access.proto index 90ced2081..ffebfe1ed 100644 --- a/protobuf/flow/access/access.proto +++ b/protobuf/flow/access/access.proto @@ -23,8 +23,7 @@ service AccessAPI { // GetNodeVersionInfo return node version information, such as semver, // commit, sporkID and protocol version. - rpc GetNodeVersionInfo(GetNodeVersionInfoRequest) - returns (GetNodeVersionInfoResponse); + rpc GetNodeVersionInfo(GetNodeVersionInfoRequest) returns (GetNodeVersionInfoResponse); // Block Headers @@ -53,8 +52,7 @@ service AccessAPI { // GetCollectionByID gets a collection by ID. rpc GetCollectionByID(GetCollectionByIDRequest) returns (CollectionResponse); // GetFullCollectionByID gets a collection by ID. - rpc GetFullCollectionByID(GetFullCollectionByIDRequest) - returns (FullCollectionResponse); + rpc GetFullCollectionByID(GetFullCollectionByIDRequest) returns (FullCollectionResponse); // Transactions @@ -77,12 +75,11 @@ service AccessAPI { rpc GetTransactionsByBlockID(GetTransactionsByBlockIDRequest) returns (TransactionsResponse); // GetSystemTransaction gets a system transaction - rpc GetSystemTransaction(GetSystemTransactionRequest) - returns (TransactionResponse); + rpc GetSystemTransaction(GetSystemTransactionRequest) returns (TransactionResponse); // GetSystemTransactionResult gets a system transaction result for a // specified block - rpc GetSystemTransactionResult(GetSystemTransactionResultRequest) - returns (TransactionResultResponse); + rpc GetSystemTransactionResult(GetSystemTransactionResultRequest) returns (TransactionResultResponse); + // Accounts @@ -168,16 +165,15 @@ service AccessAPI { rpc GetLatestProtocolStateSnapshot(GetLatestProtocolStateSnapshotRequest) returns (ProtocolStateSnapshotResponse); - // GetProtocolStateSnapshotByBlockID retrieves the latest sealed protocol - // state snapshot by block ID. Used by Flow nodes joining the network to - // bootstrap a space-efficient local state. - rpc GetProtocolStateSnapshotByBlockID( - GetProtocolStateSnapshotByBlockIDRequest) + // GetProtocolStateSnapshotByBlockID retrieves the latest sealed protocol state + // snapshot by block ID. Used by Flow nodes joining the network to bootstrap a + // space-efficient local state. + rpc GetProtocolStateSnapshotByBlockID(GetProtocolStateSnapshotByBlockIDRequest) returns (ProtocolStateSnapshotResponse); // GetProtocolStateSnapshotByHeight retrieves the latest sealed protocol state - // snapshot by block height. Used by Flow nodes joining the network to - // bootstrap a space-efficient local state. + // snapshot by block height. Used by Flow nodes joining the network to bootstrap a + // space-efficient local state. rpc GetProtocolStateSnapshotByHeight(GetProtocolStateSnapshotByHeightRequest) returns (ProtocolStateSnapshotResponse); @@ -195,122 +191,100 @@ service AccessAPI { // Subscribe blocks - // SubscribeBlocksFromStartBlockID streams finalized or sealed blocks starting - // at the requested start block id, up until the latest available block. Once - // the latest is reached, the stream will remain open and responses are sent - // for each new block as it becomes available. + // SubscribeBlocksFromStartBlockID streams finalized or sealed blocks starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. rpc SubscribeBlocksFromStartBlockID(SubscribeBlocksFromStartBlockIDRequest) returns (stream SubscribeBlocksResponse); - // SubscribeBlocksFromStartHeight streams finalized or sealed blocks starting - // at the requested start block height, up until the latest available block. - // Once the latest is reached, the stream will remain open and responses are - // sent for each new block as it becomes available. + // SubscribeBlocksFromStartHeight streams finalized or sealed blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. rpc SubscribeBlocksFromStartHeight(SubscribeBlocksFromStartHeightRequest) returns (stream SubscribeBlocksResponse); - // SubscribeBlocksFromLatest streams finalized or sealed blocks starting from - // the latest finalized or sealed block. The stream will remain open and - // responses are sent for each new block as it becomes available. + // SubscribeBlocksFromLatest streams finalized or sealed blocks starting from the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. rpc SubscribeBlocksFromLatest(SubscribeBlocksFromLatestRequest) returns (stream SubscribeBlocksResponse); // Subscribe block headers - // SubscribeBlockHeadersFromStartBlockID streams finalized or sealed block - // headers starting at the requested start block id, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block header as it becomes available. + // SubscribeBlockHeadersFromStartBlockID streams finalized or sealed block headers starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. - rpc SubscribeBlockHeadersFromStartBlockID( - SubscribeBlockHeadersFromStartBlockIDRequest) + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. + rpc SubscribeBlockHeadersFromStartBlockID(SubscribeBlockHeadersFromStartBlockIDRequest) returns (stream SubscribeBlockHeadersResponse); - // SubscribeBlockHeadersFromStartHeight streams finalized or sealed block - // headers starting at the requested start block height, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block header as it becomes available. + // SubscribeBlockHeadersFromStartHeight streams finalized or sealed block headers starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. - rpc SubscribeBlockHeadersFromStartHeight( - SubscribeBlockHeadersFromStartHeightRequest) + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. + rpc SubscribeBlockHeadersFromStartHeight(SubscribeBlockHeadersFromStartHeightRequest) returns (stream SubscribeBlockHeadersResponse); - // SubscribeBlockHeadersFromLatest streams finalized or sealed block headers - // starting from the latest finalized or sealed block. The stream will remain - // open and responses are sent for each new block header as it becomes - // available. + // SubscribeBlockHeadersFromLatest streams finalized or sealed block headers starting from the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. rpc SubscribeBlockHeadersFromLatest(SubscribeBlockHeadersFromLatestRequest) returns (stream SubscribeBlockHeadersResponse); // Subscribe block digests - // SubscribeBlockDigestsFromStartBlockID streams finalized or sealed - // lightweight block starting at the requested start block id, up until the - // latest available block. Once the latest is reached, the stream will remain - // open and responses are sent for each new lightweight block as it becomes - // available. + // SubscribeBlockDigestsFromStartBlockID streams finalized or sealed lightweight block starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. - rpc SubscribeBlockDigestsFromStartBlockID( - SubscribeBlockDigestsFromStartBlockIDRequest) + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. + rpc SubscribeBlockDigestsFromStartBlockID(SubscribeBlockDigestsFromStartBlockIDRequest) returns (stream SubscribeBlockDigestsResponse); - // SubscribeBlockDigestsFromStartHeight streams finalized or sealed - // lightweight block starting at the requested start block height, up until - // the latest available block. Once the latest is reached, the stream will - // remain open and responses are sent for each new lightweight block as it - // becomes available. + // SubscribeBlockDigestsFromStartHeight streams finalized or sealed lightweight block starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. - rpc SubscribeBlockDigestsFromStartHeight( - SubscribeBlockDigestsFromStartHeightRequest) + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. + rpc SubscribeBlockDigestsFromStartHeight(SubscribeBlockDigestsFromStartHeightRequest) returns (stream SubscribeBlockDigestsResponse); - // SubscribeBlockDigestsFromLatest streams finalized or sealed lightweight - // block headers starting of the latest finalized or sealed block. The stream - // will remain open and responses are sent for each new lightweight block as - // it becomes available. + // SubscribeBlockDigestsFromLatest streams finalized or sealed lightweight block headers starting of the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. rpc SubscribeBlockDigestsFromLatest(SubscribeBlockDigestsFromLatestRequest) returns (stream SubscribeBlockDigestsResponse); // Subscribe transaction statuses - // SendAndSubscribeTransactionStatuses send a transaction and immediately - // subscribe to its status changes. The status is streamed back until the - // block containing the transaction becomes sealed. - rpc SendAndSubscribeTransactionStatuses( - SendAndSubscribeTransactionStatusesRequest) - returns (stream SendAndSubscribeTransactionStatusesResponse); + // SendAndSubscribeTransactionStatuses send a transaction and immediately subscribe to its status changes. The status + // is streamed back until the block containing the transaction becomes sealed. + rpc SendAndSubscribeTransactionStatuses(SendAndSubscribeTransactionStatusesRequest) + returns (stream SendAndSubscribeTransactionStatusesResponse); } message PingRequest {} @@ -636,8 +610,7 @@ message SubscribeBlocksFromStartBlockIDRequest { // 2. BLOCK_SEALED entities.BlockStatus block_status = 2; - // Boolean value determining the response: 'full' if `true`, 'light' - // otherwise. + // Boolean value determining the response: 'full' if `true`, 'light' otherwise. bool full_block_response = 3; } @@ -652,8 +625,7 @@ message SubscribeBlocksFromStartHeightRequest { // 2. BLOCK_SEALED entities.BlockStatus block_status = 2; - // Boolean value determining the response: 'full' if `true`, 'light' - // otherwise. + // Boolean value determining the response: 'full' if `true`, 'light' otherwise. bool full_block_response = 3; } @@ -665,13 +637,11 @@ message SubscribeBlocksFromLatestRequest { // 2. BLOCK_SEALED entities.BlockStatus block_status = 1; - // Boolean value determining the response: 'full' if `true`, 'light' - // otherwise. + // Boolean value determining the response: 'full' if `true`, 'light' otherwise. bool full_block_response = 2; } -// The response for SubscribeBlocksFromStartBlockID, -// SubscribeBlocksFromStartHeight, SubscribeBlocksFromLatest +// The response for SubscribeBlocksFromStartBlockID, SubscribeBlocksFromStartHeight, SubscribeBlocksFromLatest message SubscribeBlocksResponse { // The sealed or finalized blocks according to the block status // in the request. @@ -713,8 +683,7 @@ message SubscribeBlockHeadersFromLatestRequest { entities.BlockStatus block_status = 1; } -// The response for SubscribeBlockHeadersFromStartBlockID, -// SubscribeBlockHeadersFromStartHeight, SubscribeBlockHeadersFromLatest +// The response for SubscribeBlockHeadersFromStartBlockID, SubscribeBlockHeadersFromStartHeight, SubscribeBlockHeadersFromLatest message SubscribeBlockHeadersResponse { // The sealed or finalized block headers according to the block status // in the request. @@ -756,34 +725,31 @@ message SubscribeBlockDigestsFromLatestRequest { entities.BlockStatus block_status = 1; } -// The response for SubscribeBlockDigestsFromStartBlockID, -// SubscribeBlockDigestsFromStartHeight, SubscribeBlockDigestsFromLatest +// The response for SubscribeBlockDigestsFromStartBlockID, SubscribeBlockDigestsFromStartHeight, SubscribeBlockDigestsFromLatest message SubscribeBlockDigestsResponse { - // The block ID of the new sealed or finalized block according to the block - // status in the request. + // The block ID of the new sealed or finalized block according to the block status + // in the request. bytes block_id = 1; - // The block height of the new sealed or finalized block according to the - // block status in the request. + // The block height of the new sealed or finalized block according to the block status + // in the request. uint64 block_height = 2; - // The timestamp of the new sealed or finalized block according to the block - // status in the request. + // The timestamp of the new sealed or finalized block according to the block status + // in the request. google.protobuf.Timestamp block_timestamp = 3; } -// Request message for sending a transaction and subscribing to its status -// changes. +// Request message for sending a transaction and subscribing to its status changes. message SendAndSubscribeTransactionStatusesRequest { - // The transaction to be sent and tracked for status changes. - entities.Transaction transaction = 1; - // The encoding for events in transaction result - entities.EventEncodingVersion event_encoding_version = 2; + // The transaction to be sent and tracked for status changes. + entities.Transaction transaction = 1; + // The encoding for events in transaction result + entities.EventEncodingVersion event_encoding_version = 2; } // Response message for transaction status changes. message SendAndSubscribeTransactionStatusesResponse { - // Transaction result of the tracked transaction - TransactionResultResponse transaction_results = 1; - // The message index of the response message. Used by the client to ensure - // they received all messages. Starts from "0". - uint64 message_index = 2; + // Transaction result of the tracked transaction + TransactionResultResponse transaction_results = 1; + // The message index of the response message. Used by the client to ensure they received all messages. Starts from "0". + uint64 message_index = 2; } diff --git a/protobuf/flow/entities/block_execution_data.proto b/protobuf/flow/entities/block_execution_data.proto index 8b1e2ac41..aa39097f3 100644 --- a/protobuf/flow/entities/block_execution_data.proto +++ b/protobuf/flow/entities/block_execution_data.proto @@ -8,51 +8,44 @@ option java_package = "org.onflow.protobuf.entities"; import "flow/entities/event.proto"; import "flow/entities/transaction.proto"; -// BlockExecutionData represents the collection of data produced while execiting -// the block. +// BlockExecutionData represents the collection of data produced while execiting the block. message BlockExecutionData { // Block ID of the block that was executed. bytes block_id = 1; // Ordered list of ChunkExecutionData produced while executing the block. // - // Note: there will be one ChunkExecutionData per collection in the block, - // plus one for the service chunk. The service chunk is executed last and is - // always the last chunk in the list. + // Note: there will be one ChunkExecutionData per collection in the block, plus one for the + // service chunk. The service chunk is executed last and is always the last chunk in the list. repeated ChunkExecutionData chunk_execution_data = 2; } -// ChunkExecutionData represents the collection of data produced while executing -// a chunk. +// ChunkExecutionData represents the collection of data produced while executing a chunk. message ChunkExecutionData { - // Ordered list of transactions included in the collection that was executed - // in the chunk. + // Ordered list of transactions included in the collection that was executed in the chunk. ExecutionDataCollection collection = 1; // Events emitted by transactions in the collection. // - // Note: events listed in the last ChunkExecutionData in the - // BlockExecutionData were emitted by the service transaction. Some, but not - // all, of these events are service events. + // Note: events listed in the last ChunkExecutionData in the BlockExecutionData were emitted by + // the service transaction. Some, but not all, of these events are service events. repeated Event events = 2; // TrieUpdate produced by executing the collection. // - // TrieUpdates contain a list of registers that were modified during chunk - // execution. The value included is the new value of the register. + // TrieUpdates contain a list of registers that were modified during chunk execution. The value + // included is the new value of the register. TrieUpdate trieUpdate = 3; // Transaction results produced by executing the collection. // - // Note: these are not the same type of results returned by other RPCs. These - // results are sepcific to execution data. The most notable difference is they - // only include a boolean value to indicate whether or not an error was - // encountered during execution, not the error itself. + // Note: these are not the same type of results returned by other RPCs. These results are sepcific + // to execution data. The most notable difference is they only include a boolean value to indicate + // whether or not an error was encountered during execution, not the error itself. repeated ExecutionDataTransactionResult transaction_results = 4; } -// ExecutionDataCollection represents the collection of transactions that were -// executed within a chunk. +// ExecutionDataCollection represents the collection of transactions that were executed within a chunk. // // Note: this is not the same type as the entities.Collection. message ExecutionDataCollection { @@ -62,24 +55,22 @@ message ExecutionDataCollection { // TrieUpdate produced by executing the collection. // -// TrieUpdates contain a list of registers that were modified during chunk -// execution. The value included is the new value of the register. +// TrieUpdates contain a list of registers that were modified during chunk execution. The value +// included is the new value of the register. message TrieUpdate { // RootHash is the root hash of the trie before the update is applied. bytes root_hash = 1; // List of register paths updated. // - // Note: paths and payloads map 1:1 with eachother. i.e. for each element in - // path, the value in payloads at the same index is the value of the register - // at that path. + // Note: paths and payloads map 1:1 with eachother. i.e. for each element in path, the value in + // payloads at the same index is the value of the register at that path. repeated bytes paths = 2; // List of register values updated. // - // Note: paths and payloads map 1:1 with eachother. i.e. for each element in - // path, the value in payloads at the same index is the value of the register - // at that path. + // Note: paths and payloads map 1:1 with eachother. i.e. for each element in path, the value in + // payloads at the same index is the value of the register at that path. repeated Payload payloads = 3; } @@ -102,14 +93,12 @@ message KeyPart { bytes value = 2; } -// ExecutionDataTransactionResult represents the result of executing a -// transaction. +// ExecutionDataTransactionResult represents the result of executing a transaction. message ExecutionDataTransactionResult { // Transaction ID of the transaction that was executed. bytes transaction_id = 1; - // Boolean indicating whether or not the transaction's execution failed with - // an error. + // Boolean indicating whether or not the transaction's execution failed with an error. bool failed = 2; // Amount of computation used during execution. diff --git a/protobuf/flow/entities/block_header.proto b/protobuf/flow/entities/block_header.proto index cc80cacee..107e2f728 100644 --- a/protobuf/flow/entities/block_header.proto +++ b/protobuf/flow/entities/block_header.proto @@ -14,8 +14,7 @@ message BlockHeader { google.protobuf.Timestamp timestamp = 4; bytes payload_hash = 5; uint64 view = 6; - repeated bytes parent_voter_ids = - 7; // deprecated!! value will be empty. replaced by parent_vote_indices + repeated bytes parent_voter_ids = 7; // deprecated!! value will be empty. replaced by parent_vote_indices bytes parent_voter_sig_data = 8; bytes proposer_id = 9; bytes proposer_sig_data = 10; diff --git a/protobuf/flow/entities/collection.proto b/protobuf/flow/entities/collection.proto index dd8f3eb0a..bdbe29e45 100644 --- a/protobuf/flow/entities/collection.proto +++ b/protobuf/flow/entities/collection.proto @@ -15,7 +15,6 @@ message CollectionGuarantee { repeated bytes signatures = 2; bytes reference_block_id = 3; bytes signature = 4; - repeated bytes signer_ids = - 5; // deprecated!! value will be empty. replaced by signer_indices + repeated bytes signer_ids = 5; // deprecated!! value will be empty. replaced by signer_indices bytes signer_indices = 6; } diff --git a/protobuf/flow/entities/event.proto b/protobuf/flow/entities/event.proto index c85e3848e..25de2f3d7 100644 --- a/protobuf/flow/entities/event.proto +++ b/protobuf/flow/entities/event.proto @@ -6,8 +6,8 @@ option go_package = "github.com/onflow/flow/protobuf/go/flow/entities"; option java_package = "org.onflow.protobuf.entities"; enum EventEncodingVersion { - JSON_CDC_V0 = 0; - CCF_V0 = 1; + JSON_CDC_V0 = 0; + CCF_V0 = 1; } message Event { diff --git a/protobuf/flow/entities/execution_result.proto b/protobuf/flow/entities/execution_result.proto index da4a70e88..7da675f59 100644 --- a/protobuf/flow/entities/execution_result.proto +++ b/protobuf/flow/entities/execution_result.proto @@ -25,8 +25,7 @@ message Chunk { uint64 index = 7; // chunk index inside the ER (starts from zero) bytes end_state = 8; // EndState inferred from next chunk or from the ER bytes execution_data_id = 9; - bytes state_delta_commitment = - 10; // a commitment over sorted list of register changes + bytes state_delta_commitment = 10; // a commitment over sorted list of register changes } message ServiceEvent { diff --git a/protobuf/flow/executiondata/executiondata.proto b/protobuf/flow/executiondata/executiondata.proto index 1b310a3d9..67b2fef79 100644 --- a/protobuf/flow/executiondata/executiondata.proto +++ b/protobuf/flow/executiondata/executiondata.proto @@ -23,10 +23,9 @@ service ExecutionDataAPI { rpc GetExecutionDataByBlockID(GetExecutionDataByBlockIDRequest) returns (GetExecutionDataByBlockIDResponse); - // Warning: this endpoint is deprecated and will be removed in future - // versions. Use SubscribeExecutionDataFromStartBlockID, - // SubscribeExecutionDataFromStartBlockHeight or - // SubscribeExecutionDataFromLatest. + // Warning: this endpoint is deprecated and will be removed in future versions. + // Use SubscribeExecutionDataFromStartBlockID, SubscribeExecutionDataFromStartBlockHeight + // or SubscribeExecutionDataFromLatest. // // SubscribeExecutionData streams execution data for all blocks starting at // the requested start block, up until the latest available block. Once the @@ -37,17 +36,17 @@ service ExecutionDataAPI { // - InvalidArgument is returned if the request contains an invalid start // block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet not been received. + // node. This may happen if the block was from a previous spork, or if the block + // has yet not been received. rpc SubscribeExecutionData(SubscribeExecutionDataRequest) returns (stream SubscribeExecutionDataResponse) { - option deprecated = true; + option deprecated = true; }; - // SubscribeExecutionDataFromStartBlockID streams execution data for all - // blocks starting at the requested start block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new execution data as it becomes available. + // SubscribeExecutionDataFromStartBlockID streams execution data for all blocks + // starting at the requested start block, up until the latest available block. + // Once the latest is reached, the stream will remain open and responses are + // sent for each new execution data as it becomes available. // // Errors: // - InvalidArgument is returned if the request contains an invalid start @@ -59,10 +58,10 @@ service ExecutionDataAPI { SubscribeExecutionDataFromStartBlockIDRequest) returns (stream SubscribeExecutionDataResponse); - // SubscribeExecutionDataFromStartBlockHeight streams execution data for all - // blocks starting at the requested start block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new execution data as it becomes available. + // SubscribeExecutionDataFromStartBlockHeight streams execution data for all blocks + // starting at the requested start block, up until the latest available block. + // Once the latest is reached, the stream will remain open and responses are + // sent for each new execution data as it becomes available. // // Errors: // - InvalidArgument is returned if the request contains an invalid start @@ -74,8 +73,8 @@ service ExecutionDataAPI { SubscribeExecutionDataFromStartBlockHeightRequest) returns (stream SubscribeExecutionDataResponse); - // SubscribeExecutionDataFromStartBlockHeight streams execution data for all - // blocks starting from the latest block. + // SubscribeExecutionDataFromStartBlockHeight streams execution data for all blocks + // starting from the latest block. // // Errors: // - NotFound is returned if the start block is not currently available on the @@ -84,9 +83,8 @@ service ExecutionDataAPI { rpc SubscribeExecutionDataFromLatest(SubscribeExecutionDataFromLatestRequest) returns (stream SubscribeExecutionDataResponse); - // Warning: this endpoint is deprecated and will be removed in future - // versions. Use SubscribeEventsFromStartBlockID, - // SubscribeEventsFromStartHeight or SubscribeEventsFromLatest. + // Warning: this endpoint is deprecated and will be removed in future versions. + // Use SubscribeEventsFromStartBlockID, SubscribeEventsFromStartHeight or SubscribeEventsFromLatest. // // SubscribeEvents streams events for all blocks starting at the requested // start block, up until the latest available block. Once the latest is @@ -112,13 +110,13 @@ service ExecutionDataAPI { // not been received. rpc SubscribeEvents(SubscribeEventsRequest) returns (stream SubscribeEventsResponse) { - option deprecated = true; + option deprecated = true; }; - // SubscribeEventsFromStartBlockID streams events for all blocks starting at - // the requested start block id, up until the latest available block. Once the - // latest is reached, the stream will remain open and responses are sent for - // each new block as it becomes available. + // SubscribeEventsFromStartBlockID streams events for all blocks starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -131,18 +129,17 @@ service ExecutionDataAPI { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid block ID - // or EventFilter. + // - InvalidArgument is returned if the request contains an invalid block ID or EventFilter. // - NotFound is returned if the start block id or execution data are not - // currently available on the node. This may happen if the block was from a - // previous spork, or if the block has yet not been received. + // currently available on the node. This may happen if the block was from a previous spork, or if the + // block has yet not been received. rpc SubscribeEventsFromStartBlockID(SubscribeEventsFromStartBlockIDRequest) returns (stream SubscribeEventsResponse); - // SubscribeEventsFromStartHeight streams events for all blocks starting at - // the requested start block height, up until the latest available block. Once - // the latest is reached, the stream will remain open and responses are sent - // for each new block as it becomes available. + // SubscribeEventsFromStartHeight streams events for all blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -155,17 +152,15 @@ service ExecutionDataAPI { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid - // EventFilter. + // - InvalidArgument is returned if the request contains an invalid EventFilter. // - NotFound is returned if the start block height or execution data are not - // currently available on the node. This may happen if the block was from a - // previous spork, or if the block has yet not been received. + // currently available on the node. This may happen if the block was from a previous spork, or if the + // block has yet not been received. rpc SubscribeEventsFromStartHeight(SubscribeEventsFromStartHeightRequest) returns (stream SubscribeEventsResponse); - // SubscribeEventsFromLatest streams events for all blocks starting from the - // latest sealed block. The stream will remain open and responses are sent for - // each new block as it becomes available. + // SubscribeEventsFromLatest streams events for all blocks starting from the latest sealed + // block. The stream will remain open and responses are sent for each new block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -178,92 +173,84 @@ service ExecutionDataAPI { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid - // EventFilter. + // - InvalidArgument is returned if the request contains an invalid EventFilter. rpc SubscribeEventsFromLatest(SubscribeEventsFromLatestRequest) returns (stream SubscribeEventsResponse); - // GetRegisterValues gets the values for the given register IDs as of the - // given block height + // GetRegisterValues gets the values for the given register IDs as of the given block height rpc GetRegisterValues(GetRegisterValuesRequest) returns (GetRegisterValuesResponse); - // SubscribeAccountStatusesFromStartBlockID streams account statuses for all - // blocks starting at the requested start block ID, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromStartBlockID streams account statuses for all blocks starting at the requested + // start block ID, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // not been received. - rpc SubscribeAccountStatusesFromStartBlockID( - SubscribeAccountStatusesFromStartBlockIDRequest) + rpc SubscribeAccountStatusesFromStartBlockID(SubscribeAccountStatusesFromStartBlockIDRequest) returns (stream SubscribeAccountStatusesResponse); - // SubscribeAccountStatusesFromStartHeight streams account statuses for all - // blocks starting at the requested start block height, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromStartHeight streams account statuses for all blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // not been received. - rpc SubscribeAccountStatusesFromStartHeight( - SubscribeAccountStatusesFromStartHeightRequest) + rpc SubscribeAccountStatusesFromStartHeight(SubscribeAccountStatusesFromStartHeightRequest) returns (stream SubscribeAccountStatusesResponse); - // SubscribeAccountStatusesFromLatestBlock streams account statuses for all - // blocks starting at the last sealed block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromLatestBlock streams account statuses for all blocks starting + // at the last sealed block, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // not been received. - rpc SubscribeAccountStatusesFromLatestBlock( - SubscribeAccountStatusesFromLatestBlockRequest) + rpc SubscribeAccountStatusesFromLatestBlock(SubscribeAccountStatusesFromLatestBlockRequest) returns (stream SubscribeAccountStatusesResponse); } @@ -384,6 +371,7 @@ message SubscribeEventsRequest { // 1. CCF // 2. JSON-CDC entities.EventEncodingVersion event_encoding_version = 5; + } // The request for SubscribeEventsFromStartBlockID @@ -478,8 +466,7 @@ message SubscribeEventsResponse { // Timestamp from the block containing the events. google.protobuf.Timestamp block_timestamp = 4; - // The message index of the response message. Used by the client to ensure - // they received all messages. Starts from "1". + // The message index of the response message. Used by the client to ensure they received all messages. Starts from "1". uint64 message_index = 5; } @@ -527,6 +514,7 @@ message EventFilter { // request for GetRegisterValues message GetRegisterValuesRequest { + // Block height of the execution state being queried. uint64 block_height = 1; @@ -536,6 +524,7 @@ message GetRegisterValuesRequest { // response for GetRegisterValues message GetRegisterValuesResponse { + // raw register values at the given height. repeated bytes values = 1; } @@ -553,10 +542,10 @@ message SubscribeAccountStatusesFromStartBlockIDRequest { StatusFilter filter = 2; // Interval in block heights at which the server should return a heartbeat - // message to the client. The heartbeat is a normal - // SubscribeAccountStatusesResponse with no events, and allows clients to - // track which blocks were searched. Clients can use this information to - // determine which block to start from when reconnecting. + // message to the client. The heartbeat is a normal SubscribeAccountStatusesResponse + // with no events, and allows clients to track which blocks were searched. + // Clients can use this information to determine which block to start from + // when reconnecting. // // The interval is calculated from the last response returned, which could be // either another heartbeat or a response containing events. @@ -582,10 +571,10 @@ message SubscribeAccountStatusesFromStartHeightRequest { StatusFilter filter = 2; // Interval in block heights at which the server should return a heartbeat - // message to the client. The heartbeat is a normal - // SubscribeAccountStatusesResponse with no events, and allows clients to - // track which blocks were searched. Clients can use this information to - // determine which block to start from when reconnecting. + // message to the client. The heartbeat is a normal SubscribeAccountStatusesResponse + // with no events, and allows clients to track which blocks were searched. + // Clients can use this information to determine which block to start from + // when reconnecting. // // The interval is calculated from the last response returned, which could be // either another heartbeat or a response containing events. @@ -605,10 +594,10 @@ message SubscribeAccountStatusesFromLatestBlockRequest { StatusFilter filter = 1; // Interval in block heights at which the server should return a heartbeat - // message to the client. The heartbeat is a normal - // SubscribeAccountStatusesResponse with no events, and allows clients to - // track which blocks were searched. Clients can use this information to - // determine which block to start from when reconnecting. + // message to the client. The heartbeat is a normal SubscribeAccountStatusesResponse + // with no events, and allows clients to track which blocks were searched. + // Clients can use this information to determine which block to start from + // when reconnecting. // // The interval is calculated from the last response returned, which could be // either another heartbeat or a response containing events. @@ -629,15 +618,14 @@ message SubscribeAccountStatusesResponse { // Block height of the block containing the events. uint64 block_height = 2; - // The message index of the response message. Used by the client to ensure - // they received all messages. Starts from "1". + // The message index of the response message. Used by the client to ensure they received all messages. Starts from "1". uint64 message_index = 3; message Result { - // Unique identifier for the account being streamed - bytes address = 1; - // Events matching the StatusFilter in the request. - repeated entities.Event events = 2; + // Unique identifier for the account being streamed + bytes address = 1; + // Events matching the StatusFilter in the request. + repeated entities.Event events = 2; } // The API may return no results which signals a periodic heartbeat. This // allows clients to track which blocks were searched. Client can use this @@ -647,11 +635,11 @@ message SubscribeAccountStatusesResponse { // StatusesFilter defines the filter to apply to block events. // Filters match for events with types in the included event_type list, that are -// related to at least one address from the provided address list. An event -// who's type matches but address does not is ignored, and vice versa. If no -// event_types are provided, all account related protocol event types are -// matched. If no addresses are provided, any address matches. If there are any -// invalid filters, the API will return an InvalidArgument error. +// related to at least one address from the provided address list. An event who's +// type matches but address does not is ignored, and vice versa. +// If no event_types are provided, all account related protocol event types are matched. +// If no addresses are provided, any address matches. +// If there are any invalid filters, the API will return an InvalidArgument error. message StatusFilter { // A list of full event types to include. // @@ -663,12 +651,12 @@ message StatusFilter { repeated string event_type = 1; // A list of addresses who's events should be included. // - // All events matching the provided event_types that are related to any of the - // provided addresses will be returned. If no addresses are provided, all - // events matching event_types will be returned. + // All events matching the provided event_types that are related to any of the provided addresses + // will be returned. If no addresses are provided, all events matching event_types will be returned. // // Addresses must be Flow account addresses in hex format and valid for the // network the node is connected to. i.e. only a mainnet address is valid for // a mainnet node. Addresses may optionally include the 0x prefix. repeated string address = 3; -} \ No newline at end of file +} + diff --git a/protobuf/go/flow/access/access.pb.go b/protobuf/go/flow/access/access.pb.go index 92d37a17f..8adbe4684 100644 --- a/protobuf/go/flow/access/access.pb.go +++ b/protobuf/go/flow/access/access.pb.go @@ -2772,8 +2772,7 @@ type SubscribeBlocksFromStartBlockIDRequest struct { // 1. BLOCK_FINALIZED // 2. BLOCK_SEALED BlockStatus entities.BlockStatus `protobuf:"varint,2,opt,name=block_status,json=blockStatus,proto3,enum=flow.entities.BlockStatus" json:"block_status,omitempty"` - // Boolean value determining the response: 'full' if `true`, 'light' - // otherwise. + // Boolean value determining the response: 'full' if `true`, 'light' otherwise. FullBlockResponse bool `protobuf:"varint,3,opt,name=full_block_response,json=fullBlockResponse,proto3" json:"full_block_response,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -2837,8 +2836,7 @@ type SubscribeBlocksFromStartHeightRequest struct { // 1. BLOCK_FINALIZED // 2. BLOCK_SEALED BlockStatus entities.BlockStatus `protobuf:"varint,2,opt,name=block_status,json=blockStatus,proto3,enum=flow.entities.BlockStatus" json:"block_status,omitempty"` - // Boolean value determining the response: 'full' if `true`, 'light' - // otherwise. + // Boolean value determining the response: 'full' if `true`, 'light' otherwise. FullBlockResponse bool `protobuf:"varint,3,opt,name=full_block_response,json=fullBlockResponse,proto3" json:"full_block_response,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -2898,8 +2896,7 @@ type SubscribeBlocksFromLatestRequest struct { // 1. BLOCK_FINALIZED // 2. BLOCK_SEALED BlockStatus entities.BlockStatus `protobuf:"varint,1,opt,name=block_status,json=blockStatus,proto3,enum=flow.entities.BlockStatus" json:"block_status,omitempty"` - // Boolean value determining the response: 'full' if `true`, 'light' - // otherwise. + // Boolean value determining the response: 'full' if `true`, 'light' otherwise. FullBlockResponse bool `protobuf:"varint,2,opt,name=full_block_response,json=fullBlockResponse,proto3" json:"full_block_response,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -2945,8 +2942,7 @@ func (m *SubscribeBlocksFromLatestRequest) GetFullBlockResponse() bool { return false } -// The response for SubscribeBlocksFromStartBlockID, -// SubscribeBlocksFromStartHeight, SubscribeBlocksFromLatest +// The response for SubscribeBlocksFromStartBlockID, SubscribeBlocksFromStartHeight, SubscribeBlocksFromLatest type SubscribeBlocksResponse struct { // The sealed or finalized blocks according to the block status // in the request. @@ -3148,8 +3144,7 @@ func (m *SubscribeBlockHeadersFromLatestRequest) GetBlockStatus() entities.Block return entities.BlockStatus_BLOCK_UNKNOWN } -// The response for SubscribeBlockHeadersFromStartBlockID, -// SubscribeBlockHeadersFromStartHeight, SubscribeBlockHeadersFromLatest +// The response for SubscribeBlockHeadersFromStartBlockID, SubscribeBlockHeadersFromStartHeight, SubscribeBlockHeadersFromLatest type SubscribeBlockHeadersResponse struct { // The sealed or finalized block headers according to the block status // in the request. @@ -3351,17 +3346,16 @@ func (m *SubscribeBlockDigestsFromLatestRequest) GetBlockStatus() entities.Block return entities.BlockStatus_BLOCK_UNKNOWN } -// The response for SubscribeBlockDigestsFromStartBlockID, -// SubscribeBlockDigestsFromStartHeight, SubscribeBlockDigestsFromLatest +// The response for SubscribeBlockDigestsFromStartBlockID, SubscribeBlockDigestsFromStartHeight, SubscribeBlockDigestsFromLatest type SubscribeBlockDigestsResponse struct { - // The block ID of the new sealed or finalized block according to the block - // status in the request. + // The block ID of the new sealed or finalized block according to the block status + // in the request. BlockId []byte `protobuf:"bytes,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` - // The block height of the new sealed or finalized block according to the - // block status in the request. + // The block height of the new sealed or finalized block according to the block status + // in the request. BlockHeight uint64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` - // The timestamp of the new sealed or finalized block according to the block - // status in the request. + // The timestamp of the new sealed or finalized block according to the block status + // in the request. BlockTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -3414,8 +3408,7 @@ func (m *SubscribeBlockDigestsResponse) GetBlockTimestamp() *timestamppb.Timesta return nil } -// Request message for sending a transaction and subscribing to its status -// changes. +// Request message for sending a transaction and subscribing to its status changes. type SendAndSubscribeTransactionStatusesRequest struct { // The transaction to be sent and tracked for status changes. Transaction *entities.Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` @@ -3473,8 +3466,7 @@ func (m *SendAndSubscribeTransactionStatusesRequest) GetEventEncodingVersion() e type SendAndSubscribeTransactionStatusesResponse struct { // Transaction result of the tracked transaction TransactionResults *TransactionResultResponse `protobuf:"bytes,1,opt,name=transaction_results,json=transactionResults,proto3" json:"transaction_results,omitempty"` - // The message index of the response message. Used by the client to ensure - // they received all messages. Starts from "0". + // The message index of the response message. Used by the client to ensure they received all messages. Starts from "0". MessageIndex uint64 `protobuf:"varint,2,opt,name=message_index,json=messageIndex,proto3" json:"message_index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` diff --git a/protobuf/go/flow/access/access_grpc.pb.go b/protobuf/go/flow/access/access_grpc.pb.go index 170cd69ff..cb7062095 100644 --- a/protobuf/go/flow/access/access_grpc.pb.go +++ b/protobuf/go/flow/access/access_grpc.pb.go @@ -164,13 +164,13 @@ type AccessAPIClient interface { // snapshot. Used by Flow nodes joining the network to bootstrap a // space-efficient local state. GetLatestProtocolStateSnapshot(ctx context.Context, in *GetLatestProtocolStateSnapshotRequest, opts ...grpc.CallOption) (*ProtocolStateSnapshotResponse, error) - // GetProtocolStateSnapshotByBlockID retrieves the latest sealed protocol - // state snapshot by block ID. Used by Flow nodes joining the network to - // bootstrap a space-efficient local state. + // GetProtocolStateSnapshotByBlockID retrieves the latest sealed protocol state + // snapshot by block ID. Used by Flow nodes joining the network to bootstrap a + // space-efficient local state. GetProtocolStateSnapshotByBlockID(ctx context.Context, in *GetProtocolStateSnapshotByBlockIDRequest, opts ...grpc.CallOption) (*ProtocolStateSnapshotResponse, error) // GetProtocolStateSnapshotByHeight retrieves the latest sealed protocol state - // snapshot by block height. Used by Flow nodes joining the network to - // bootstrap a space-efficient local state. + // snapshot by block height. Used by Flow nodes joining the network to bootstrap a + // space-efficient local state. GetProtocolStateSnapshotByHeight(ctx context.Context, in *GetProtocolStateSnapshotByHeightRequest, opts ...grpc.CallOption) (*ProtocolStateSnapshotResponse, error) // GetExecutionResultForBlockID returns Execution Result for a given block. // At present, Access Node might not have execution results for every block @@ -178,91 +178,74 @@ type AccessAPIClient interface { GetExecutionResultForBlockID(ctx context.Context, in *GetExecutionResultForBlockIDRequest, opts ...grpc.CallOption) (*ExecutionResultForBlockIDResponse, error) // GetExecutionResultByID returns Execution Result by its ID. GetExecutionResultByID(ctx context.Context, in *GetExecutionResultByIDRequest, opts ...grpc.CallOption) (*ExecutionResultByIDResponse, error) - // SubscribeBlocksFromStartBlockID streams finalized or sealed blocks starting - // at the requested start block id, up until the latest available block. Once - // the latest is reached, the stream will remain open and responses are sent - // for each new block as it becomes available. + // SubscribeBlocksFromStartBlockID streams finalized or sealed blocks starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. SubscribeBlocksFromStartBlockID(ctx context.Context, in *SubscribeBlocksFromStartBlockIDRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlocksFromStartBlockIDClient, error) - // SubscribeBlocksFromStartHeight streams finalized or sealed blocks starting - // at the requested start block height, up until the latest available block. - // Once the latest is reached, the stream will remain open and responses are - // sent for each new block as it becomes available. + // SubscribeBlocksFromStartHeight streams finalized or sealed blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. SubscribeBlocksFromStartHeight(ctx context.Context, in *SubscribeBlocksFromStartHeightRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlocksFromStartHeightClient, error) - // SubscribeBlocksFromLatest streams finalized or sealed blocks starting from - // the latest finalized or sealed block. The stream will remain open and - // responses are sent for each new block as it becomes available. + // SubscribeBlocksFromLatest streams finalized or sealed blocks starting from the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. SubscribeBlocksFromLatest(ctx context.Context, in *SubscribeBlocksFromLatestRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlocksFromLatestClient, error) - // SubscribeBlockHeadersFromStartBlockID streams finalized or sealed block - // headers starting at the requested start block id, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block header as it becomes available. + // SubscribeBlockHeadersFromStartBlockID streams finalized or sealed block headers starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. SubscribeBlockHeadersFromStartBlockID(ctx context.Context, in *SubscribeBlockHeadersFromStartBlockIDRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlockHeadersFromStartBlockIDClient, error) - // SubscribeBlockHeadersFromStartHeight streams finalized or sealed block - // headers starting at the requested start block height, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block header as it becomes available. + // SubscribeBlockHeadersFromStartHeight streams finalized or sealed block headers starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. SubscribeBlockHeadersFromStartHeight(ctx context.Context, in *SubscribeBlockHeadersFromStartHeightRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlockHeadersFromStartHeightClient, error) - // SubscribeBlockHeadersFromLatest streams finalized or sealed block headers - // starting from the latest finalized or sealed block. The stream will remain - // open and responses are sent for each new block header as it becomes - // available. + // SubscribeBlockHeadersFromLatest streams finalized or sealed block headers starting from the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. SubscribeBlockHeadersFromLatest(ctx context.Context, in *SubscribeBlockHeadersFromLatestRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlockHeadersFromLatestClient, error) - // SubscribeBlockDigestsFromStartBlockID streams finalized or sealed - // lightweight block starting at the requested start block id, up until the - // latest available block. Once the latest is reached, the stream will remain - // open and responses are sent for each new lightweight block as it becomes - // available. + // SubscribeBlockDigestsFromStartBlockID streams finalized or sealed lightweight block starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. SubscribeBlockDigestsFromStartBlockID(ctx context.Context, in *SubscribeBlockDigestsFromStartBlockIDRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlockDigestsFromStartBlockIDClient, error) - // SubscribeBlockDigestsFromStartHeight streams finalized or sealed - // lightweight block starting at the requested start block height, up until - // the latest available block. Once the latest is reached, the stream will - // remain open and responses are sent for each new lightweight block as it - // becomes available. + // SubscribeBlockDigestsFromStartHeight streams finalized or sealed lightweight block starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. SubscribeBlockDigestsFromStartHeight(ctx context.Context, in *SubscribeBlockDigestsFromStartHeightRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlockDigestsFromStartHeightClient, error) - // SubscribeBlockDigestsFromLatest streams finalized or sealed lightweight - // block headers starting of the latest finalized or sealed block. The stream - // will remain open and responses are sent for each new lightweight block as - // it becomes available. + // SubscribeBlockDigestsFromLatest streams finalized or sealed lightweight block headers starting of the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. SubscribeBlockDigestsFromLatest(ctx context.Context, in *SubscribeBlockDigestsFromLatestRequest, opts ...grpc.CallOption) (AccessAPI_SubscribeBlockDigestsFromLatestClient, error) - // SendAndSubscribeTransactionStatuses send a transaction and immediately - // subscribe to its status changes. The status is streamed back until the - // block containing the transaction becomes sealed. + // SendAndSubscribeTransactionStatuses send a transaction and immediately subscribe to its status changes. The status + // is streamed back until the block containing the transaction becomes sealed. SendAndSubscribeTransactionStatuses(ctx context.Context, in *SendAndSubscribeTransactionStatusesRequest, opts ...grpc.CallOption) (AccessAPI_SendAndSubscribeTransactionStatusesClient, error) } @@ -1031,13 +1014,13 @@ type AccessAPIServer interface { // snapshot. Used by Flow nodes joining the network to bootstrap a // space-efficient local state. GetLatestProtocolStateSnapshot(context.Context, *GetLatestProtocolStateSnapshotRequest) (*ProtocolStateSnapshotResponse, error) - // GetProtocolStateSnapshotByBlockID retrieves the latest sealed protocol - // state snapshot by block ID. Used by Flow nodes joining the network to - // bootstrap a space-efficient local state. + // GetProtocolStateSnapshotByBlockID retrieves the latest sealed protocol state + // snapshot by block ID. Used by Flow nodes joining the network to bootstrap a + // space-efficient local state. GetProtocolStateSnapshotByBlockID(context.Context, *GetProtocolStateSnapshotByBlockIDRequest) (*ProtocolStateSnapshotResponse, error) // GetProtocolStateSnapshotByHeight retrieves the latest sealed protocol state - // snapshot by block height. Used by Flow nodes joining the network to - // bootstrap a space-efficient local state. + // snapshot by block height. Used by Flow nodes joining the network to bootstrap a + // space-efficient local state. GetProtocolStateSnapshotByHeight(context.Context, *GetProtocolStateSnapshotByHeightRequest) (*ProtocolStateSnapshotResponse, error) // GetExecutionResultForBlockID returns Execution Result for a given block. // At present, Access Node might not have execution results for every block @@ -1045,91 +1028,74 @@ type AccessAPIServer interface { GetExecutionResultForBlockID(context.Context, *GetExecutionResultForBlockIDRequest) (*ExecutionResultForBlockIDResponse, error) // GetExecutionResultByID returns Execution Result by its ID. GetExecutionResultByID(context.Context, *GetExecutionResultByIDRequest) (*ExecutionResultByIDResponse, error) - // SubscribeBlocksFromStartBlockID streams finalized or sealed blocks starting - // at the requested start block id, up until the latest available block. Once - // the latest is reached, the stream will remain open and responses are sent - // for each new block as it becomes available. + // SubscribeBlocksFromStartBlockID streams finalized or sealed blocks starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. SubscribeBlocksFromStartBlockID(*SubscribeBlocksFromStartBlockIDRequest, AccessAPI_SubscribeBlocksFromStartBlockIDServer) error - // SubscribeBlocksFromStartHeight streams finalized or sealed blocks starting - // at the requested start block height, up until the latest available block. - // Once the latest is reached, the stream will remain open and responses are - // sent for each new block as it becomes available. + // SubscribeBlocksFromStartHeight streams finalized or sealed blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. SubscribeBlocksFromStartHeight(*SubscribeBlocksFromStartHeightRequest, AccessAPI_SubscribeBlocksFromStartHeightServer) error - // SubscribeBlocksFromLatest streams finalized or sealed blocks starting from - // the latest finalized or sealed block. The stream will remain open and - // responses are sent for each new block as it becomes available. + // SubscribeBlocksFromLatest streams finalized or sealed blocks starting from the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new block as it becomes available. // - // Blocks are only returned when they have reached the provided block status. - // For example, if the status is "sealed", only sealed blocks will be - // returned. + // Blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed blocks will be returned. SubscribeBlocksFromLatest(*SubscribeBlocksFromLatestRequest, AccessAPI_SubscribeBlocksFromLatestServer) error - // SubscribeBlockHeadersFromStartBlockID streams finalized or sealed block - // headers starting at the requested start block id, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block header as it becomes available. + // SubscribeBlockHeadersFromStartBlockID streams finalized or sealed block headers starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. SubscribeBlockHeadersFromStartBlockID(*SubscribeBlockHeadersFromStartBlockIDRequest, AccessAPI_SubscribeBlockHeadersFromStartBlockIDServer) error - // SubscribeBlockHeadersFromStartHeight streams finalized or sealed block - // headers starting at the requested start block height, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block header as it becomes available. + // SubscribeBlockHeadersFromStartHeight streams finalized or sealed block headers starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. SubscribeBlockHeadersFromStartHeight(*SubscribeBlockHeadersFromStartHeightRequest, AccessAPI_SubscribeBlockHeadersFromStartHeightServer) error - // SubscribeBlockHeadersFromLatest streams finalized or sealed block headers - // starting from the latest finalized or sealed block. The stream will remain - // open and responses are sent for each new block header as it becomes - // available. + // SubscribeBlockHeadersFromLatest streams finalized or sealed block headers starting from the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new block header as it becomes available. // - // Block headers are only returned when they have reached the provided block - // status. For example, if the status is "sealed", only sealed block headers - // will be returned. + // Block headers are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed block headers will be returned. SubscribeBlockHeadersFromLatest(*SubscribeBlockHeadersFromLatestRequest, AccessAPI_SubscribeBlockHeadersFromLatestServer) error - // SubscribeBlockDigestsFromStartBlockID streams finalized or sealed - // lightweight block starting at the requested start block id, up until the - // latest available block. Once the latest is reached, the stream will remain - // open and responses are sent for each new lightweight block as it becomes - // available. + // SubscribeBlockDigestsFromStartBlockID streams finalized or sealed lightweight block starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. SubscribeBlockDigestsFromStartBlockID(*SubscribeBlockDigestsFromStartBlockIDRequest, AccessAPI_SubscribeBlockDigestsFromStartBlockIDServer) error - // SubscribeBlockDigestsFromStartHeight streams finalized or sealed - // lightweight block starting at the requested start block height, up until - // the latest available block. Once the latest is reached, the stream will - // remain open and responses are sent for each new lightweight block as it - // becomes available. + // SubscribeBlockDigestsFromStartHeight streams finalized or sealed lightweight block starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. SubscribeBlockDigestsFromStartHeight(*SubscribeBlockDigestsFromStartHeightRequest, AccessAPI_SubscribeBlockDigestsFromStartHeightServer) error - // SubscribeBlockDigestsFromLatest streams finalized or sealed lightweight - // block headers starting of the latest finalized or sealed block. The stream - // will remain open and responses are sent for each new lightweight block as - // it becomes available. + // SubscribeBlockDigestsFromLatest streams finalized or sealed lightweight block headers starting of the latest finalized or sealed + // block. The stream will remain open and responses are sent for each new lightweight block as it becomes available. // - // Lightweight blocks are only returned when they have reached the provided - // block status. For example, if the status is "sealed", only sealed - // lightweight blocks will be returned. + // Lightweight blocks are only returned when they have reached the provided block status. For example, + // if the status is "sealed", only sealed lightweight blocks will be returned. SubscribeBlockDigestsFromLatest(*SubscribeBlockDigestsFromLatestRequest, AccessAPI_SubscribeBlockDigestsFromLatestServer) error - // SendAndSubscribeTransactionStatuses send a transaction and immediately - // subscribe to its status changes. The status is streamed back until the - // block containing the transaction becomes sealed. + // SendAndSubscribeTransactionStatuses send a transaction and immediately subscribe to its status changes. The status + // is streamed back until the block containing the transaction becomes sealed. SendAndSubscribeTransactionStatuses(*SendAndSubscribeTransactionStatusesRequest, AccessAPI_SendAndSubscribeTransactionStatusesServer) error } diff --git a/protobuf/go/flow/entities/block_execution_data.pb.go b/protobuf/go/flow/entities/block_execution_data.pb.go index a9240bd74..d41da1773 100644 --- a/protobuf/go/flow/entities/block_execution_data.pb.go +++ b/protobuf/go/flow/entities/block_execution_data.pb.go @@ -20,16 +20,14 @@ var _ = math.Inf // proto package needs to be updated. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package -// BlockExecutionData represents the collection of data produced while execiting -// the block. +// BlockExecutionData represents the collection of data produced while execiting the block. type BlockExecutionData struct { // Block ID of the block that was executed. BlockId []byte `protobuf:"bytes,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` // Ordered list of ChunkExecutionData produced while executing the block. // - // Note: there will be one ChunkExecutionData per collection in the block, - // plus one for the service chunk. The service chunk is executed last and is - // always the last chunk in the list. + // Note: there will be one ChunkExecutionData per collection in the block, plus one for the + // service chunk. The service chunk is executed last and is always the last chunk in the list. ChunkExecutionData []*ChunkExecutionData `protobuf:"bytes,2,rep,name=chunk_execution_data,json=chunkExecutionData,proto3" json:"chunk_execution_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -75,29 +73,25 @@ func (m *BlockExecutionData) GetChunkExecutionData() []*ChunkExecutionData { return nil } -// ChunkExecutionData represents the collection of data produced while executing -// a chunk. +// ChunkExecutionData represents the collection of data produced while executing a chunk. type ChunkExecutionData struct { - // Ordered list of transactions included in the collection that was executed - // in the chunk. + // Ordered list of transactions included in the collection that was executed in the chunk. Collection *ExecutionDataCollection `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"` // Events emitted by transactions in the collection. // - // Note: events listed in the last ChunkExecutionData in the - // BlockExecutionData were emitted by the service transaction. Some, but not - // all, of these events are service events. + // Note: events listed in the last ChunkExecutionData in the BlockExecutionData were emitted by + // the service transaction. Some, but not all, of these events are service events. Events []*Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"` // TrieUpdate produced by executing the collection. // - // TrieUpdates contain a list of registers that were modified during chunk - // execution. The value included is the new value of the register. + // TrieUpdates contain a list of registers that were modified during chunk execution. The value + // included is the new value of the register. TrieUpdate *TrieUpdate `protobuf:"bytes,3,opt,name=trieUpdate,proto3" json:"trieUpdate,omitempty"` // Transaction results produced by executing the collection. // - // Note: these are not the same type of results returned by other RPCs. These - // results are sepcific to execution data. The most notable difference is they - // only include a boolean value to indicate whether or not an error was - // encountered during execution, not the error itself. + // Note: these are not the same type of results returned by other RPCs. These results are sepcific + // to execution data. The most notable difference is they only include a boolean value to indicate + // whether or not an error was encountered during execution, not the error itself. TransactionResults []*ExecutionDataTransactionResult `protobuf:"bytes,4,rep,name=transaction_results,json=transactionResults,proto3" json:"transaction_results,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -157,8 +151,7 @@ func (m *ChunkExecutionData) GetTransactionResults() []*ExecutionDataTransaction return nil } -// ExecutionDataCollection represents the collection of transactions that were -// executed within a chunk. +// ExecutionDataCollection represents the collection of transactions that were executed within a chunk. // // Note: this is not the same type as the entities.Collection. type ExecutionDataCollection struct { @@ -203,22 +196,20 @@ func (m *ExecutionDataCollection) GetTransactions() []*Transaction { // TrieUpdate produced by executing the collection. // -// TrieUpdates contain a list of registers that were modified during chunk -// execution. The value included is the new value of the register. +// TrieUpdates contain a list of registers that were modified during chunk execution. The value +// included is the new value of the register. type TrieUpdate struct { // RootHash is the root hash of the trie before the update is applied. RootHash []byte `protobuf:"bytes,1,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"` // List of register paths updated. // - // Note: paths and payloads map 1:1 with eachother. i.e. for each element in - // path, the value in payloads at the same index is the value of the register - // at that path. + // Note: paths and payloads map 1:1 with eachother. i.e. for each element in path, the value in + // payloads at the same index is the value of the register at that path. Paths [][]byte `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"` // List of register values updated. // - // Note: paths and payloads map 1:1 with eachother. i.e. for each element in - // path, the value in payloads at the same index is the value of the register - // at that path. + // Note: paths and payloads map 1:1 with eachother. i.e. for each element in path, the value in + // payloads at the same index is the value of the register at that path. Payloads []*Payload `protobuf:"bytes,3,rep,name=payloads,proto3" json:"payloads,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -372,13 +363,11 @@ func (m *KeyPart) GetValue() []byte { return nil } -// ExecutionDataTransactionResult represents the result of executing a -// transaction. +// ExecutionDataTransactionResult represents the result of executing a transaction. type ExecutionDataTransactionResult struct { // Transaction ID of the transaction that was executed. TransactionId []byte `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` - // Boolean indicating whether or not the transaction's execution failed with - // an error. + // Boolean indicating whether or not the transaction's execution failed with an error. Failed bool `protobuf:"varint,2,opt,name=failed,proto3" json:"failed,omitempty"` // Amount of computation used during execution. ComputationUsed uint64 `protobuf:"varint,3,opt,name=computation_used,json=computationUsed,proto3" json:"computation_used,omitempty"` diff --git a/protobuf/go/flow/entities/node_version_info.pb.go b/protobuf/go/flow/entities/node_version_info.pb.go index 0466046c3..d50ecfa9f 100644 --- a/protobuf/go/flow/entities/node_version_info.pb.go +++ b/protobuf/go/flow/entities/node_version_info.pb.go @@ -20,6 +20,55 @@ var _ = math.Inf // proto package needs to be updated. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package +type CompatibleRange struct { + // The first block that the version supports. + StartHeight uint64 `protobuf:"varint,1,opt,name=start_height,json=startHeight,proto3" json:"start_height,omitempty"` + // The last block that the version supports. + EndHeight uint64 `protobuf:"varint,2,opt,name=end_height,json=endHeight,proto3" json:"end_height,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *CompatibleRange) Reset() { *m = CompatibleRange{} } +func (m *CompatibleRange) String() string { return proto.CompactTextString(m) } +func (*CompatibleRange) ProtoMessage() {} +func (*CompatibleRange) Descriptor() ([]byte, []int) { + return fileDescriptor_ff9e447351cb4a8a, []int{0} +} + +func (m *CompatibleRange) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_CompatibleRange.Unmarshal(m, b) +} +func (m *CompatibleRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_CompatibleRange.Marshal(b, m, deterministic) +} +func (m *CompatibleRange) XXX_Merge(src proto.Message) { + xxx_messageInfo_CompatibleRange.Merge(m, src) +} +func (m *CompatibleRange) XXX_Size() int { + return xxx_messageInfo_CompatibleRange.Size(m) +} +func (m *CompatibleRange) XXX_DiscardUnknown() { + xxx_messageInfo_CompatibleRange.DiscardUnknown(m) +} + +var xxx_messageInfo_CompatibleRange proto.InternalMessageInfo + +func (m *CompatibleRange) GetStartHeight() uint64 { + if m != nil { + return m.StartHeight + } + return 0 +} + +func (m *CompatibleRange) GetEndHeight() uint64 { + if m != nil { + return m.EndHeight + } + return 0 +} + type NodeVersionInfo struct { // The currently running node software version. Semver string `protobuf:"bytes,1,opt,name=semver,proto3" json:"semver,omitempty"` @@ -29,24 +78,25 @@ type NodeVersionInfo struct { SporkId []byte `protobuf:"bytes,3,opt,name=spork_id,json=sporkId,proto3" json:"spork_id,omitempty"` // The protocol version of the currently running node software. ProtocolVersion uint64 `protobuf:"varint,4,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` - // The spork root block height. This is the height of the first sealed block - // in the spork network. + // The spork root block height. This is the height of the first sealed block in the spork network. SporkRootBlockHeight uint64 `protobuf:"varint,5,opt,name=spork_root_block_height,json=sporkRootBlockHeight,proto3" json:"spork_root_block_height,omitempty"` - // The node's root block height. This is the first sealed block in the node's - // protocol database. If the node started at the beginning of the spork, it is - // the same as the spork root block height. If the node started after the - // beginning of the spork, it is the height of the first sealed block indexed. - NodeRootBlockHeight uint64 `protobuf:"varint,6,opt,name=node_root_block_height,json=nodeRootBlockHeight,proto3" json:"node_root_block_height,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + // The node's root block height. This is the first sealed block in the node's protocol database. + // If the node started at the beginning of the spork, it is the same as the spork root block height. + // If the node started after the beginning of the spork, it is the height of the first sealed block + // indexed. + NodeRootBlockHeight uint64 `protobuf:"varint,6,opt,name=node_root_block_height,json=nodeRootBlockHeight,proto3" json:"node_root_block_height,omitempty"` + // The compatible version range. + CompatibleRange *CompatibleRange `protobuf:"bytes,7,opt,name=compatible_range,json=compatibleRange,proto3" json:"compatible_range,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } func (m *NodeVersionInfo) Reset() { *m = NodeVersionInfo{} } func (m *NodeVersionInfo) String() string { return proto.CompactTextString(m) } func (*NodeVersionInfo) ProtoMessage() {} func (*NodeVersionInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_ff9e447351cb4a8a, []int{0} + return fileDescriptor_ff9e447351cb4a8a, []int{1} } func (m *NodeVersionInfo) XXX_Unmarshal(b []byte) error { @@ -109,7 +159,15 @@ func (m *NodeVersionInfo) GetNodeRootBlockHeight() uint64 { return 0 } +func (m *NodeVersionInfo) GetCompatibleRange() *CompatibleRange { + if m != nil { + return m.CompatibleRange + } + return nil +} + func init() { + proto.RegisterType((*CompatibleRange)(nil), "flow.entities.CompatibleRange") proto.RegisterType((*NodeVersionInfo)(nil), "flow.entities.NodeVersionInfo") } @@ -118,22 +176,26 @@ func init() { } var fileDescriptor_ff9e447351cb4a8a = []byte{ - // 263 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x64, 0x50, 0xcd, 0x4a, 0xf4, 0x30, - 0x14, 0xa5, 0xdf, 0x37, 0x56, 0x0d, 0xca, 0x48, 0x94, 0x31, 0x82, 0x8b, 0x22, 0x08, 0x75, 0xd3, - 0x08, 0x83, 0x2f, 0x30, 0x2b, 0x67, 0x23, 0xd2, 0x85, 0x0b, 0x37, 0x81, 0xb6, 0x69, 0x1b, 0xa6, - 0xcd, 0x19, 0xd2, 0xcc, 0xf8, 0xe0, 0xbe, 0x80, 0xf4, 0x66, 0x2a, 0xa8, 0x9b, 0xc0, 0xf9, 0xcb, - 0xbd, 0xf7, 0xb0, 0xfb, 0xba, 0xc3, 0x87, 0xd4, 0xd6, 0x1b, 0x6f, 0xf4, 0x20, 0x2d, 0x2a, 0xad, - 0xf6, 0xda, 0x0d, 0x06, 0x56, 0x19, 0x5b, 0x23, 0xdb, 0x3a, 0x78, 0xf0, 0xf3, 0xd1, 0x96, 0x4d, - 0xb6, 0xbb, 0xcf, 0x88, 0xcd, 0x5f, 0x50, 0xe9, 0xb7, 0xe0, 0x5c, 0xdb, 0x1a, 0x7c, 0xc1, 0xe2, - 0x41, 0xf7, 0x7b, 0xed, 0x44, 0x94, 0x44, 0xe9, 0x69, 0x7e, 0x40, 0x23, 0x5f, 0xa2, 0xef, 0x8d, - 0x17, 0xff, 0x02, 0x1f, 0x10, 0xbf, 0x61, 0x27, 0xc3, 0x16, 0x6e, 0xa3, 0x4c, 0x25, 0xfe, 0x27, - 0x51, 0x7a, 0x96, 0x1f, 0x13, 0x5e, 0x57, 0xfc, 0x81, 0x5d, 0xd0, 0xd8, 0x12, 0xdd, 0xb4, 0x8c, - 0x98, 0x25, 0x51, 0x3a, 0xcb, 0xe7, 0x13, 0x7f, 0x98, 0xcc, 0x9f, 0xd8, 0x75, 0xf8, 0xc5, 0x01, - 0x5e, 0x15, 0x1d, 0xca, 0x8d, 0x6a, 0xb5, 0x69, 0x5a, 0x2f, 0x8e, 0x28, 0x71, 0x45, 0x72, 0x0e, - 0xf8, 0xd5, 0x28, 0x3e, 0x93, 0xc6, 0x97, 0x6c, 0x41, 0xa7, 0xfe, 0x4d, 0xc5, 0x94, 0xba, 0x1c, - 0xd5, 0x5f, 0xa1, 0xd5, 0x2b, 0xbb, 0x85, 0x6b, 0x32, 0x58, 0x2a, 0x83, 0x36, 0x29, 0x76, 0xf5, - 0x77, 0x2b, 0xef, 0x8f, 0x8d, 0xf1, 0xed, 0xae, 0xc8, 0x4a, 0xf4, 0x32, 0x98, 0x24, 0x3d, 0x93, - 0x53, 0x36, 0x90, 0x3f, 0xea, 0x2e, 0x62, 0x92, 0x96, 0x5f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x0c, - 0x2a, 0x5d, 0x89, 0x86, 0x01, 0x00, 0x00, + // 331 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x64, 0x52, 0xcd, 0x4a, 0xc3, 0x40, + 0x10, 0x26, 0xb5, 0xb6, 0x76, 0x5a, 0x49, 0x59, 0xa5, 0x46, 0x50, 0xa9, 0x05, 0xa1, 0x5e, 0x12, + 0xb1, 0xf8, 0x02, 0xf5, 0x62, 0x2f, 0x22, 0x2b, 0x78, 0xf0, 0x12, 0x9a, 0x64, 0x93, 0x2e, 0x4d, + 0x76, 0xca, 0x66, 0x5b, 0xdf, 0xce, 0x67, 0x93, 0x4c, 0xb2, 0x85, 0xd6, 0x4b, 0x60, 0xbe, 0x9f, + 0xd9, 0xf9, 0x3e, 0x02, 0x0f, 0x69, 0x8e, 0x3f, 0x81, 0x50, 0x46, 0x1a, 0x29, 0xca, 0x40, 0x61, + 0x22, 0xc2, 0x9d, 0xd0, 0xa5, 0x44, 0x15, 0x4a, 0x95, 0xa2, 0xbf, 0xd1, 0x68, 0x90, 0x9d, 0x57, + 0x32, 0xdf, 0xca, 0x26, 0x9f, 0xe0, 0xbe, 0x62, 0xb1, 0x59, 0x1a, 0x19, 0xe5, 0x82, 0x2f, 0x55, + 0x26, 0xd8, 0x3d, 0x0c, 0x4a, 0xb3, 0xd4, 0x26, 0x5c, 0x09, 0x99, 0xad, 0x8c, 0xe7, 0x8c, 0x9d, + 0x69, 0x9b, 0xf7, 0x09, 0x7b, 0x23, 0x88, 0xdd, 0x02, 0x08, 0x95, 0x58, 0x41, 0x8b, 0x04, 0x3d, + 0xa1, 0x92, 0x9a, 0x9e, 0xfc, 0xb6, 0xc0, 0x7d, 0xc7, 0x44, 0x7c, 0xd5, 0xcf, 0x2f, 0x54, 0x8a, + 0x6c, 0x04, 0x9d, 0x52, 0x14, 0x3b, 0xa1, 0x69, 0x5f, 0x8f, 0x37, 0x53, 0x85, 0xc7, 0x58, 0x14, + 0xb2, 0x5e, 0xd3, 0xe3, 0xcd, 0xc4, 0xae, 0xe1, 0xac, 0xdc, 0xa0, 0x5e, 0x87, 0x32, 0xf1, 0x4e, + 0xc6, 0xce, 0x74, 0xc0, 0xbb, 0x34, 0x2f, 0x12, 0xf6, 0x08, 0x43, 0xca, 0x12, 0x63, 0x6e, 0x13, + 0x7a, 0x6d, 0xba, 0xc1, 0xb5, 0x78, 0xf3, 0x32, 0x7b, 0x81, 0xab, 0x7a, 0x8b, 0x46, 0x34, 0x61, + 0x94, 0x63, 0xbc, 0xb6, 0x57, 0x9f, 0x92, 0xe3, 0x92, 0x68, 0x8e, 0x68, 0xe6, 0x15, 0xd9, 0xe4, + 0x9b, 0xc1, 0x88, 0xfa, 0xfb, 0xef, 0xea, 0x90, 0xeb, 0xa2, 0x62, 0x8f, 0x4d, 0x0b, 0x18, 0xc6, + 0xfb, 0x2a, 0x43, 0x5d, 0x75, 0xe9, 0x75, 0xc7, 0xce, 0xb4, 0xff, 0x7c, 0xe7, 0x1f, 0x94, 0xee, + 0x1f, 0x35, 0xce, 0xdd, 0xf8, 0x10, 0x98, 0x7f, 0xc0, 0x0d, 0xea, 0xcc, 0x47, 0x45, 0x3e, 0x0a, + 0x15, 0x6d, 0xd3, 0xfd, 0x82, 0xef, 0xa7, 0x4c, 0x9a, 0xd5, 0x36, 0xf2, 0x63, 0x2c, 0x82, 0x5a, + 0x14, 0xd0, 0xc7, 0x2a, 0x83, 0x0c, 0x83, 0x83, 0xdf, 0x21, 0xea, 0x10, 0x35, 0xfb, 0x0b, 0x00, + 0x00, 0xff, 0xff, 0xf6, 0x11, 0xfd, 0x6f, 0x26, 0x02, 0x00, 0x00, } diff --git a/protobuf/go/flow/executiondata/executiondata.pb.go b/protobuf/go/flow/executiondata/executiondata.pb.go index cd15d98d8..f855b6d7a 100644 --- a/protobuf/go/flow/executiondata/executiondata.pb.go +++ b/protobuf/go/flow/executiondata/executiondata.pb.go @@ -741,8 +741,7 @@ type SubscribeEventsResponse struct { Events []*entities.Event `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"` // Timestamp from the block containing the events. BlockTimestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"` - // The message index of the response message. Used by the client to ensure - // they received all messages. Starts from "1". + // The message index of the response message. Used by the client to ensure they received all messages. Starts from "1". MessageIndex uint64 `protobuf:"varint,5,opt,name=message_index,json=messageIndex,proto3" json:"message_index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -1000,10 +999,10 @@ type SubscribeAccountStatusesFromStartBlockIDRequest struct { // If no filter is provided, all statuses are returned. Filter *StatusFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` // Interval in block heights at which the server should return a heartbeat - // message to the client. The heartbeat is a normal - // SubscribeAccountStatusesResponse with no events, and allows clients to - // track which blocks were searched. Clients can use this information to - // determine which block to start from when reconnecting. + // message to the client. The heartbeat is a normal SubscribeAccountStatusesResponse + // with no events, and allows clients to track which blocks were searched. + // Clients can use this information to determine which block to start from + // when reconnecting. // // The interval is calculated from the last response returned, which could be // either another heartbeat or a response containing events. @@ -1086,10 +1085,10 @@ type SubscribeAccountStatusesFromStartHeightRequest struct { // If no filter is provided, all statuses are returned. Filter *StatusFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` // Interval in block heights at which the server should return a heartbeat - // message to the client. The heartbeat is a normal - // SubscribeAccountStatusesResponse with no events, and allows clients to - // track which blocks were searched. Clients can use this information to - // determine which block to start from when reconnecting. + // message to the client. The heartbeat is a normal SubscribeAccountStatusesResponse + // with no events, and allows clients to track which blocks were searched. + // Clients can use this information to determine which block to start from + // when reconnecting. // // The interval is calculated from the last response returned, which could be // either another heartbeat or a response containing events. @@ -1167,10 +1166,10 @@ type SubscribeAccountStatusesFromLatestBlockRequest struct { // If no filter is provided, all statuses are returned. Filter *StatusFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // Interval in block heights at which the server should return a heartbeat - // message to the client. The heartbeat is a normal - // SubscribeAccountStatusesResponse with no events, and allows clients to - // track which blocks were searched. Clients can use this information to - // determine which block to start from when reconnecting. + // message to the client. The heartbeat is a normal SubscribeAccountStatusesResponse + // with no events, and allows clients to track which blocks were searched. + // Clients can use this information to determine which block to start from + // when reconnecting. // // The interval is calculated from the last response returned, which could be // either another heartbeat or a response containing events. @@ -1241,8 +1240,7 @@ type SubscribeAccountStatusesResponse struct { BlockId []byte `protobuf:"bytes,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` // Block height of the block containing the events. BlockHeight uint64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` - // The message index of the response message. Used by the client to ensure - // they received all messages. Starts from "1". + // The message index of the response message. Used by the client to ensure they received all messages. Starts from "1". MessageIndex uint64 `protobuf:"varint,3,opt,name=message_index,json=messageIndex,proto3" json:"message_index,omitempty"` // The API may return no results which signals a periodic heartbeat. This // allows clients to track which blocks were searched. Client can use this @@ -1359,11 +1357,11 @@ func (m *SubscribeAccountStatusesResponse_Result) GetEvents() []*entities.Event // StatusesFilter defines the filter to apply to block events. // Filters match for events with types in the included event_type list, that are -// related to at least one address from the provided address list. An event -// who's type matches but address does not is ignored, and vice versa. If no -// event_types are provided, all account related protocol event types are -// matched. If no addresses are provided, any address matches. If there are any -// invalid filters, the API will return an InvalidArgument error. +// related to at least one address from the provided address list. An event who's +// type matches but address does not is ignored, and vice versa. +// If no event_types are provided, all account related protocol event types are matched. +// If no addresses are provided, any address matches. +// If there are any invalid filters, the API will return an InvalidArgument error. type StatusFilter struct { // A list of full event types to include. // @@ -1376,9 +1374,8 @@ type StatusFilter struct { EventType []string `protobuf:"bytes,1,rep,name=event_type,json=eventType,proto3" json:"event_type,omitempty"` // A list of addresses who's events should be included. // - // All events matching the provided event_types that are related to any of the - // provided addresses will be returned. If no addresses are provided, all - // events matching event_types will be returned. + // All events matching the provided event_types that are related to any of the provided addresses + // will be returned. If no addresses are provided, all events matching event_types will be returned. // // Addresses must be Flow account addresses in hex format and valid for the // network the node is connected to. i.e. only a mainnet address is valid for diff --git a/protobuf/go/flow/executiondata/executiondata_grpc.pb.go b/protobuf/go/flow/executiondata/executiondata_grpc.pb.go index 726f350a4..5e6687018 100644 --- a/protobuf/go/flow/executiondata/executiondata_grpc.pb.go +++ b/protobuf/go/flow/executiondata/executiondata_grpc.pb.go @@ -49,10 +49,9 @@ type ExecutionDataAPIClient interface { // block has yet not been received. GetExecutionDataByBlockID(ctx context.Context, in *GetExecutionDataByBlockIDRequest, opts ...grpc.CallOption) (*GetExecutionDataByBlockIDResponse, error) // Deprecated: Do not use. - // Warning: this endpoint is deprecated and will be removed in future - // versions. Use SubscribeExecutionDataFromStartBlockID, - // SubscribeExecutionDataFromStartBlockHeight or - // SubscribeExecutionDataFromLatest. + // Warning: this endpoint is deprecated and will be removed in future versions. + // Use SubscribeExecutionDataFromStartBlockID, SubscribeExecutionDataFromStartBlockHeight + // or SubscribeExecutionDataFromLatest. // // SubscribeExecutionData streams execution data for all blocks starting at // the requested start block, up until the latest available block. Once the @@ -63,13 +62,13 @@ type ExecutionDataAPIClient interface { // - InvalidArgument is returned if the request contains an invalid start // block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet not been received. + // node. This may happen if the block was from a previous spork, or if the block + // has yet not been received. SubscribeExecutionData(ctx context.Context, in *SubscribeExecutionDataRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeExecutionDataClient, error) - // SubscribeExecutionDataFromStartBlockID streams execution data for all - // blocks starting at the requested start block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new execution data as it becomes available. + // SubscribeExecutionDataFromStartBlockID streams execution data for all blocks + // starting at the requested start block, up until the latest available block. + // Once the latest is reached, the stream will remain open and responses are + // sent for each new execution data as it becomes available. // // Errors: // - InvalidArgument is returned if the request contains an invalid start @@ -78,10 +77,10 @@ type ExecutionDataAPIClient interface { // node. This may happen if the block was from a previous spork, // or if the block has yet not been received. SubscribeExecutionDataFromStartBlockID(ctx context.Context, in *SubscribeExecutionDataFromStartBlockIDRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeExecutionDataFromStartBlockIDClient, error) - // SubscribeExecutionDataFromStartBlockHeight streams execution data for all - // blocks starting at the requested start block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new execution data as it becomes available. + // SubscribeExecutionDataFromStartBlockHeight streams execution data for all blocks + // starting at the requested start block, up until the latest available block. + // Once the latest is reached, the stream will remain open and responses are + // sent for each new execution data as it becomes available. // // Errors: // - InvalidArgument is returned if the request contains an invalid start @@ -90,8 +89,8 @@ type ExecutionDataAPIClient interface { // node. This may happen if the block was from a previous spork, // or if the block has yet not been received. SubscribeExecutionDataFromStartBlockHeight(ctx context.Context, in *SubscribeExecutionDataFromStartBlockHeightRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeExecutionDataFromStartBlockHeightClient, error) - // SubscribeExecutionDataFromStartBlockHeight streams execution data for all - // blocks starting from the latest block. + // SubscribeExecutionDataFromStartBlockHeight streams execution data for all blocks + // starting from the latest block. // // Errors: // - NotFound is returned if the start block is not currently available on the @@ -99,9 +98,8 @@ type ExecutionDataAPIClient interface { // or if the block has yet not been received. SubscribeExecutionDataFromLatest(ctx context.Context, in *SubscribeExecutionDataFromLatestRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeExecutionDataFromLatestClient, error) // Deprecated: Do not use. - // Warning: this endpoint is deprecated and will be removed in future - // versions. Use SubscribeEventsFromStartBlockID, - // SubscribeEventsFromStartHeight or SubscribeEventsFromLatest. + // Warning: this endpoint is deprecated and will be removed in future versions. + // Use SubscribeEventsFromStartBlockID, SubscribeEventsFromStartHeight or SubscribeEventsFromLatest. // // SubscribeEvents streams events for all blocks starting at the requested // start block, up until the latest available block. Once the latest is @@ -127,10 +125,10 @@ type ExecutionDataAPIClient interface { // happen if the block was from a previous spork, or if the block has yet // not been received. SubscribeEvents(ctx context.Context, in *SubscribeEventsRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeEventsClient, error) - // SubscribeEventsFromStartBlockID streams events for all blocks starting at - // the requested start block id, up until the latest available block. Once the - // latest is reached, the stream will remain open and responses are sent for - // each new block as it becomes available. + // SubscribeEventsFromStartBlockID streams events for all blocks starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -143,16 +141,15 @@ type ExecutionDataAPIClient interface { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid block ID - // or EventFilter. + // - InvalidArgument is returned if the request contains an invalid block ID or EventFilter. // - NotFound is returned if the start block id or execution data are not - // currently available on the node. This may happen if the block was from a - // previous spork, or if the block has yet not been received. + // currently available on the node. This may happen if the block was from a previous spork, or if the + // block has yet not been received. SubscribeEventsFromStartBlockID(ctx context.Context, in *SubscribeEventsFromStartBlockIDRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeEventsFromStartBlockIDClient, error) - // SubscribeEventsFromStartHeight streams events for all blocks starting at - // the requested start block height, up until the latest available block. Once - // the latest is reached, the stream will remain open and responses are sent - // for each new block as it becomes available. + // SubscribeEventsFromStartHeight streams events for all blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -165,15 +162,13 @@ type ExecutionDataAPIClient interface { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid - // EventFilter. + // - InvalidArgument is returned if the request contains an invalid EventFilter. // - NotFound is returned if the start block height or execution data are not - // currently available on the node. This may happen if the block was from a - // previous spork, or if the block has yet not been received. + // currently available on the node. This may happen if the block was from a previous spork, or if the + // block has yet not been received. SubscribeEventsFromStartHeight(ctx context.Context, in *SubscribeEventsFromStartHeightRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeEventsFromStartHeightClient, error) - // SubscribeEventsFromLatest streams events for all blocks starting from the - // latest sealed block. The stream will remain open and responses are sent for - // each new block as it becomes available. + // SubscribeEventsFromLatest streams events for all blocks starting from the latest sealed + // block. The stream will remain open and responses are sent for each new block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -186,81 +181,76 @@ type ExecutionDataAPIClient interface { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid - // EventFilter. + // - InvalidArgument is returned if the request contains an invalid EventFilter. SubscribeEventsFromLatest(ctx context.Context, in *SubscribeEventsFromLatestRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeEventsFromLatestClient, error) - // GetRegisterValues gets the values for the given register IDs as of the - // given block height + // GetRegisterValues gets the values for the given register IDs as of the given block height GetRegisterValues(ctx context.Context, in *GetRegisterValuesRequest, opts ...grpc.CallOption) (*GetRegisterValuesResponse, error) - // SubscribeAccountStatusesFromStartBlockID streams account statuses for all - // blocks starting at the requested start block ID, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromStartBlockID streams account statuses for all blocks starting at the requested + // start block ID, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // // not been received. SubscribeAccountStatusesFromStartBlockID(ctx context.Context, in *SubscribeAccountStatusesFromStartBlockIDRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeAccountStatusesFromStartBlockIDClient, error) - // SubscribeAccountStatusesFromStartHeight streams account statuses for all - // blocks starting at the requested start block height, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromStartHeight streams account statuses for all blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // // not been received. SubscribeAccountStatusesFromStartHeight(ctx context.Context, in *SubscribeAccountStatusesFromStartHeightRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeAccountStatusesFromStartHeightClient, error) - // SubscribeAccountStatusesFromLatestBlock streams account statuses for all - // blocks starting at the last sealed block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromLatestBlock streams account statuses for all blocks starting + // at the last sealed block, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // // not been received. SubscribeAccountStatusesFromLatestBlock(ctx context.Context, in *SubscribeAccountStatusesFromLatestBlockRequest, opts ...grpc.CallOption) (ExecutionDataAPI_SubscribeAccountStatusesFromLatestBlockClient, error) @@ -661,10 +651,9 @@ type ExecutionDataAPIServer interface { // block has yet not been received. GetExecutionDataByBlockID(context.Context, *GetExecutionDataByBlockIDRequest) (*GetExecutionDataByBlockIDResponse, error) // Deprecated: Do not use. - // Warning: this endpoint is deprecated and will be removed in future - // versions. Use SubscribeExecutionDataFromStartBlockID, - // SubscribeExecutionDataFromStartBlockHeight or - // SubscribeExecutionDataFromLatest. + // Warning: this endpoint is deprecated and will be removed in future versions. + // Use SubscribeExecutionDataFromStartBlockID, SubscribeExecutionDataFromStartBlockHeight + // or SubscribeExecutionDataFromLatest. // // SubscribeExecutionData streams execution data for all blocks starting at // the requested start block, up until the latest available block. Once the @@ -675,13 +664,13 @@ type ExecutionDataAPIServer interface { // - InvalidArgument is returned if the request contains an invalid start // block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet not been received. + // node. This may happen if the block was from a previous spork, or if the block + // has yet not been received. SubscribeExecutionData(*SubscribeExecutionDataRequest, ExecutionDataAPI_SubscribeExecutionDataServer) error - // SubscribeExecutionDataFromStartBlockID streams execution data for all - // blocks starting at the requested start block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new execution data as it becomes available. + // SubscribeExecutionDataFromStartBlockID streams execution data for all blocks + // starting at the requested start block, up until the latest available block. + // Once the latest is reached, the stream will remain open and responses are + // sent for each new execution data as it becomes available. // // Errors: // - InvalidArgument is returned if the request contains an invalid start @@ -690,10 +679,10 @@ type ExecutionDataAPIServer interface { // node. This may happen if the block was from a previous spork, // or if the block has yet not been received. SubscribeExecutionDataFromStartBlockID(*SubscribeExecutionDataFromStartBlockIDRequest, ExecutionDataAPI_SubscribeExecutionDataFromStartBlockIDServer) error - // SubscribeExecutionDataFromStartBlockHeight streams execution data for all - // blocks starting at the requested start block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new execution data as it becomes available. + // SubscribeExecutionDataFromStartBlockHeight streams execution data for all blocks + // starting at the requested start block, up until the latest available block. + // Once the latest is reached, the stream will remain open and responses are + // sent for each new execution data as it becomes available. // // Errors: // - InvalidArgument is returned if the request contains an invalid start @@ -702,8 +691,8 @@ type ExecutionDataAPIServer interface { // node. This may happen if the block was from a previous spork, // or if the block has yet not been received. SubscribeExecutionDataFromStartBlockHeight(*SubscribeExecutionDataFromStartBlockHeightRequest, ExecutionDataAPI_SubscribeExecutionDataFromStartBlockHeightServer) error - // SubscribeExecutionDataFromStartBlockHeight streams execution data for all - // blocks starting from the latest block. + // SubscribeExecutionDataFromStartBlockHeight streams execution data for all blocks + // starting from the latest block. // // Errors: // - NotFound is returned if the start block is not currently available on the @@ -711,9 +700,8 @@ type ExecutionDataAPIServer interface { // or if the block has yet not been received. SubscribeExecutionDataFromLatest(*SubscribeExecutionDataFromLatestRequest, ExecutionDataAPI_SubscribeExecutionDataFromLatestServer) error // Deprecated: Do not use. - // Warning: this endpoint is deprecated and will be removed in future - // versions. Use SubscribeEventsFromStartBlockID, - // SubscribeEventsFromStartHeight or SubscribeEventsFromLatest. + // Warning: this endpoint is deprecated and will be removed in future versions. + // Use SubscribeEventsFromStartBlockID, SubscribeEventsFromStartHeight or SubscribeEventsFromLatest. // // SubscribeEvents streams events for all blocks starting at the requested // start block, up until the latest available block. Once the latest is @@ -739,10 +727,10 @@ type ExecutionDataAPIServer interface { // happen if the block was from a previous spork, or if the block has yet // not been received. SubscribeEvents(*SubscribeEventsRequest, ExecutionDataAPI_SubscribeEventsServer) error - // SubscribeEventsFromStartBlockID streams events for all blocks starting at - // the requested start block id, up until the latest available block. Once the - // latest is reached, the stream will remain open and responses are sent for - // each new block as it becomes available. + // SubscribeEventsFromStartBlockID streams events for all blocks starting at the requested + // start block id, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -755,16 +743,15 @@ type ExecutionDataAPIServer interface { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid block ID - // or EventFilter. + // - InvalidArgument is returned if the request contains an invalid block ID or EventFilter. // - NotFound is returned if the start block id or execution data are not - // currently available on the node. This may happen if the block was from a - // previous spork, or if the block has yet not been received. + // currently available on the node. This may happen if the block was from a previous spork, or if the + // block has yet not been received. SubscribeEventsFromStartBlockID(*SubscribeEventsFromStartBlockIDRequest, ExecutionDataAPI_SubscribeEventsFromStartBlockIDServer) error - // SubscribeEventsFromStartHeight streams events for all blocks starting at - // the requested start block height, up until the latest available block. Once - // the latest is reached, the stream will remain open and responses are sent - // for each new block as it becomes available. + // SubscribeEventsFromStartHeight streams events for all blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -777,15 +764,13 @@ type ExecutionDataAPIServer interface { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid - // EventFilter. + // - InvalidArgument is returned if the request contains an invalid EventFilter. // - NotFound is returned if the start block height or execution data are not - // currently available on the node. This may happen if the block was from a - // previous spork, or if the block has yet not been received. + // currently available on the node. This may happen if the block was from a previous spork, or if the + // block has yet not been received. SubscribeEventsFromStartHeight(*SubscribeEventsFromStartHeightRequest, ExecutionDataAPI_SubscribeEventsFromStartHeightServer) error - // SubscribeEventsFromLatest streams events for all blocks starting from the - // latest sealed block. The stream will remain open and responses are sent for - // each new block as it becomes available. + // SubscribeEventsFromLatest streams events for all blocks starting from the latest sealed + // block. The stream will remain open and responses are sent for each new block as it becomes available. // // Events within each block are filtered by the provided EventFilter, and only // those events that match the filter are returned. If no filter is provided, @@ -798,81 +783,76 @@ type ExecutionDataAPIServer interface { // information to determine which block to start from when reconnecting. // // Errors: - // - InvalidArgument is returned if the request contains an invalid - // EventFilter. + // - InvalidArgument is returned if the request contains an invalid EventFilter. SubscribeEventsFromLatest(*SubscribeEventsFromLatestRequest, ExecutionDataAPI_SubscribeEventsFromLatestServer) error - // GetRegisterValues gets the values for the given register IDs as of the - // given block height + // GetRegisterValues gets the values for the given register IDs as of the given block height GetRegisterValues(context.Context, *GetRegisterValuesRequest) (*GetRegisterValuesResponse, error) - // SubscribeAccountStatusesFromStartBlockID streams account statuses for all - // blocks starting at the requested start block ID, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromStartBlockID streams account statuses for all blocks starting at the requested + // start block ID, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // // not been received. SubscribeAccountStatusesFromStartBlockID(*SubscribeAccountStatusesFromStartBlockIDRequest, ExecutionDataAPI_SubscribeAccountStatusesFromStartBlockIDServer) error - // SubscribeAccountStatusesFromStartHeight streams account statuses for all - // blocks starting at the requested start block height, up until the latest - // available block. Once the latest is reached, the stream will remain open - // and responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromStartHeight streams account statuses for all blocks starting at the requested + // start block height, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // // not been received. SubscribeAccountStatusesFromStartHeight(*SubscribeAccountStatusesFromStartHeightRequest, ExecutionDataAPI_SubscribeAccountStatusesFromStartHeightServer) error - // SubscribeAccountStatusesFromLatestBlock streams account statuses for all - // blocks starting at the last sealed block, up until the latest available - // block. Once the latest is reached, the stream will remain open and - // responses are sent for each new block as it becomes available. + // SubscribeAccountStatusesFromLatestBlock streams account statuses for all blocks starting + // at the last sealed block, up until the latest available block. Once the latest is + // reached, the stream will remain open and responses are sent for each new + // block as it becomes available. // - // Events within each block are filtered by the provided StatusFilter, and - // only those events that match the filter are returned. If no filter is - // provided, all events are returned. + // Events within each block are filtered by the provided StatusFilter, and only + // those events that match the filter are returned. If no filter is provided, + // all events are returned. // // Responses are returned for each block containing at least one event that // matches the filter. Additionally, heartbeat responses - // (SubscribeAccountStatusesResponse with no events) are returned periodically - // to allow clients to track which blocks were searched. Clients can use this + // (SubscribeAccountStatusesResponse with no events) are returned periodically to allow + // clients to track which blocks were searched. Clients can use this // information to determine which block to start from when reconnecting. // // Errors: // - InvalidArgument is returned if the request contains an invalid // StatusFilter or start block. // - NotFound is returned if the start block is not currently available on the - // node. This may happen if the block was from a previous spork, or if the - // block has yet + // node. This may happen if the block was from a previous spork, or if the block has yet // // not been received. SubscribeAccountStatusesFromLatestBlock(*SubscribeAccountStatusesFromLatestBlockRequest, ExecutionDataAPI_SubscribeAccountStatusesFromLatestBlockServer) error