Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Start action.Action = func(topCtx context.Context) error { l := logger.WithField("func", "Start") l.Info("starting") ctx, cancel := context.WithCancel(topCtx) uptrace.ConfigureOpentelemetry( uptrace.WithServiceName(viper.GetString(config.Keys.ApplicationName)), uptrace.WithServiceVersion(viper.GetString(config.Keys.SoftwareVersion)), ) defer func() { l.Info("closing uptrace") err := uptrace.Shutdown(context.Background()) if err != nil { l.Errorf("closing uptrace: %s", err.Error()) } }() l.Debug("creating clock") clockMod := clock.NewClock() l.Debug("creating database client") dbClient, err := bun.New(ctx) if err != nil { l.Errorf("db: %s", err.Error()) cancel() return err } dbCacheClient, err := cachemem.New(ctx, dbClient) if err != nil { l.Errorf("db: %s", err.Error()) cancel() return err } defer func() { err := dbCacheClient.Close(ctx) if err != nil { l.Errorf("closing db: %s", err.Error()) } }() httpClient, err := http.NewClient(ctx) if err != nil { l.Errorf("http client: %s", err.Error()) cancel() return err } kvClient, err := redis.New(ctx) if err != nil { l.Errorf("redis: %s", err.Error()) cancel() return err } defer func() { err := kvClient.Close(ctx) if err != nil { l.Errorf("closing redis: %s", err.Error()) } }() languageMod, err := language.New() if err != nil { l.Errorf("language: %s", err.Error()) cancel() return err } tokz, err := token.New() if err != nil { l.Errorf("create tokenizer: %s", err.Error()) cancel() return err } l.Debug("creating logic module") logicMod, err := logic1.New(ctx, clockMod, dbCacheClient, httpClient, kvClient, tokz) if err != nil { l.Errorf("logic: %s", err.Error()) cancel() return err } fediMod, err := fedi.New(dbCacheClient, logicMod.Transport(), kvClient, tokz) if err != nil { l.Errorf("fedi: %s", err.Error()) cancel() return err } logicMod.SetFedi(fediMod) notifier, err := newNotifier(logicMod) if err != nil { l.Errorf("notifier: %s", err.Error()) cancel() return err } logicMod.SetNotifier(notifier) runnerMod, err := faktory.New(logicMod) if err != nil { l.Errorf("runner: %s", err.Error()) cancel() return err } logicMod.SetRunner(runnerMod) runnerMod.Start(ctx) schedulerMod, err := scheduler.New(logicMod, runnerMod) if err != nil { l.Errorf("scheduler: %s", err.Error()) cancel() return err } logicMod.SetScheduler(schedulerMod) l.Debug("creating http server") server, err := newHttpServer( ctx, dbCacheClient, fediMod, languageMod, logicMod, kvClient.RedisClient(), runnerMod, tokz, ) if err != nil { l.Errorf("http server: %s", err.Error()) cancel() return err } errChan := make(chan error) stopSigChan := make(chan os.Signal) signal.Notify(stopSigChan, syscall.SIGINT, syscall.SIGTERM) go func(s *scheduler.Module, errChan chan error) { l.Debug("starting scheduler server") s.Start() errChan <- errors.New("scheduler stopped") }(schedulerMod, errChan) go func(s *http.Server, errChan chan error) { l.Debug("starting http server") err := s.Start() if err != nil { errChan <- fmt.Errorf("http server: %s", err.Error()) } }(server, errChan) select { case sig := <-stopSigChan: l.Infof("got sig: %s", sig) cancel() case err := <-errChan: l.Fatal(err.Error()) cancel() } <-ctx.Done() l.Infof("done") return nil }
Start starts the server
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.