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 logicrunner.Reference) (string, error)
  • func (t *GoInsider) RouteCall(ref string, method string, args []byte) ([]byte, error)
  • func (t *GoInsider) Serialize(what interface{}, to *[]byte) error
  • func (t *GoInsider) Upstream() (*rpc.Client, error)
• type RPC
  • func (t *RPC) Call(args rpctypes.DownCallReq, reply *rpctypes.DownCallResp) 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 logicrunner.Reference) (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) RouteCall

func (t *GoInsider) RouteCall(ref string, method string, args []byte) ([]byte, error)

RouteCall ...

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) Call

func (t *RPC) Call(args rpctypes.DownCallReq, reply *rpctypes.DownCallResp) error

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