rs

Documentation

Index

• Variables
• type ClientRpcContext
  • func (rpc *ClientRpcContext) Close() error
  • func (rpc *ClientRpcContext) Receive() (<-chan *api.ServerResponse, <-chan error)
  • func (rpc *ClientRpcContext) Send(resp *api.ServerRequest)
• type ConnManager
  • func (cm *ConnManager) AddConnectEventListener(listener api.ConnectEventListener)
  • func (cm *ConnManager) PutConn(conn *transport.TCPConn)
  • func (cm *ConnManager) RemoveConn(conn *transport.TCPConn)
  • func (cm *ConnManager) RemoveConnectEventListener(listener api.ConnectEventListener)
• type RSocketClient
  • func NewClient(opt api.ClientOption) (*RSocketClient, error)
  • func (c *RSocketClient) AddChain(filter func(req *api.ServerRequest))
  • func (c *RSocketClient) CheckConnection(endpoint api.Endpoint) (bool, error)
  • func (c *RSocketClient) Close() error
  • func (c *RSocketClient) RegisterConnectEventWatcher(watcher func(eventType api.ConnectEventType, conn net.Conn))
  • func (c *RSocketClient) Request(ctx context.Context, endpoint api.Endpoint, req *api.ServerRequest) (*api.ServerResponse, error)
  • func (c *RSocketClient) RequestChannel(ctx context.Context, endpoint api.Endpoint) (api.RpcClientContext, error)
• type RSocketDispatcher
• type RSocketServer
  • func NewServer(ctx context.Context, opt api.ServerOption) *RSocketServer
  • func (rs *RSocketServer) AddConnectEventListener(listener api.ConnectEventListener)
  • func (rs *RSocketServer) RegisterChannelHandler(funName string, handler api.ChannelHandler)
  • func (rs *RSocketServer) RegisterSimpleHandler(funName string, handler api.SimpleHandler)
  • func (rs *RSocketServer) RemoveConnectEventListener(listener api.ConnectEventListener)
• type ServerRpcContext
  • func (rpc *ServerRpcContext) Close() error
  • func (rpc *ServerRpcContext) Complete()
  • func (rpc *ServerRpcContext) GetReq() *api.ServerRequest
  • func (rpc *ServerRpcContext) Send(resp *api.ServerResponse) error

Variables

var ErrorCannotResponse = fmt.Errorf("cann't send reponse to client")

var (
	ErrorNotImplement = errors.New("not implement")
)

Types

type ClientRpcContext

type ClientRpcContext struct {
	// contains filtered or unexported fields
}

ClientRpcContext 客户端侧的 RPC 上下文处理

func (*ClientRpcContext) Close

func (rpc *ClientRpcContext) Close() error

func (*ClientRpcContext) Receive

func (rpc *ClientRpcContext) Receive() (<-chan *api.ServerResponse, <-chan error)

func (*ClientRpcContext) Send

func (rpc *ClientRpcContext) Send(resp *api.ServerRequest)

type ConnManager

type ConnManager struct {
	// contains filtered or unexported fields
}

func (*ConnManager) AddConnectEventListener

func (cm *ConnManager) AddConnectEventListener(listener api.ConnectEventListener)

AddConnectEventListener

func (*ConnManager) PutConn

func (cm *ConnManager) PutConn(conn *transport.TCPConn)

PutConn 添加一个 transport.TCPConn

func (*ConnManager) RemoveConn

func (cm *ConnManager) RemoveConn(conn *transport.TCPConn)

RemoveConn 移除某一个 transport.TCPConn

func (*ConnManager) RemoveConnectEventListener

func (cm *ConnManager) RemoveConnectEventListener(listener api.ConnectEventListener)

RemoveConnectEventListener

type RSocketClient

type RSocketClient struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(opt api.ClientOption) (*RSocketClient, error)

TODO 后续改造成为 Option 的模式

func (*RSocketClient) AddChain

func (c *RSocketClient) AddChain(filter func(req *api.ServerRequest))

func (*RSocketClient) CheckConnection

func (c *RSocketClient) CheckConnection(endpoint api.Endpoint) (bool, error)

func (*RSocketClient) Close

func (c *RSocketClient) Close() error

func (*RSocketClient) RegisterConnectEventWatcher

func (c *RSocketClient) RegisterConnectEventWatcher(watcher func(eventType api.ConnectEventType, conn net.Conn))

func (*RSocketClient) Request

func (c *RSocketClient) Request(ctx context.Context, endpoint api.Endpoint, req *api.ServerRequest) (*api.ServerResponse, error)

func (*RSocketClient) RequestChannel

func (c *RSocketClient) RequestChannel(ctx context.Context, endpoint api.Endpoint) (api.RpcClientContext, error)

type RSocketDispatcher

type RSocketDispatcher struct {
	api.Dispatcher
	// contains filtered or unexported fields
}

type RSocketServer

type RSocketServer struct {
	IsReady chan int8

	ConnMgr *ConnManager
	ErrChan chan error
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, opt api.ServerOption) *RSocketServer

newRSocketServer 创建一个 RSocketServer

func (*RSocketServer) AddConnectEventListener

func (rs *RSocketServer) AddConnectEventListener(listener api.ConnectEventListener)

AddConnectEventListener

func (*RSocketServer) RegisterChannelHandler

func (rs *RSocketServer) RegisterChannelHandler(funName string, handler api.ChannelHandler)

RegisterChannelHandler

func (*RSocketServer) RegisterSimpleHandler

func (rs *RSocketServer) RegisterSimpleHandler(funName string, handler api.SimpleHandler)

RegisterSimpleHandler

func (*RSocketServer) RemoveConnectEventListener

func (rs *RSocketServer) RemoveConnectEventListener(listener api.ConnectEventListener)

RemoveConnectEventListener

type ServerRpcContext

type ServerRpcContext struct {
	// contains filtered or unexported fields
}

func (*ServerRpcContext) Close

func (rpc *ServerRpcContext) Close() error

func (*ServerRpcContext) Complete

func (rpc *ServerRpcContext) Complete()

func (*ServerRpcContext) GetReq

func (rpc *ServerRpcContext) GetReq() *api.ServerRequest

func (*ServerRpcContext) Send

func (rpc *ServerRpcContext) Send(resp *api.ServerResponse) error