Help us shape the future of Go! Take the 2026 Go Developer Survey

apiproxy

package
v0.28.11 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2022 License: AGPL-3.0 Imports: 16 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 NewFlowAccessAPIForwarder 

func NewFlowAccessAPIForwarder(identities flow.IdentityList, timeout time.Duration) (*FlowAccessAPIForwarder, error)

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) GetTransactionResultsByBlockID 

func (h *FlowAccessAPIForwarder) GetTransactionResultsByBlockID(context context.Context, req *access.GetTransactionsByBlockIDRequest) (*access.TransactionResultsResponse, error)

func (*FlowAccessAPIForwarder) GetTransactionsByBlockID 

func (h *FlowAccessAPIForwarder) GetTransactionsByBlockID(context context.Context, req *access.GetTransactionsByBlockIDRequest) (*access.TransactionsResponse, 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 {
	Logger   zerolog.Logger
	Metrics  *metrics.ObserverCollector
	Upstream *FlowAccessAPIForwarder
	Observer *protocol.Handler
}

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

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) GetTransactionResultsByBlockID 

func (h *FlowAccessAPIRouter) GetTransactionResultsByBlockID(context context.Context, req *access.GetTransactionsByBlockIDRequest) (*access.TransactionResultsResponse, error)

func (*FlowAccessAPIRouter) GetTransactionsByBlockID 

func (h *FlowAccessAPIRouter) GetTransactionsByBlockID(context context.Context, req *access.GetTransactionsByBlockIDRequest) (*access.TransactionsResponse, 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)

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.