logicrunner

Documentation

Overview

Package logicrunner - infrastructure for executing smartcontracts

Index

• func HashInterface(in interface{}) []byte
• func MakeBaseEvent(req rpctypes.UpBaseReq) message.BaseLogicEvent
• type CaseBind
• type CaseRecord
• type CaseRecordType
• type LogicRunner
  • func NewLogicRunner(cfg *configuration.LogicRunner) (*LogicRunner, error)
  • func (lr *LogicRunner) Execute(msg core.Message) (core.Reply, error)
  • func (lr *LogicRunner) GetExecutor(t core.MachineType) (core.MachineLogicExecutor, error)
  • func (lr *LogicRunner) OnPulse(pulse core.Pulse) error
  • func (lr *LogicRunner) RegisterExecutor(t core.MachineType, e core.MachineLogicExecutor) error
  • func (lr *LogicRunner) Start(c core.Components) error
  • func (lr *LogicRunner) Stop() error
• type RPC
  • func StartRPC(lr *LogicRunner) *RPC
  • func (gpr *RPC) GetCode(req rpctypes.UpGetCodeReq, reply *rpctypes.UpGetCodeResp) error
  • func (gpr *RPC) GetDelegate(req rpctypes.UpGetDelegateReq, reply *rpctypes.UpGetDelegateResp) error
  • func (gpr *RPC) GetObjChildren(req rpctypes.UpGetObjChildrenReq, reply *rpctypes.UpGetObjChildrenResp) error
  • func (gpr *RPC) RouteCall(req rpctypes.UpRouteReq, rep *rpctypes.UpRouteResp) error
  • func (gpr *RPC) RouteConstructorCall(req rpctypes.UpRouteConstructorReq, rep *rpctypes.UpRouteConstructorResp) error
  • func (gpr *RPC) SaveAsChild(req rpctypes.UpSaveAsChildReq, reply *rpctypes.UpSaveAsChildResp) error
  • func (gpr *RPC) SaveAsDelegate(req rpctypes.UpSaveAsDelegateReq, reply *rpctypes.UpSaveAsDelegateResp) error

Functions

func HashInterface

func HashInterface(in interface{}) []byte

func MakeBaseEvent

func MakeBaseEvent(req rpctypes.UpBaseReq) message.BaseLogicEvent

MakeBaseEvent makes base of logicrunner event from base of up request

Types

type CaseBind

type CaseBind struct {
	P core.Pulse           // pulse info for this bind
	R map[trf][]CaseRecord // ordered cases for each object
}

CaseBinder is a whole result of executor efforts on every object it seen on this pulse

type CaseRecord

type CaseRecord struct {
	Type   CaseRecordType
	ReqSig []byte
	Resp   rpctypes.UpRespIface
}

CaseRecord is one record of validateable object calling history

type CaseRecordType

type CaseRecordType int

const (
	CaseRecordTypeMethodCall CaseRecordType
	CaseRecordTypeConstructorCall
	CaseRecordTypeMethodCallResult
	CaseRecordTypeConstructorCallResult
	CaseRecordTypeRouteCall
	CaseRecordTypeSaveAsChild
	CaseRecordTypeGetObjChildren
	CaseRecordTypeSaveAsDelegate
	CaseRecordTypeGetDelegate
)

Types of records

type LogicRunner

type LogicRunner struct {
	Executors       [core.MachineTypesLastID]core.MachineLogicExecutor
	ArtifactManager core.ArtifactManager
	MessageBus      core.MessageBus

	Cfg *configuration.LogicRunner
	// contains filtered or unexported fields
}

LogicRunner is a general interface of contract executor

func NewLogicRunner

func NewLogicRunner(cfg *configuration.LogicRunner) (*LogicRunner, error)

NewLogicRunner is constructor for LogicRunner

func (*LogicRunner) Execute

func (lr *LogicRunner) Execute(msg core.Message) (core.Reply, error)

Execute runs a method on an object, ATM just thin proxy to `GoPlugin.Exec`

func (*LogicRunner) GetExecutor

func (lr *LogicRunner) GetExecutor(t core.MachineType) (core.MachineLogicExecutor, error)

GetExecutor returns an executor for the `MachineType` if it was registered (`RegisterExecutor`), returns error otherwise

func (*LogicRunner) OnPulse

func (lr *LogicRunner) OnPulse(pulse core.Pulse) error

func (*LogicRunner) RegisterExecutor

func (lr *LogicRunner) RegisterExecutor(t core.MachineType, e core.MachineLogicExecutor) error

RegisterExecutor registers an executor for particular `MachineType`

func (*LogicRunner) Start

func (lr *LogicRunner) Start(c core.Components) error

Start starts logic runner component

func (*LogicRunner) Stop

func (lr *LogicRunner) Stop() error

Stop stops logic runner component and its executors

type RPC

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

RPC is a RPC interface for runner to use for various tasks, e.g. code fetching

func StartRPC

func StartRPC(lr *LogicRunner) *RPC

StartRPC starts RPC server for isolated executors to use

func (*RPC) GetCode

func (gpr *RPC) GetCode(req rpctypes.UpGetCodeReq, reply *rpctypes.UpGetCodeResp) error

GetCode is an RPC retrieving a code by its reference

func (*RPC) GetDelegate

func (gpr *RPC) GetDelegate(req rpctypes.UpGetDelegateReq, reply *rpctypes.UpGetDelegateResp) error

GetDelegate is an RPC saving data as memory of a contract as child a parent

func (*RPC) GetObjChildren

func (gpr *RPC) GetObjChildren(req rpctypes.UpGetObjChildrenReq, reply *rpctypes.UpGetObjChildrenResp) error

GetObjChildren is an RPC returns set of object children

func (*RPC) RouteCall

func (gpr *RPC) RouteCall(req rpctypes.UpRouteReq, rep *rpctypes.UpRouteResp) error

RouteCall routes call from a contract to a contract through event bus.

func (*RPC) RouteConstructorCall

func (gpr *RPC) RouteConstructorCall(req rpctypes.UpRouteConstructorReq, rep *rpctypes.UpRouteConstructorResp) error

RouteConstructorCall routes call from a contract to a constructor of another contract

func (*RPC) SaveAsChild

func (gpr *RPC) SaveAsChild(req rpctypes.UpSaveAsChildReq, reply *rpctypes.UpSaveAsChildResp) error

SaveAsChild is an RPC saving data as memory of a contract as child a parent

func (*RPC) SaveAsDelegate

func (gpr *RPC) SaveAsDelegate(req rpctypes.UpSaveAsDelegateReq, reply *rpctypes.UpSaveAsDelegateResp) error

SaveAsDelegate is an RPC saving data as memory of a contract as child a parent