Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов 2020-09-07 15:29:43 +03:00
parent 5fe3a46732
commit f1fde75567

View File

@ -63,37 +63,49 @@ func (s *service) Init(opts ...Option) {
); err != nil { ); err != nil {
logger.Fatalf("[cmd] init failed: %v", err) logger.Fatalf("[cmd] init failed: %v", err)
} }
})
if s.opts.Registry != nil {
if err := s.opts.Registry.Init(); err != nil { if err := s.opts.Registry.Init(); err != nil {
logger.Fatalf("[cmd] init failed: %v", err) logger.Fatalf("[cmd] init failed: %v", err)
} }
}
if s.opts.Broker != nil {
if err := s.opts.Broker.Init(); err != nil { if err := s.opts.Broker.Init(); err != nil {
logger.Fatalf("[cmd] init failed: %v", err) logger.Fatalf("[cmd] init failed: %v", err)
} }
}
if s.opts.Transport != nil {
if err := s.opts.Transport.Init(); err != nil { if err := s.opts.Transport.Init(); err != nil {
logger.Fatalf("[cmd] init failed: %v", err) logger.Fatalf("[cmd] init failed: %v", err)
} }
}
if s.opts.Store != nil {
if err := s.opts.Store.Init(); err != nil { if err := s.opts.Store.Init(); err != nil {
logger.Fatalf("[cmd] init failed: %v", err) logger.Fatalf("[cmd] init failed: %v", err)
} }
}
if s.opts.Server != nil {
if err := s.opts.Server.Init(); err != nil { if err := s.opts.Server.Init(); err != nil {
logger.Fatalf("[cmd] init failed: %v", err) logger.Fatalf("[cmd] init failed: %v", err)
} }
}
if s.opts.Client != nil {
if err := s.opts.Client.Init(); err != nil { if err := s.opts.Client.Init(); err != nil {
logger.Fatalf("[cmd] init failed: %v", err) logger.Fatalf("[cmd] init failed: %v", err)
} }
}
// execute the command // execute the command
// TODO: do this in service.Run() // TODO: do this in service.Run()
if err := s.opts.Cmd.Run(); err != nil { if err := s.opts.Cmd.Run(); err != nil {
logger.Fatalf("[cmd] run failed: %v", err) logger.Fatalf("[cmd] run failed: %v", err)
} }
})
} }
func (s *service) Options() Options { func (s *service) Options() Options {