Function newRPCServer

ethstorage/node/server.go:31–62

(
	ctx context.Context,
	rpcCfg *RPCConfig,
	chainId *big.Int,
	sm *ethstorage.StorageManager,
	dl *downloader.Downloader,
	lg log.Logger,
	appVersion string,
)

}

func newRPCServer(
	ctx context.Context,
	rpcCfg *RPCConfig,
	chainId *big.Int,
	sm *ethstorage.StorageManager,
	dl *downloader.Downloader,
	lg log.Logger,
	appVersion string,
) (*rpcServer, error) {
	esAPI := NewESAPI(rpcCfg, sm, dl, lg)
	ethApi := NewETHAPI(rpcCfg, chainId, lg)

	endpoint := net.JoinHostPort(rpcCfg.ListenAddr, strconv.Itoa(rpcCfg.ListenPort))
	r := &rpcServer{
		endpoint: endpoint,
		apis: []rpc.API{
			{
				Namespace:     "es",
				Service:       esAPI,
				Authenticated: false,
			},
			{
				Namespace:     "eth",
				Service:       ethApi,
				Authenticated: false,
			},
		},
		appVersion: appVersion,
		lg:         lg,
	}
	return r, nil
}

func (s *rpcServer) Start() error {
	srv := rpc.NewServer()