overflow_probe_container/server/server.go

package server

import (
	crpj "git.loafle.net/commons_go/rpc/protocol/json"
	crr "git.loafle.net/commons_go/rpc/registry"
	"git.loafle.net/commons_go/server"
)

func New(addr string, serverName string, rpcInvoker crr.RPCInvoker) server.Server {
	rpcSH := newRPCServletHandler(rpcInvoker)
	rpcSH.RegisterCodec(crpj.Name, crpj.NewServerCodec())

	socketHandler := newSocketHandler(rpcSH)

	sh := newServerHandler(addr, serverName, socketHandler)
	s := server.New(sh)

	return s
}