From 36ea77baa5a41de10bd604cd0e5b5b3cafaaeb64 Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Sun, 3 Jun 2018 12:54:43 +0300 Subject: service bus, http service, rpc bus, cli commands, new configs --- service/rpc.go | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 service/rpc.go (limited to 'service/rpc.go') diff --git a/service/rpc.go b/service/rpc.go new file mode 100644 index 00000000..eb128768 --- /dev/null +++ b/service/rpc.go @@ -0,0 +1,32 @@ +package service + +import ( + "net" + "strings" +) + +type RPCConfig struct { + Listen string +} + +func (cfg *RPCConfig) CreateListener() (net.Listener, error) { + dsn := strings.Split(cfg.Listen, "://") + if len(dsn) != 2 { + return nil, dsnError + } + + return net.Listen(dsn[0], dsn[1]) +} + +func (cfg *RPCConfig) CreateDialer() (net.Conn, error) { + dsn := strings.Split(cfg.Listen, "://") + if len(dsn) != 2 { + return nil, dsnError + } + + return net.Dial(dsn[0], dsn[1]) +} + +func NewBus() *Bus { + return &Bus{services: make([]Service, 0)} +} -- cgit v1.2.3