ServerConfig.go 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. // this file is auto create by program, don't edit manually
  2. package data
  3. import (
  4. mhayaError "github.com/mhaya/error"
  5. mhayaLogger "github.com/mhaya/logger"
  6. )
  7. type serverConfig struct {
  8. maps map[int]*ServerConfigRow
  9. }
  10. type ServerConfigRow struct {
  11. ID int // 配置ID
  12. Name string // 配置描述信息
  13. Enable int // 是否启用0否1是
  14. Max int // 服务器最大负载
  15. Expansion int // 扩容指标(到达扩容指标权重降低到1)
  16. Weight WeightInt32 // 权重规则
  17. Range int // 规则标准(均值每100为标准)
  18. }
  19. func (p *serverConfig) Name() string {
  20. return "ServerConfig"
  21. }
  22. func (p *serverConfig) Init() {
  23. p.maps = make(map[int]*ServerConfigRow)
  24. }
  25. func (p *serverConfig) OnLoad(maps interface{}, _ bool) (int, error) {
  26. list, ok := maps.([]interface{})
  27. if !ok {
  28. return 0, mhayaError.Error("maps convert to []interface{} error.")
  29. }
  30. loadMaps := make(map[int]*ServerConfigRow)
  31. for index, data := range list {
  32. loadConfig := &ServerConfigRow{}
  33. err := DecodeData(data, loadConfig)
  34. if err != nil {
  35. mhayaLogger.Warnf("decode error. [row = %d, %v], err = %s", index+1, loadConfig, err)
  36. continue
  37. }
  38. loadMaps[loadConfig.ID] = loadConfig
  39. }
  40. p.maps = loadMaps
  41. return len(list), nil
  42. }
  43. func (p *serverConfig) OnAfterLoad(_ bool) {
  44. }
  45. func (p *serverConfig) Get() (*ServerConfigRow, bool) {
  46. for _, row := range p.maps {
  47. if row.Enable == 1 {
  48. return row, true
  49. }
  50. }
  51. return nil, false
  52. }