ginsider

Documentation

Index

• type GoInsider
  • func NewGoInsider(path string, address string) *GoInsider
  • func (t *GoInsider) Deserialize(from []byte, into interface{}) error
  • func (t *GoInsider) ObtainCode(ref core.RecordRef) (string, error)
  • func (t *GoInsider) Plugin(ref core.RecordRef) (*plugin.Plugin, error)
  • func (t *GoInsider) RouteCall(ref string, method string, args []byte) ([]byte, error)
  • func (t *GoInsider) RouteConstructorCall(ref string, name string, args []byte) (string, error)
  • func (t *GoInsider) Serialize(what interface{}, to *[]byte) error
  • func (t *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

Types

type GoInsider

type GoInsider struct {
	UpstreamRPCAddress string
	UpstreamRPCClient  *rpc.Client
	// contains filtered or unexported fields
}

GoInsider is an RPC interface to run code of plugins

func NewGoInsider

func NewGoInsider(path string, address string) *GoInsider

NewGoInsider creates a new GoInsider instance validating arguments

func (*GoInsider) Deserialize

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

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

func (*GoInsider) ObtainCode

func (t *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 (t *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 (t *GoInsider) RouteCall(ref string, method string, args []byte) ([]byte, error)

RouteCall ...

func (*GoInsider) RouteConstructorCall

func (t *GoInsider) RouteConstructorCall(ref string, name string, args []byte) (string, error)

RouteConstructorCall ...

func (*GoInsider) Serialize

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

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

func (*GoInsider) Upstream

func (t *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