server

type ConnConfig struct {
	network.Config

	Kleepalive int32
	Pool       RpcPool
}

type ConnConfigOption func(config *ConnConfig)

type RpcClient interface {
	ClientID() *network.ClientID
	Register(key interface{}, f func(*RpcClientContext) (protoreflect.ProtoMessage, error))
	Accept(ctx network.Context)
	Ping(ctx network.Context)
	Recvice(ctx network.Context)
	Closed(ctx network.Context)
	Destory()
	// contains filtered or unexported methods
}

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

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

type RpcPool interface {
	Get() RpcClient
	Put(s RpcClient)
}

type RpcServer struct {
	*network.NetworkSystem
	// contains filtered or unexported fields
}