eeproxy

type CallContext interface {
	GetValue(key []byte) ([]byte, error)
	SetValue(key []byte, value []byte) ([]byte, error)
	DeleteValue(key []byte) ([]byte, error)
	ArrayDBContains(prefix, value []byte, limit int64) (bool, int, int, error)
	GetInfo() *codec.TypedObj
	GetBalance(addr module.Address) *big.Int
	OnEvent(addr module.Address, indexed, data [][]byte) error
	OnResult(status error, steps *big.Int, result *codec.TypedObj)
	OnCall(from, to module.Address, value, limit *big.Int, dataType string, dataObj *codec.TypedObj)
	OnAPI(status error, info *scoreapi.Info)
	OnSetFeeProportion(owner module.Address, portion int)
	SetCode(code []byte) error
	GetObjGraph(bool) (int, []byte, []byte, error)
	SetObjGraph(flags bool, nextHash int, objGraph []byte) error
	Logger() log.Logger
}

type CodeState struct {
	NexHash   int
	GraphHash []byte
	PrevEID   int
}

type Engine interface {
	Type() string
	Init(net, addr string) error
	SetInstances(n int) error
	OnAttach(uid string) bool
	OnEnd(uid string) bool
	Kill(uid string) (bool, error)
	OnConnect(conn ipc.Connection, version uint16) error
	OnClose(conn ipc.Connection) bool
}

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

type InstanceStatus int

type Manager interface {
	GetExecutor(pr RequestPriority) *Executor
	SetInstances(total, tx, query int) error
	Loop() error
	Close() error
}

type ManagerProxy interface {
	Run(uuid string) error
	Kill(uuid string) error
}

type Message uint

type Proxy interface {
	Invoke(ctx CallContext, code string, isQuery bool, from, to module.Address,
		value, limit *big.Int, method string, params *codec.TypedObj,
		cid []byte, eid int, state *CodeState) error
	SendResult(ctx CallContext, status error, steps *big.Int, result *codec.TypedObj, eid int, last int) error
	GetAPI(ctx CallContext, code string) error
	Release()
	Kill() error
}

type RequestPriority int