ginsider

Documentation

Index

• func MakeUpBaseReq() rpctypes.UpBaseReq
• type GoInsider
  • func NewGoInsider(path, network, address string) *GoInsider
  • func (gi *GoInsider) Deserialize(from []byte, into interface{}) error
  • func (gi *GoInsider) GetDelegate(object, ofType core.RecordRef) (core.RecordRef, error)
  • func (gi *GoInsider) GetObjChildren(obj core.RecordRef, class core.RecordRef) ([]core.RecordRef, error)
  • func (gi *GoInsider) MakeErrorSerializable(e error) error
  • func (gi *GoInsider) ObtainCode(ref core.RecordRef) (string, error)
  • func (gi *GoInsider) Plugin(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) error
  • func (t *RPC) CallMethod(args rpctypes.DownCallMethodReq, reply *rpctypes.DownCallMethodResp) error

Functions

func MakeUpBaseReq

func MakeUpBaseReq() rpctypes.UpBaseReq

MakeUpBaseReq makes base of request from current CallContext

Types

type GoInsider

type GoInsider struct {
	UpstreamProtocol string
	UpstreamAddress  string
	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) 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) GetObjChildren

func (gi *GoInsider) GetObjChildren(obj core.RecordRef, class core.RecordRef) ([]core.RecordRef, error)

GetObjChildren ...

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(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(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) ([]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) 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) 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