rpc

Documentation

Index

• type RPC
  • func NewRPC(cfgFile string) (*RPC, error)
  • func (r *RPC) Attach() (*rpc.Client, error)
  • func (r *RPC) GetApis(apiModule ...string) []rpc.API
  • func (r *RPC) GetHttpApis() []rpc.API
  • func (r *RPC) GetInProcessApis() []rpc.API
  • func (r *RPC) GetIpcApis() []rpc.API
  • func (r *RPC) GetPublicApis() []rpc.API
  • func (r *RPC) GetWSApis() []rpc.API
  • func (r *RPC) StartHTTPEndpoint(endpoint string, apis []rpc.API, modules []string, cors []string, ...) (net.Listener, *rpc.Server, error)
  • func (r *RPC) StartRPC() error
  • func (r *RPC) StartWSEndpoint(endpoint string, apis []rpc.API, modules []string, wsOrigins []string, ...) (net.Listener, *rpc.Server, error)
  • func (r *RPC) StopRPC()

Types

type RPC

type RPC struct {
	DashboardTargetURL string
	NetID              uint `json:"NetID"`
	// contains filtered or unexported fields
}

func NewRPC

func NewRPC(cfgFile string) (*RPC, error)

func (*RPC) Attach

func (r *RPC) Attach() (*rpc.Client, error)

func (*RPC) GetApis

func (r *RPC) GetApis(apiModule ...string) []rpc.API

func (*RPC) GetHttpApis

func (r *RPC) GetHttpApis() []rpc.API

Http apis

func (*RPC) GetInProcessApis

func (r *RPC) GetInProcessApis() []rpc.API

In-proc apis

func (*RPC) GetIpcApis

func (r *RPC) GetIpcApis() []rpc.API

Ipc apis

func (*RPC) GetPublicApis

func (r *RPC) GetPublicApis() []rpc.API

func (*RPC) GetWSApis

func (r *RPC) GetWSApis() []rpc.API

WS apis

func (*RPC) StartHTTPEndpoint

func (r *RPC) StartHTTPEndpoint(endpoint string, apis []rpc.API, modules []string, cors []string, vhosts []string, timeouts rpc.HTTPTimeouts) (net.Listener, *rpc.Server, error)

StartHTTPEndpoint starts the HTTP RPC endpoint, configured with cors/vhosts/modules

func (*RPC) StartRPC

func (r *RPC) StartRPC() error

func (*RPC) StartWSEndpoint

func (r *RPC) StartWSEndpoint(endpoint string, apis []rpc.API, modules []string, wsOrigins []string, exposeAll bool) (net.Listener, *rpc.Server, error)

StartWSEndpoint starts a websocket endpoint

func (*RPC) StopRPC

func (r *RPC) StopRPC()