apiproxy

package
v0.29.17-read-ledger Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 30, 2023 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FlowAccessAPIForwarder 

type FlowAccessAPIForwarder struct {
	// contains filtered or unexported fields
}

FlowAccessAPIForwarder forwards all requests to a set of upstream access nodes or observers

func (*FlowAccessAPIForwarder) ExecuteScriptAtBlockHeight 

func (h *FlowAccessAPIForwarder) ExecuteScriptAtBlockHeight(context context.Context, req *access.ExecuteScriptAtBlockHeightRequest) (*access.ExecuteScriptResponse, error)

func (*FlowAccessAPIForwarder) ExecuteScriptAtBlockID 

func (h *FlowAccessAPIForwarder) ExecuteScriptAtBlockID(context context.Context, req *access.ExecuteScriptAtBlockIDRequest) (*access.ExecuteScriptResponse, error)

func (*FlowAccessAPIForwarder) ExecuteScriptAtLatestBlock 

func (h *FlowAccessAPIForwarder) ExecuteScriptAtLatestBlock(context context.Context, req *access.ExecuteScriptAtLatestBlockRequest) (*access.ExecuteScriptResponse, error)

func (*FlowAccessAPIForwarder) GetAccount 

func (h *FlowAccessAPIForwarder) GetAccount(context context.Context, req *access.GetAccountRequest) (*access.GetAccountResponse, error)

func (*FlowAccessAPIForwarder) GetAccountAtBlockHeight 

func (h *FlowAccessAPIForwarder) GetAccountAtBlockHeight(context context.Context, req *access.GetAccountAtBlockHeightRequest) (*access.AccountResponse, error)

func (*FlowAccessAPIForwarder) GetAccountAtLatestBlock 

func (h *FlowAccessAPIForwarder) GetAccountAtLatestBlock(context context.Context, req *access.GetAccountAtLatestBlockRequest) (*access.AccountResponse, error)

func (*FlowAccessAPIForwarder) GetBlockByHeight 

func (h *FlowAccessAPIForwarder) GetBlockByHeight(context context.Context, req *access.GetBlockByHeightRequest) (*access.BlockResponse, error)

func (*FlowAccessAPIForwarder) GetBlockByID 

func (h *FlowAccessAPIForwarder) GetBlockByID(context context.Context, req *access.GetBlockByIDRequest) (*access.BlockResponse, error)

func (*FlowAccessAPIForwarder) GetBlockHeaderByHeight 

func (h *FlowAccessAPIForwarder) GetBlockHeaderByHeight(context context.Context, req *access.GetBlockHeaderByHeightRequest) (*access.BlockHeaderResponse, error)

func (*FlowAccessAPIForwarder) GetBlockHeaderByID 

func (h *FlowAccessAPIForwarder) GetBlockHeaderByID(context context.Context, req *access.GetBlockHeaderByIDRequest) (*access.BlockHeaderResponse, error)

func (*FlowAccessAPIForwarder) GetCollectionByID 

func (h *FlowAccessAPIForwarder) GetCollectionByID(context context.Context, req *access.GetCollectionByIDRequest) (*access.CollectionResponse, error)

func (*FlowAccessAPIForwarder) GetEventsForBlockIDs 

func (h *FlowAccessAPIForwarder) GetEventsForBlockIDs(context context.Context, req *access.GetEventsForBlockIDsRequest) (*access.EventsResponse, error)

func (*FlowAccessAPIForwarder) GetEventsForHeightRange 

func (h *FlowAccessAPIForwarder) GetEventsForHeightRange(context context.Context, req *access.GetEventsForHeightRangeRequest) (*access.EventsResponse, error)

func (*FlowAccessAPIForwarder) GetExecutionResultForBlockID 

func (h *FlowAccessAPIForwarder) GetExecutionResultForBlockID(context context.Context, req *access.GetExecutionResultForBlockIDRequest) (*access.ExecutionResultForBlockIDResponse, error)

func (*FlowAccessAPIForwarder) GetLatestBlock 

func (h *FlowAccessAPIForwarder) GetLatestBlock(context context.Context, req *access.GetLatestBlockRequest) (*access.BlockResponse, error)

func (*FlowAccessAPIForwarder) GetLatestBlockHeader 

