Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
GRPCListenAddr string
HTTPListenAddr string
ExecutionAddr string
CollectionAddr string
MaxMsgSize int // In bytes
}
Config defines the configurable options for the access node server
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
Engine implements a gRPC server with a simplified version of the Observation API.
func New ¶
func New(log zerolog.Logger, state protocol.State, config Config, executionRPC execproto.ExecutionAPIClient, collectionRPC accessproto.AccessAPIClient, blocks storage.Blocks, headers storage.Headers, collections storage.Collections, transactions storage.Transactions, chainID flow.ChainID, transactionMetrics module.TransactionMetrics, collectionGRPCPort uint, retryEnabled bool, ) *Engine
New returns a new RPC engine.
func (*Engine) Done ¶
func (e *Engine) Done() <-chan struct{}
Done returns a done channel that is closed once the engine has fully stopped. It sends a signal to stop the gRPC server, then closes the channel.
func (*Engine) Ready ¶
func (e *Engine) Ready() <-chan struct{}
Ready returns a ready channel that is closed once the engine has fully started. The RPC engine is ready when the gRPC server has successfully started.
func (*Engine) SubmitLocal ¶
func (e *Engine) SubmitLocal(event interface{})
SubmitLocal submits an event originating on the local node.
type HTTPHeader ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.