ginsider

Documentation

Index

• func MakeUpBaseReq() rpctypes.UpBaseReq
• type GoInsider
  • func NewGoInsider(path, network, address string) *GoInsider
  • func (gi *GoInsider) AddPlugin(ref core.RecordRef, path string) error
  • func (gi *GoInsider) DeactivateObject(object core.RecordRef) error
  • func (gi *GoInsider) Deserialize(from []byte, into interface{}) error
  • func (gi *GoInsider) GetDelegate(object, ofType core.RecordRef) (core.RecordRef, error)
  • func (gi *GoInsider) GetObjChildrenIterator(obj core.RecordRef, prototype core.RecordRef, iteratorID string) (*proxyctx.ChildrenTypedIterator, error)
  • func (gi *GoInsider) MakeErrorSerializable(e error) error
  • func (gi *GoInsider) ObtainCode(ctx context.Context, ref core.RecordRef) (string, error)
  • func (gi *GoInsider) Plugin(ctx context.Context, ref core.RecordRef) (*plugin.Plugin, error)
  • func (gi *GoInsider) RouteCall(ref core.RecordRef, wait bool, method string, args []byte, ...) ([]byte, error)
  • func (gi *GoInsider) SaveAsChild(parentRef, classRef core.RecordRef, constructorName string, ...) (core.RecordRef, error)
  • func (gi *GoInsider) SaveAsDelegate(intoRef, classRef core.RecordRef, constructorName string, ...) (core.RecordRef, error)
  • func (gi *GoInsider) Serialize(what interface{}, to *[]byte) error
  • func (gi *GoInsider) Upstream() (*rpc.Client, error)
• type RPC
  • func (t *RPC) CallConstructor(args rpctypes.DownCallConstructorReq, reply *rpctypes.DownCallConstructorResp) (err error)
  • func (t *RPC) CallMethod(args rpctypes.DownCallMethodReq, reply *rpctypes.DownCallMethodResp) (err error)

Functions

func MakeUpBaseReq

func MakeUpBaseReq() rpctypes.UpBaseReq

MakeUpBaseReq makes base of request from current CallContext

Types

type GoInsider

type GoInsider struct {
	UpstreamClient *rpc.Client
	// contains filtered or unexported fields
}

GoInsider is an RPC interface to run code of plugins

func NewGoInsider

func NewGoInsider(path, network, address string) *GoInsider

NewGoInsider creates a new GoInsider instance validating arguments

func (*GoInsider) AddPlugin

func (gi *GoInsider) AddPlugin(ref core.RecordRef, path string) error

AddPlugin inject plugin by ref in gi memory

func (*GoInsider) DeactivateObject

func (gi *GoInsider) DeactivateObject(object core.RecordRef) error

DeactivateObject ...

func (*GoInsider) Deserialize

func (gi *GoInsider) Deserialize(from []byte, into interface{}) error

Deserialize - CBOR de-serializer wrapper: `from` -> `into`

func (*GoInsider) GetDelegate

func (gi *GoInsider) GetDelegate(object, ofType core.RecordRef) (core.RecordRef, error)

GetDelegate ...

func (*GoInsider) GetObjChildrenIterator

func (gi *GoInsider) GetObjChildrenIterator(obj core.RecordRef, prototype core.RecordRef, iteratorID string) (*proxyctx.ChildrenTypedIterator, error)

GetObjChildrenIterator rpc call to insolard service, returns iterator over children of object with specified prototype at first time call it without iteratorID iteratorID is a cache key on service side, use it in all calls, except first

func (*GoInsider) MakeErrorSerializable

func (gi *GoInsider) MakeErrorSerializable(e error) error

MakeErrorSerializable converts errors satisfying error interface to foundation.Error

func (*GoInsider) ObtainCode

func (gi *GoInsider) ObtainCode(ctx context.Context, ref core.RecordRef) (string, error)

ObtainCode returns path on the file system to the plugin, fetches it from a provider if it's not in the storage

func (*GoInsider) Plugin

func (gi *GoInsider) Plugin(ctx context.Context, ref core.RecordRef) (*plugin.Plugin, error)

Plugin loads Go plugin by reference and returns `*plugin.Plugin` ready to lookup symbols

func (*GoInsider) RouteCall

func (gi *GoInsider) RouteCall(ref core.RecordRef, wait bool, method string, args []byte, proxyPrototype core.RecordRef) ([]byte, error)

RouteCall ...

func (*GoInsider) SaveAsChild

func (gi *GoInsider) SaveAsChild(parentRef, classRef core.RecordRef, constructorName string, argsSerialized []byte) (core.RecordRef, error)

SaveAsChild ...

func (*GoInsider) SaveAsDelegate

func (gi *GoInsider) SaveAsDelegate(intoRef, classRef core.RecordRef, constructorName string, argsSerialized []byte) (core.RecordRef, error)

SaveAsDelegate ...

func (*GoInsider) Serialize

func (gi *GoInsider) Serialize(what interface{}, to *[]byte) error

Serialize - CBOR serializer wrapper: `what` -> `to`

func (*GoInsider) Upstream

func (gi *GoInsider) Upstream() (*rpc.Client, error)

Upstream returns RPC client connected to upstream server (goplugin)

type RPC

type RPC struct {
	GI *GoInsider
}

RPC struct with methods representing RPC interface of this code runner

func (*RPC) CallConstructor

func (t *RPC) CallConstructor(args rpctypes.DownCallConstructorReq, reply *rpctypes.DownCallConstructorResp) (err error)

CallConstructor is an RPC that runs a method on an object and returns a new state of the object and result of the method

func (*RPC) CallMethod

func (t *RPC) CallMethod(args rpctypes.DownCallMethodReq, reply *rpctypes.DownCallMethodResp) (err error)

CallMethod is an RPC that runs a method on an object and returns a new state of the object and result of the method