Documentation ¶
Index ¶
- type InterceptorNode
- func (n *InterceptorNode) AddMsgToMempool(bz []byte)
- func (n *InterceptorNode) ClearMsgs()
- func (n *InterceptorNode) GetCompositeBlock(blockHash common.Hash) eetypes.CompositeBlock
- func (n *InterceptorNode) GetCompositePayload(compositePayload eth.PayloadID) eetypes.CompositePayload
- func (n *InterceptorNode) GetMsgs() [][]byte
- func (n *InterceptorNode) HasMsgs() bool
- func (n *InterceptorNode) SaveCompositeBlock(compositeBlock eetypes.CompositeBlock)
- func (n *InterceptorNode) SaveCompositePayload(compositePayload eetypes.CompositePayload)
- func (n *InterceptorNode) Start() error
- func (n *InterceptorNode) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InterceptorNode ¶
type InterceptorNode struct {
// contains filtered or unexported fields
}
InterceptorNode is the main struct for the Interceptor node that facilitates communication between the op-node on one side and the ethereum and sdk engines on the other. It holds rpc clients for boths and intercepts all engine API calls performed by op-node.
func NewInterceptorNode ¶
func NewInterceptorNode(config *types.Config) *InterceptorNode
func (*InterceptorNode) AddMsgToMempool ¶
func (n *InterceptorNode) AddMsgToMempool(bz []byte)
AddTxToMempool add a tx to the mempool.
func (*InterceptorNode) ClearMsgs ¶
func (n *InterceptorNode) ClearMsgs()
ClearMsgs clears all messages from the mempool.
func (*InterceptorNode) GetCompositeBlock ¶
func (n *InterceptorNode) GetCompositeBlock(blockHash common.Hash) eetypes.CompositeBlock
GetCompositeBlock returns a composite block given the combined block hash
func (*InterceptorNode) GetCompositePayload ¶
func (n *InterceptorNode) GetCompositePayload(compositePayload eth.PayloadID) eetypes.CompositePayload
GetCompositePayload returns a composite payload given the combined payload hash
func (*InterceptorNode) GetMsgs ¶
func (n *InterceptorNode) GetMsgs() [][]byte
GetMsgs returns all messages in the mempool.
func (*InterceptorNode) HasMsgs ¶
func (n *InterceptorNode) HasMsgs() bool
HasMsgs returns true if the mempool has messages.
func (*InterceptorNode) SaveCompositeBlock ¶
func (n *InterceptorNode) SaveCompositeBlock(compositeBlock eetypes.CompositeBlock)
func (*InterceptorNode) SaveCompositePayload ¶
func (n *InterceptorNode) SaveCompositePayload(compositePayload eetypes.CompositePayload)
func (*InterceptorNode) Start ¶
func (n *InterceptorNode) Start() error
func (*InterceptorNode) Stop ¶
func (n *InterceptorNode) Stop() error
Click to show internal directories.
Click to hide internal directories.