Documentation
¶
Index ¶
- type Config
- type CoreDriver
- func (driver *CoreDriver) Close() error
- func (driver *CoreDriver) DiagnoseWait(milliseconds uint32) error
- func (driver *CoreDriver) GetVersion() (string, error)
- func (driver *CoreDriver) IsClosed() bool
- func (driver *CoreDriver) RestartCoreIfNecessary() error
- func (driver *CoreDriver) RunSmartContractCall(input *vmcommon.ContractCallInput) (*vmcommon.VMOutput, error)
- func (driver *CoreDriver) RunSmartContractCreate(input *vmcommon.ContractCreateInput) (*vmcommon.VMOutput, error)
- type NodeMessenger
- func (messenger *NodeMessenger) ReceiveHookCallRequestOrContractResponse(timeout int) (common.MessageHandler, int, error)
- func (messenger *NodeMessenger) SendContractRequest(request common.MessageHandler) error
- func (messenger *NodeMessenger) SendHookCallResponse(response common.MessageHandler) error
- type NodePart
- type ParentLogsPart
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
MaxLoopTime int
}
Config is the configuration for the driver and for Node's part
type CoreDriver ¶
type CoreDriver struct {
// contains filtered or unexported fields
}
CoreDriver manages the execution of the Core process
func NewCoreDriver ¶
func NewCoreDriver( blockchainHook vmcommon.BlockchainHook, coreArguments common.CoreArguments, config Config, ) (*CoreDriver, error)
NewCoreDriver creates a new driver
func (*CoreDriver) DiagnoseWait ¶
func (driver *CoreDriver) DiagnoseWait(milliseconds uint32) error
DiagnoseWait sends a diagnose message to Core
func (*CoreDriver) GetVersion ¶ added in v0.0.3
func (driver *CoreDriver) GetVersion() (string, error)
func (*CoreDriver) IsClosed ¶
func (driver *CoreDriver) IsClosed() bool
IsClosed checks whether the Core process is closed
func (*CoreDriver) RestartCoreIfNecessary ¶
func (driver *CoreDriver) RestartCoreIfNecessary() error
RestartCoreIfNecessary restarts Core if the process is closed
func (*CoreDriver) RunSmartContractCall ¶
func (driver *CoreDriver) RunSmartContractCall(input *vmcommon.ContractCallInput) (*vmcommon.VMOutput, error)
RunSmartContractCall sends an execution request to Core and waits for the output
func (*CoreDriver) RunSmartContractCreate ¶
func (driver *CoreDriver) RunSmartContractCreate(input *vmcommon.ContractCreateInput) (*vmcommon.VMOutput, error)
RunSmartContractCreate sends a deploy request to Core and waits for the output
type NodeMessenger ¶
NodeMessenger is the messenger on Node's part of the pipe
func NewNodeMessenger ¶
func NewNodeMessenger(reader *os.File, writer *os.File, marshalizer marshaling.Marshalizer) *NodeMessenger
NewNodeMessenger creates a new messenger
func (*NodeMessenger) ReceiveHookCallRequestOrContractResponse ¶
func (messenger *NodeMessenger) ReceiveHookCallRequestOrContractResponse(timeout int) (common.MessageHandler, int, error)
ReceiveHookCallRequestOrContractResponse waits for any message that could arrive from Core
func (*NodeMessenger) SendContractRequest ¶
func (messenger *NodeMessenger) SendContractRequest(request common.MessageHandler) error
SendContractRequest sends a request to Core
func (*NodeMessenger) SendHookCallResponse ¶
func (messenger *NodeMessenger) SendHookCallResponse(response common.MessageHandler) error
SendHookCallResponse sends a hook response to Core
type NodePart ¶
type NodePart struct {
Messenger *NodeMessenger
Repliers []common.MessageReplier
// contains filtered or unexported fields
}
NodePart is the endpoint that implements the message loop on Node's side
func NewNodePart ¶
func NewNodePart( input *os.File, output *os.File, blockchain vmcommon.BlockchainHook, config Config, marshalizer marshaling.Marshalizer, ) (*NodePart, error)
NewNodePart creates the Node part
func (*NodePart) SendStopSignal ¶
SendStopSignal sends a stop signal to Core Should only be used for tests!
func (*NodePart) StartLoop ¶
func (part *NodePart) StartLoop(request common.MessageHandler) (common.MessageHandler, error)
StartLoop runs the main loop
Source Files