overflow_discovery/server/server.go

package server

import (
	crr "git.loafle.net/commons_go/rpc/registry"
	"git.loafle.net/commons_go/server"
	"git.loafle.net/overflow/overflow_discovery/service"
	oopcs "git.loafle.net/overflow/overflow_probe_container/server"
)

func New(addr string) server.Server {
	rpcRegistry := crr.NewRPCRegistry()
	service.RegisterRPC(rpcRegistry)

	rpcSH := oopcs.NewRPCServletHandler(rpcRegistry)
	socketHandler := newSocketHandler(rpcSH)

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

	return s
}
ing 2017-10-26 12:55:55 +00:00			`package server`

			`import (`
ing 2017-12-01 08:29:54 +00:00			`crr "git.loafle.net/commons_go/rpc/registry"`
ing 2017-10-26 12:55:55 +00:00			`"git.loafle.net/commons_go/server"`
ing 2017-12-04 09:37:39 +00:00			`"git.loafle.net/overflow/overflow_discovery/service"`
ing 2017-12-05 05:58:32 +00:00			`oopcs "git.loafle.net/overflow/overflow_probe_container/server"`
ing 2017-10-26 12:55:55 +00:00			`)`

ing 2017-11-15 06:59:43 +00:00			`func New(addr string) server.Server {`
ing 2017-12-01 08:29:54 +00:00			`rpcRegistry := crr.NewRPCRegistry()`
ing 2017-12-04 09:37:39 +00:00			`service.RegisterRPC(rpcRegistry)`
ing 2017-11-15 06:59:43 +00:00
ing 2017-12-05 05:58:32 +00:00			`rpcSH := oopcs.NewRPCServletHandler(rpcRegistry)`
ing 2017-11-29 05:19:36 +00:00			`socketHandler := newSocketHandler(rpcSH)`
ing 2017-10-26 12:55:55 +00:00
ing 2017-11-29 05:19:36 +00:00			`sh := newServerHandler(addr, socketHandler)`
ing 2017-12-05 05:58:32 +00:00			`s := oopcs.New(sh)`
ing 2017-10-26 12:55:55 +00:00
			`return s`
			`}`