access

package

v1.3.1 Latest Latest Go to latest Published: Sep 10, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/optakt/flow-dps

Links

Open Source Insights

Documentation ¶

Index ¶

type Invoker
type Server
- func NewServer(index dps.Reader, codec dps.Codec, invoker Invoker) *Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Invoker ¶

type Invoker interface {
	Account(height uint64, address flow.Address) (*flow.Account, error)
	Script(height uint64, script []byte, parameters []cadence.Value) (cadence.Value, error)
}

type Server ¶

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

Server is a simple implementation of the generated AccessAPIServer interface. It uses an index reader interface as the backend to retrieve the desired data. This is generally an on-disk interface, but could be a GRPC-based index as well, in which case there is a double redirection.

func NewServer ¶

func NewServer(index dps.Reader, codec dps.Codec, invoker Invoker) *Server

NewServer creates a new server, using the provided index reader as a backend for data retrieval.

func (*Server) ExecuteScriptAtBlockHeight ¶

func (s *Server) ExecuteScriptAtBlockHeight(_ context.Context, in *access.ExecuteScriptAtBlockHeightRequest) (*access.ExecuteScriptResponse, error)

func (*Server) ExecuteScriptAtBlockID ¶

func (s *Server) ExecuteScriptAtBlockID(ctx context.Context, in *access.ExecuteScriptAtBlockIDRequest) (*access.ExecuteScriptResponse, error)

func (*Server) ExecuteScriptAtLatestBlock ¶

func (s *Server) ExecuteScriptAtLatestBlock(ctx context.Context, in *access.ExecuteScriptAtLatestBlockRequest) (*access.ExecuteScriptResponse, error)

func (*Server) GetAccount ¶

func (s *Server) GetAccount(ctx context.Context, in *access.GetAccountRequest) (*access.GetAccountResponse, error)

func (*Server) GetAccountAtBlockHeight ¶

func (s *Server) GetAccountAtBlockHeight(_ context.Context, in *access.GetAccountAtBlockHeightRequest) (*access.AccountResponse, error)

func (*Server) GetAccountAtLatestBlock ¶

func (s *Server) GetAccountAtLatestBlock(ctx context.Context, in *access.GetAccountAtLatestBlockRequest) (*access.AccountResponse, error)

func (*Server) GetBlockByHeight ¶

func (s *Server) GetBlockByHeight(_ context.Context, in *access.GetBlockByHeightRequest) (*access.BlockResponse, error)

func (*Server) GetBlockByID ¶

func (s *Server) GetBlockByID(ctx context.Context, in *access.GetBlockByIDRequest) (*access.BlockResponse, error)

func (*Server) GetBlockHeaderByHeight ¶

func (s *Server) GetBlockHeaderByHeight(_ context.Context, in *access.GetBlockHeaderByHeightRequest) (*access.BlockHeaderResponse, error)

func (*Server) GetBlockHeaderByID ¶

func (s *Server) GetBlockHeaderByID(ctx context.Context, in *access.GetBlockHeaderByIDRequest) (*access.BlockHeaderResponse, error)

func (*Server) GetCollectionByID ¶

func (s *Server) GetCollectionByID(_ context.Context, in *access.GetCollectionByIDRequest) (*access.CollectionResponse, error)

func (*Server) GetEventsForBlockIDs ¶

func (s *Server) GetEventsForBlockIDs(_ context.Context, in *access.GetEventsForBlockIDsRequest) (*access.EventsResponse, error)

func (*Server) GetEventsForHeightRange ¶

func (s *Server) GetEventsForHeightRange(_ context.Context, in *access.GetEventsForHeightRangeRequest) (*access.EventsResponse, error)

func (*Server) GetExecutionResultForBlockID ¶ added in v1.3.0

func (s *Server) GetExecutionResultForBlockID(_ context.Context, req *access.GetExecutionResultForBlockIDRequest) (*access.ExecutionResultForBlockIDResponse, error)

func (*Server) GetLatestBlock ¶

func (s *Server) GetLatestBlock(ctx context.Context, in *access.GetLatestBlockRequest) (*access.BlockResponse, error)

func (*Server) GetLatestBlockHeader ¶

func (s *Server) GetLatestBlockHeader(ctx context.Context, _ *access.GetLatestBlockHeaderRequest) (*access.BlockHeaderResponse, error)

func (*Server) GetLatestProtocolStateSnapshot ¶

func (s *Server) GetLatestProtocolStateSnapshot(ctx context.Context, in *access.GetLatestProtocolStateSnapshotRequest) (*access.ProtocolStateSnapshotResponse, error)

func (*Server) GetNetworkParameters ¶

func (s *Server) GetNetworkParameters(_ context.Context, _ *access.GetNetworkParametersRequest) (*access.GetNetworkParametersResponse, error)

func (*Server) GetTransaction ¶

func (s *Server) GetTransaction(_ context.Context, in *access.GetTransactionRequest) (*access.TransactionResponse, error)

func (*Server) GetTransactionResult ¶

func (s *Server) GetTransactionResult(_ context.Context, in *access.GetTransactionRequest) (*access.TransactionResultResponse, error)

func (*Server) Ping ¶

func (s *Server) Ping(_ context.Context, _ *access.PingRequest) (*access.PingResponse, error)

func (*Server) SendTransaction ¶

func (s *Server) SendTransaction(ctx context.Context, in *access.SendTransactionRequest) (*access.SendTransactionResponse, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL