rpcx

package module

Go to main page

Versions in this module

v1

v1.2.0

Jun 1, 2017

Changes in this version

+ var ErrWrongServiceMethod = NewRPCError("? is not allowed in service method name):%s")

+ var IP4Reg = regexp.MustCompile(...)

+ func NewCompressConn(conn net.Conn, compressType CompressType) net.Conn

+ func NewDirectKCPRPCClient(c *Client, clientCodecFunc ClientCodecFunc, network, address string, ...) (*core.Client, error)

+ func ServeByMux(ln net.Listener, mux *http.ServeMux)

+ type ArgsContext interface

+ SetValue func(key string, value interface{})

+ Value func(key string) interface{}

type AuthorizationAndServiceMethod

+ func (aasm *AuthorizationAndServiceMethod) String() string

type Client

+ Block kcp.BlockCrypt

type ClientPluginContainer

+ func (p *ClientPluginContainer) DoPostCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

+ func (p *ClientPluginContainer) DoPostConnected(conn net.Conn) (net.Conn, bool)

+ func (p *ClientPluginContainer) DoPreCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

type ClientSelector

+ HandleFailedClient func(client *core.Client)

+ type CompressConn struct

+ func (c *CompressConn) Read(b []byte) (n int, err error)

+ func (c *CompressConn) Write(b []byte) (n int, err error)

+ type CompressType byte

+ const CompressFlate

+ const CompressLZ4

+ const CompressNone

+ const CompressSnappy

+ const CompressZstd

type DirectClientSelector

+ func (s *DirectClientSelector) HandleFailedClient(client *core.Client)

type IClientPluginContainer

+ DoPostCall func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

+ DoPostConnected func(net.Conn) (net.Conn, bool)

+ DoPreCall func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

+ type IPostCallPlugin interface

+ DoPostCall func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

+ type IPostConnectedPlugin interface

+ HandleConnected func(net.Conn) (net.Conn, bool)

+ type IPreCallPlugin interface

+ DoPreCall func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

type SelectMode

+ const Closest

+ const WeightedICMP

type Server

+ func (s *Server) ServeByMux(ln net.Listener, rpcPath string, mux *http.ServeMux)

v1.1.0

Sep 18, 2016

Changes in this version

+ const DefaultRPCPath

+ var ErrPluginActivate = NewRPCError("While trying to activate plugin '%s'. Trace: %s")

+ var ErrPluginAlreadyExists = NewRPCError("Cannot use the same plugin again, '%s[%s]' is already exists")

+ var ErrPluginRemoveEmptyName = NewRPCError("Plugin with an empty name cannot be removed")

+ var ErrPluginRemoveNoPlugins = NewRPCError("No plugins are registed yet, you cannot remove a plugin from an empty list!")

+ var ErrPluginRemoveNotFound = NewRPCError("Cannot remove a plugin which doesn't exists")

+ func Auth(fn AuthorizationFunc) error

+ func Close() error

+ func GetListenedAddress() string

+ func NewDirectHTTPRPCClient(c *Client, clientCodecFunc ClientCodecFunc, network, address string, ...) (*rpc.Client, error)

+ func NewDirectRPCClient(c *Client, clientCodecFunc ClientCodecFunc, network, address string, ...) (*rpc.Client, error)

+ func RegisterName(name string, service interface{})

+ func Serve(n, address string)

+ func ServeByHTTP(ln net.Listener, rpcPath, debugPath string)

+ func ServeListener(ln net.Listener)

+ func ServeTLS(n, address string, config *tls.Config)

+ func SetServerCodecFunc(fn ServerCodecFunc)

+ func Start(n, address string)

+ func StartTLS(n, address string, config *tls.Config)

+ type AuthorizationAndServiceMethod struct

+ Authorization string

+ ServiceMethod string

+ Tag string

+ type AuthorizationClientPlugin struct

+ AuthorizationAndServiceMethod *AuthorizationAndServiceMethod

+ func NewAuthorizationClientPlugin(authorization, tag string) *AuthorizationClientPlugin

+ func (plugin *AuthorizationClientPlugin) Description() string

+ func (plugin *AuthorizationClientPlugin) Name() string

+ func (plugin *AuthorizationClientPlugin) PreWriteRequest(r *rpc.Request, body interface{}) error

+ type AuthorizationFunc func(p *AuthorizationAndServiceMethod) error

+ type AuthorizationServerPlugin struct

+ AuthorizationFunc AuthorizationFunc

+ func (plugin *AuthorizationServerPlugin) Description() string

