jrpc

Documentation

Index

• Constants
• func CallItem(method string, data et.Json) (et.Item, error)
• func CallItems(method string, data et.Json) (et.Items, error)
• func CallJson(method string, data et.Json) (et.Json, error)
• func CallList(method string, data et.Json) (et.List, error)
• func CallPermitios(method string, data et.Json) (map[string]bool, error)
• func Close()
• func DeleteRouters(host, packageName string) (et.Item, error)
• func GetRouters() (et.Items, error)
• func HttpCallRPC(w http.ResponseWriter, r *http.Request)
• func Mount(services any) error
• func UnMount(host, name string) error
• type Package
  • func Load(name string) (*Package, error)
  • func (s *Package) Save() error
  • func (s *Package) Start() 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"
	MSG_PACKAGE_NOT_FOUND = "Package not found"
	MSG_PACKAGE_DELETE    = "Package deleted"
	MSG_INVALID_RESPONSE  = "Invalid response - %s"
	MSG_NOT_LOAD_CONFIG   = "Not load config - stage:%s name:%s"
)

const RPC_KEY = "apigateway-rpc"

Functions

func CallItem

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

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

func CallItems

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

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

func CallJson

func CallJson(method string, data et.Json) (et.Json, error)

* * CallJson * @param method string * @param data et.Json * @return et.Json * @return error *

func CallList

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

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

func CallPermitios

func CallPermitios(method string, data et.Json) (map[string]bool, error)

* * CallPermitios * @param method string * @param data et.Json * @return map[string]bool * @return error *

func Close

func Close()

* * Close *

func DeleteRouters

func DeleteRouters(host, packageName string) (et.Item, error)

* * DeleteRouters * @param host string * @param packageName string * @return et.Item * @return error *

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 UnMount

func UnMount(host, name string) 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 *

func (*Package) Start

func (s *Package) Start() error

* * Start *

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 *