gorpc

Nov 13, 2023

Changes in this version

+ var ErrConnInit = fmt.Errorf("connection is not initilized")

Sep 8, 2023

Changes in this version

type RPCServerOption

+ func WithServerFinalizer(m adapter.ServerFinalizer) RPCServerOption

+ func WithServerMiddleware(m adapter.ServerMiddleware) RPCServerOption

Sep 8, 2023

Changes in this version

+ var ErrCertError = fmt.Errorf("cert error")

+ var ErrCleaned = fmt.Errorf("connection has been cleaned")

+ var ErrConnect = fmt.Errorf("fail to connect to the target address")

+ var ErrInitialized = fmt.Errorf("fail to initilize the connection pool")

+ var ErrNoServer = fmt.Errorf("no rpc server")

+ func DefaultDialerFunc(address string) adapter.DialerFunc

+ func DefaultTLSDialerFunc(address string, c *tls.Config) adapter.DialerFunc

+ func IsCertError(err error) bool

+ func IsRPCServerError(err error) bool

+ func NewGoRPCClient(address string, opts ...RPCClientOption) (adapter.Client, error)

+ func NewGoRPCServer(opts ...RPCServerOption) adapter.Server

+ type GoRPCClient struct

+ func (g *GoRPCClient) Call(serviceMethod string, args any, reply any) (err error)

+ func (g *GoRPCClient) CallWithConn(conn io.ReadWriteCloser, serviceMethod string, args any, reply any) error

+ func (g *GoRPCClient) Close() error

+ func (g *GoRPCClient) SetDialer(dialer adapter.DialerFunc)

+ func (g *GoRPCClient) SetRPCServer(address string) error

+ type GoRPCServer struct

+ func (s *GoRPCServer) Accept(l net.Listener)

+ func (s *GoRPCServer) AddCert(cert []byte)

+ func (s *GoRPCServer) ServeConn(conn io.ReadWriteCloser)

+ type PoolOptions func(*connPool)

+ type RPCClientOption func(*GoRPCClient)

+ func WithCACert(cert []byte) RPCClientOption

+ func WithClientCert(cert tls.Certificate) RPCClientOption

+ func WithClientDialer(dialer adapter.DialerFunc) RPCClientOption

+ func WithClientTLSConfig(c *tls.Config) RPCClientOption

+ func WithTLSFail(f func()) RPCClientOption

+ type RPCServerOption func(*GoRPCServer)

+ func WithClientCA(cert []byte) RPCServerOption

+ func WithServerCert(cert tls.Certificate) RPCServerOption

+ func WithTLSConfig(c *tls.Config) RPCServerOption