main.go 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. package main
  2. import (
  3. "github.com/joho/godotenv"
  4. "github.com/kelseyhightower/envconfig"
  5. "github.com/langgenius/dify-plugin-daemon/internal/server"
  6. "github.com/langgenius/dify-plugin-daemon/internal/types/app"
  7. "github.com/langgenius/dify-plugin-daemon/internal/utils/log"
  8. "golang.org/x/exp/constraints"
  9. )
  10. func main() {
  11. var config app.Config
  12. err := godotenv.Load()
  13. if err != nil {
  14. log.Panic("Error loading .env file")
  15. }
  16. err = envconfig.Process("", &config)
  17. if err != nil {
  18. log.Panic("Error processing environment variables")
  19. }
  20. setDefault(&config)
  21. if err := config.Validate(); err != nil {
  22. log.Panic("Invalid configuration: %s", err.Error())
  23. }
  24. server.Run(&config)
  25. }
  26. func setDefault(config *app.Config) {
  27. setDefaultInt(&config.ServerPort, 5002)
  28. setDefaultInt(&config.RoutinePoolSize, 1000)
  29. setDefaultInt(&config.LifetimeCollectionGCInterval, 60)
  30. setDefaultInt(&config.LifetimeCollectionHeartbeatInterval, 5)
  31. setDefaultInt(&config.LifetimeStateGCInterval, 300)
  32. setDefaultInt(&config.DifyInvocationConnectionIdleTimeout, 120)
  33. setDefaultInt(&config.PluginRemoteInstallServerEventLoopNums, 8)
  34. setDefaultInt(&config.PluginRemoteInstallingMaxConn, 128)
  35. settDefaultBool(&config.PluginRemoteInstallingEnabled, true)
  36. settDefaultString(&config.DBSslMode, "disable")
  37. settDefaultString(&config.ProcessCachingPath, "/tmp/dify-plugin-daemon-subprocesses")
  38. }
  39. func setDefaultInt[T constraints.Integer](value *T, defaultValue T) {
  40. if *value == 0 {
  41. *value = defaultValue
  42. }
  43. }
  44. func settDefaultString(value *string, defaultValue string) {
  45. if *value == "" {
  46. *value = defaultValue
  47. }
  48. }
  49. func settDefaultBool(value *bool, defaultValue bool) {
  50. if !*value {
  51. *value = defaultValue
  52. }
  53. }