jrpc

Documentation

Index

• Constants
• func Call(method string, data et.Json) (et.Item, error)
• func CallAny(method string, data et.Json) (any, error)
• func CallItems(method string, data et.Json) (et.Items, error)
• func CallList(method string, data et.Json) (et.List, error)
• func Close()
• func GetRouters() (et.Items, error)
• func HttpCallRPC(w http.ResponseWriter, r *http.Request)
• func Mount(services any) error
• func Start() error
• func UnMount() error
• type Package
  • func Load(name string) (*Package, error)
  • func (s *Package) Save() error
• type Solver
  • func GetSolver(method string) (*Solver, error)

Constants

const (
	ERR_PACKAGE_NOT_FOUND = "RPC package not load"
	ERR_SERVER_NOT_FOUND  = "RPC server not found"
	ERR_METHOD_NOT_FOUND  = "Method not found - %s"
	ERR_ENV_REQUIRED      = "Environment RPC_HOST required"
)

const RPC_KEY = "apigateway-rpc"

Functions

func Call

func Call(method string, data et.Json) (et.Item, error)

* * Call * @param method string * @param data et.Json * @return et.Item * @return error *

func CallAny

func CallAny(method string, data et.Json) (any, error)

* * CallAny * @param method string * @param data et.Json * @return et.List * @return error *

func CallItems

func CallItems(method string, data et.Json) (et.Items, error)

* * CallItems * @param method string * @param data et.Json * @return et.Items * @return error *

func CallList

func CallList(method string, data et.Json) (et.List, error)

* * CallItems * @param method string * @param data et.Json * @return et.List * @return error *

func Close

func Close()

* * Close *

func GetRouters

func GetRouters() (et.Items, error)

* * GetRouters * @return et.Items * @return error *

func HttpCallRPC

func HttpCallRPC(w http.ResponseWriter, r *http.Request)

* * HttpCallRPC * @param w http.ResponseWriter * @param r *http.Request *

func Mount

func Mount(services any) error

* * Mount * @param host string * @param port int * @param service any *

func Start

func Start() error

* * Start *

func UnMount

func UnMount() error

* * UnMount * @return error *

Types

type Package

type Package struct {
	Name    string             `json:"name"`
	Host    string             `json:"host"`
	Port    int                `json:"port"`
	Solvers map[string]*Solver `json:"routes"`
}

func Load

func Load(name string) (*Package, error)

* * load *

func (*Package) Save

func (s *Package) Save() error

* * Save * @return error *

type Solver

type Solver struct {
	PackageName string   `json:"packageName"`
	Host        string   `json:"host"`
	Port        int      `json:"port"`
	Method      string   `json:"method"`
	Inputs      []string `json:"inputs"`
	Output      []string `json:"outputs"`
}

func GetSolver

func GetSolver(method string) (*Solver, error)

* * GetSolver * @param method string * @return *Solver * @return error *