+ func (plugin *AuthorizationServerPlugin) Name() string

+ func (plugin *AuthorizationServerPlugin) PostReadRequestHeader(r *rpc.Request) (err error)

+ type Client struct

+ ClientCodecFunc ClientCodecFunc

+ ClientSelector ClientSelector

+ FailMode FailMode

+ PluginContainer IClientPluginContainer

+ ReadTimeout time.Duration

+ Retries int

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ WriteTimeout time.Duration

+ func NewClient(s ClientSelector) *Client

+ func (c *Client) Auth(authorization, tag string) error

+ func (c *Client) Call(serviceMethod string, args interface{}, reply interface{}) (err error)

+ func (c *Client) Close() error

+ func (c *Client) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call

+ type ClientCodecFunc func(conn io.ReadWriteCloser) rpc.ClientCodec

+ type ClientPluginContainer struct

+ func (p *ClientPluginContainer) Add(plugin IPlugin) error

+ func (p *ClientPluginContainer) DoPostReadResponseBody(body interface{}) error

+ func (p *ClientPluginContainer) DoPostReadResponseHeader(r *rpc.Response) error

+ func (p *ClientPluginContainer) DoPostWriteRequest(r *rpc.Request, body interface{}) error

+ func (p *ClientPluginContainer) DoPreReadResponseBody(body interface{}) error

+ func (p *ClientPluginContainer) DoPreReadResponseHeader(r *rpc.Response) error

+ func (p *ClientPluginContainer) DoPreWriteRequest(r *rpc.Request, body interface{}) error

+ func (p *ClientPluginContainer) GetAll() []IPlugin

+ func (p *ClientPluginContainer) GetByName(pluginName string) IPlugin

+ func (p *ClientPluginContainer) GetDescription(plugin IPlugin) string

+ func (p *ClientPluginContainer) GetName(plugin IPlugin) string

+ func (p *ClientPluginContainer) Remove(pluginName string) error

+ type ClientSelector interface

+ AllClients func(clientCodecFunc ClientCodecFunc) []*rpc.Client

+ Select func(clientCodecFunc ClientCodecFunc, options ...interface{}) (*rpc.Client, error)

+ SetClient func(*Client)

+ SetSelectMode func(SelectMode)

+ type DirectClientSelector struct

+ Address string

+ Client *Client

+ DialTimeout time.Duration

+ Network string

+ func (s *DirectClientSelector) AllClients(clientCodecFunc ClientCodecFunc) []*rpc.Client

+ func (s *DirectClientSelector) Select(clientCodecFunc ClientCodecFunc, options ...interface{}) (*rpc.Client, error)

+ func (s *DirectClientSelector) SetClient(c *Client)

+ func (s *DirectClientSelector) SetSelectMode(sm SelectMode)

+ type FailMode int

+ const Broadcast

+ const Failfast

+ const Failover

+ const Failtry

+ const Forking

+ type IClientPluginContainer interface

+ Add func(plugin IPlugin) error

+ DoPostReadResponseBody func(interface{}) error

+ DoPostReadResponseHeader func(*rpc.Response) error

+ DoPostWriteRequest func(*rpc.Request, interface{}) error

+ DoPreReadResponseBody func(interface{}) error

+ DoPreReadResponseHeader func(*rpc.Response) error

+ DoPreWriteRequest func(*rpc.Request, interface{}) error

+ GetAll func() []IPlugin

+ GetByName func(pluginName string) IPlugin

+ GetDescription func(plugin IPlugin) string

+ GetName func(plugin IPlugin) string

+ Remove func(pluginName string) error

+ type IPlugin interface

+ Description func() string

+ Name func() string

+ type IPostConnAcceptPlugin interface

+ HandleConnAccept func(net.Conn) bool

+ type IPostReadRequestBodyPlugin interface

+ PostReadRequestBody func(body interface{}) error

+ type IPostReadRequestHeaderPlugin interface

+ PostReadRequestHeader func(r *rpc.Request) error

+ type IPostReadResponseBodyPlugin interface

+ PostReadResponseBody func(interface{}) error

+ type IPostReadResponseHeaderPlugin interface

+ PostReadResponseHeader func(*rpc.Response) error

+ type IPostWriteRequestPlugin interface

+ PostWriteRequest func(*rpc.Request, interface{}) error

+ type IPostWriteResponsePlugin interface

+ PostWriteResponse func(*rpc.Response, interface{}) error

+ type IPreReadRequestBodyPlugin interface

+ PreReadRequestBody func(body interface{}) error

+ type IPreReadRequestHeaderPlugin interface