func (h *FlowAccessAPIForwarder) GetLatestBlockHeader(context context.Context, req *access.GetLatestBlockHeaderRequest) (*access.BlockHeaderResponse, error)

func (*FlowAccessAPIForwarder) GetLatestProtocolStateSnapshot 

func (h *FlowAccessAPIForwarder) GetLatestProtocolStateSnapshot(context context.Context, req *access.GetLatestProtocolStateSnapshotRequest) (*access.ProtocolStateSnapshotResponse, error)

func (*FlowAccessAPIForwarder) GetNetworkParameters 

func (h *FlowAccessAPIForwarder) GetNetworkParameters(context context.Context, req *access.GetNetworkParametersRequest) (*access.GetNetworkParametersResponse, error)

func (*FlowAccessAPIForwarder) GetTransaction 

func (h *FlowAccessAPIForwarder) GetTransaction(context context.Context, req *access.GetTransactionRequest) (*access.TransactionResponse, error)

func (*FlowAccessAPIForwarder) GetTransactionResult 

func (h *FlowAccessAPIForwarder) GetTransactionResult(context context.Context, req *access.GetTransactionRequest) (*access.TransactionResultResponse, error)

func (*FlowAccessAPIForwarder) GetTransactionResultByIndex 

func (h *FlowAccessAPIForwarder) GetTransactionResultByIndex(context context.Context, req *access.GetTransactionByIndexRequest) (*access.TransactionResultResponse, error)

func (*FlowAccessAPIForwarder) Ping 

func (h *FlowAccessAPIForwarder) Ping(context context.Context, req *access.PingRequest) (*access.PingResponse, error)

Ping pings the service. It is special in the sense that it responds successful, only if all underlying services are ready.

func (*FlowAccessAPIForwarder) SendTransaction 

func (h *FlowAccessAPIForwarder) SendTransaction(context context.Context, req *access.SendTransactionRequest) (*access.SendTransactionResponse, error)

type FlowAccessAPIRouter 

type FlowAccessAPIRouter struct {
	access.AccessAPIServer
	// contains filtered or unexported fields
}

FlowAccessAPIRouter is a structure that represents the routing proxy algorithm. It splits requests between a local and a remote API service.

func NewFlowAccessAPIRouter 

func NewFlowAccessAPIRouter(accessNodeAddressAndPort flow.IdentityList, timeout time.Duration) (*FlowAccessAPIRouter, error)

NewFlowAccessAPIRouter creates a backend access API that forwards some requests to an upstream node. It is used by Observer services, Blockchain Data Service, etc. Make sure that this is just for observation and not a staked participant in the flow network. This means that observers see a copy of the data but there is no interaction to ensure integrity from the root block.

func (*FlowAccessAPIRouter) ExecuteScriptAtBlockHeight 

func (h *FlowAccessAPIRouter) ExecuteScriptAtBlockHeight(context context.Context, req *access.ExecuteScriptAtBlockHeightRequest) (*access.ExecuteScriptResponse, error)

func (*FlowAccessAPIRouter) ExecuteScriptAtBlockID 

func (h *FlowAccessAPIRouter) ExecuteScriptAtBlockID(context context.Context, req *access.ExecuteScriptAtBlockIDRequest) (*access.ExecuteScriptResponse, error)

func (*FlowAccessAPIRouter) ExecuteScriptAtLatestBlock 

func (h *FlowAccessAPIRouter) ExecuteScriptAtLatestBlock(context context.Context, req *access.ExecuteScriptAtLatestBlockRequest) (*access.ExecuteScriptResponse, error)

func (*FlowAccessAPIRouter) GetAccount 

func (h *FlowAccessAPIRouter) GetAccount(context context.Context, req *access.GetAccountRequest) (*access.GetAccountResponse, error)

func (*FlowAccessAPIRouter) GetAccountAtBlockHeight 

func (h *FlowAccessAPIRouter) GetAccountAtBlockHeight(context context.Context, req *access.GetAccountAtBlockHeightRequest) (*access.AccountResponse, error)

func (*FlowAccessAPIRouter) GetAccountAtLatestBlock 

func (h *FlowAccessAPIRouter) GetAccountAtLatestBlock(context context.Context, req *access.GetAccountAtLatestBlockRequest) (*access.AccountResponse, error)

func (*FlowAccessAPIRouter) GetBlockByHeight 

func (h *FlowAccessAPIRouter) GetBlockByHeight(context context.Context, req *access.GetBlockByHeightRequest) (*access.BlockResponse, error)

func (*FlowAccessAPIRouter) GetBlockByID 

func (h *FlowAccessAPIRouter) GetBlockByID(context context.Context, req *access.GetBlockByIDRequest) (*access.BlockResponse, error)

func (*FlowAccessAPIRouter) GetBlockHeaderByHeight 

func (h *FlowAccessAPIRouter) GetBlockHeaderByHeight(context context.Context, req *access.GetBlockHeaderByHeightRequest) (*access.BlockHeaderResponse, error)

func (*FlowAccessAPIRouter) GetBlockHeaderByID 

func (h *FlowAccessAPIRouter) GetBlockHeaderByID(context context.Context, req *access.GetBlockHeaderByIDRequest) (*access.BlockHeaderResponse, error)

func (*FlowAccessAPIRouter) GetCollectionByID 

func (h *FlowAccessAPIRouter) GetCollectionByID(context context.Context, req *access.GetCollectionByIDRequest) (*access.CollectionResponse, error)

func (*FlowAccessAPIRouter) GetEventsForBlockIDs 

func (h *FlowAccessAPIRouter) GetEventsForBlockIDs(context context.Context, req *access.GetEventsForBlockIDsRequest) (*access.EventsResponse, error)

func (*FlowAccessAPIRouter) GetEventsForHeightRange 

func (h *FlowAccessAPIRouter) GetEventsForHeightRange(context context.Context, req *access.GetEventsForHeightRangeRequest) (*access.EventsResponse, error)

func (*FlowAccessAPIRouter) GetExecutionResultForBlockID 

func (h *FlowAccessAPIRouter) GetExecutionResultForBlockID(context context.Context, req *access.GetExecutionResultForBlockIDRequest) (*access.ExecutionResultForBlockIDResponse, error)

func (*FlowAccessAPIRouter) GetLatestBlock 

func (h *FlowAccessAPIRouter) GetLatestBlock(context context.Context, req *access.GetLatestBlockRequest) (*access.BlockResponse, error)

func (*FlowAccessAPIRouter) GetLatestBlockHeader 

func (h *FlowAccessAPIRouter) GetLatestBlockHeader(context context.Context, req *access.GetLatestBlockHeaderRequest) (*access.BlockHeaderResponse, error)

func (*FlowAccessAPIRouter) GetLatestProtocolStateSnapshot 

func (h *FlowAccessAPIRouter) GetLatestProtocolStateSnapshot(context context.Context, req *access.GetLatestProtocolStateSnapshotRequest) (*access.ProtocolStateSnapshotResponse, error)

func (*FlowAccessAPIRouter) GetNetworkParameters 

func (h *FlowAccessAPIRouter) GetNetworkParameters(context context.Context, req *access.GetNetworkParametersRequest) (*access.GetNetworkParametersResponse, error)

func (*FlowAccessAPIRouter) GetTransaction 

func (h *FlowAccessAPIRouter) GetTransaction(context context.Context, req *access.GetTransactionRequest) (*access.TransactionResponse, error)

func (*FlowAccessAPIRouter) GetTransactionResult 

func (h *FlowAccessAPIRouter) GetTransactionResult(context context.Context, req *access.GetTransactionRequest) (*access.TransactionResultResponse, error)

func (*FlowAccessAPIRouter) GetTransactionResultByIndex 

func (h *FlowAccessAPIRouter) GetTransactionResultByIndex(context context.Context, req *access.GetTransactionByIndexRequest) (*access.TransactionResultResponse, error)

func (*FlowAccessAPIRouter) Ping 

func (h *FlowAccessAPIRouter) Ping(context context.Context, req *access.PingRequest) (*access.PingResponse, error)

Ping pings the service. It is special in the sense that it responds successful, only if all underlying services are ready.

func (*FlowAccessAPIRouter) SendTransaction 

func (h *FlowAccessAPIRouter) SendTransaction(context context.Context, req *access.SendTransactionRequest) (*access.SendTransactionResponse, error)

func (*FlowAccessAPIRouter) SetLocalAPI 

func (h *FlowAccessAPIRouter) SetLocalAPI(local access.AccessAPIServer)

SetLocalAPI sets the local backend that responds to block related calls Everything else is forwarded to a selected upstream node

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.