+ PreReadRequestHeader func(r *rpc.Request) error

+ type IPreReadResponseBodyPlugin interface

+ PreReadResponseBody func(interface{}) error

+ type IPreReadResponseHeaderPlugin interface

+ PreReadResponseHeader func(*rpc.Response) error

+ type IPreWriteRequestPlugin interface

+ PreWriteRequest func(*rpc.Request, interface{}) error

+ type IPreWriteResponsePlugin interface

+ PreWriteResponse func(*rpc.Response, interface{}) error

+ type IRegisterPlugin interface

+ Register func(name string, rcvr interface{}, metadata ...string) error

+ type IServerCodecPlugin interface

+ type IServerPluginContainer interface

+ Add func(plugin IPlugin) error

+ DoPostConnAccept func(net.Conn) bool

+ DoPostReadRequestBody func(body interface{}) error

+ DoPostReadRequestHeader func(r *rpc.Request) error

+ DoPostWriteResponse func(*rpc.Response, interface{}) error

+ DoPreReadRequestBody func(body interface{}) error

+ DoPreReadRequestHeader func(r *rpc.Request) error

+ DoPreWriteResponse func(*rpc.Response, interface{}) error

+ DoRegister func(name string, rcvr interface{}, metadata ...string) error

+ GetAll func() []IPlugin

+ GetByName func(pluginName string) IPlugin

+ GetDescription func(plugin IPlugin) string

+ GetName func(plugin IPlugin) string

+ Remove func(pluginName string) error

+ func GetPluginContainer() IServerPluginContainer

+ type MultiError struct

+ Errors []error

+ func NewMultiError(errors []error) *MultiError

+ func (e *MultiError) Error() string

+ type RPCError struct

+ func NewRPCError(errMsg string) *RPCError

+ func (e *RPCError) Error() string

+ func (e *RPCError) Format(args ...interface{}) error

+ func (e *RPCError) Panic()

+ func (e *RPCError) Panicf(args ...interface{})

+ func (e *RPCError) Return() error

+ func (e *RPCError) With(err error) error

+ type SelectMode int

+ const ConsistentHash

+ const LeastActive

+ const RandomSelect

+ const RoundRobin

+ const WeightedRoundRobin

+ func (s SelectMode) String() string

+ type Server struct

+ Metadata string

+ PluginContainer IServerPluginContainer

+ ReadTimeout time.Duration

+ ServerCodecFunc ServerCodecFunc

+ Timeout time.Duration

+ WriteTimeout time.Duration

+ func NewServer() *Server

+ func (s *Server) Address() string

+ func (s *Server) Auth(fn AuthorizationFunc) error

+ func (s *Server) Close() error

+ func (s *Server) RegisterName(name string, service interface{}, metadata ...string)

+ func (s *Server) Serve(network, address string)

+ func (s *Server) ServeByHTTP(ln net.Listener, rpcPath string)

+ func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (s *Server) ServeListener(ln net.Listener)

+ func (s *Server) ServeTLS(network, address string, config *tls.Config)

+ func (s *Server) Start(network, address string)

+ func (s *Server) StartTLS(network, address string, config *tls.Config)

+ type ServerCodecFunc func(conn io.ReadWriteCloser) rpc.ServerCodec

+ type ServerPluginContainer struct

+ func (p *ServerPluginContainer) Add(plugin IPlugin) error

+ func (p *ServerPluginContainer) DoPostConnAccept(conn net.Conn) bool

+ func (p *ServerPluginContainer) DoPostReadRequestBody(body interface{}) error

+ func (p *ServerPluginContainer) DoPostReadRequestHeader(r *rpc.Request) error

+ func (p *ServerPluginContainer) DoPostWriteResponse(resp *rpc.Response, body interface{}) error

+ func (p *ServerPluginContainer) DoPreReadRequestBody(body interface{}) error

+ func (p *ServerPluginContainer) DoPreReadRequestHeader(r *rpc.Request) error

+ func (p *ServerPluginContainer) DoPreWriteResponse(resp *rpc.Response, body interface{}) error

+ func (p *ServerPluginContainer) DoRegister(name string, rcvr interface{}, metadata ...string) error

+ func (p *ServerPluginContainer) GetAll() []IPlugin

+ func (p *ServerPluginContainer) GetByName(pluginName string) IPlugin

+ func (p *ServerPluginContainer) GetDescription(plugin IPlugin) string

+ func (p *ServerPluginContainer) GetName(plugin IPlugin) string

+ func (p *ServerPluginContainer) Remove(pluginName string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL