Documentation
¶
Index ¶
- type App
- func (s *App) GetConfig(w http.ResponseWriter, r *http.Request)
- func (s *App) GetConfigTune(w http.ResponseWriter, r *http.Request)
- func (s *App) Load(w http.ResponseWriter, r *http.Request)
- func (s *App) Route(r chi.Router)
- func (s *App) Status() string
- func (s *App) UpdateConfig(w http.ResponseWriter, r *http.Request)
- func (s *App) UpdateConfigTune(w http.ResponseWriter, r *http.Request)
- type ConfigTune
- type UpdateConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
func (*App) GetConfigTune ¶
func (s *App) GetConfigTune(w http.ResponseWriter, r *http.Request)
GetConfigTune 获取 RocketMQ 配置调整参数
func (*App) UpdateConfig ¶
func (s *App) UpdateConfig(w http.ResponseWriter, r *http.Request)
func (*App) UpdateConfigTune ¶
func (s *App) UpdateConfigTune(w http.ResponseWriter, r *http.Request)
UpdateConfigTune 更新 RocketMQ 配置调整参数
type ConfigTune ¶
type ConfigTune struct {
// Broker 基础
BrokerName string `form:"broker_name" json:"broker_name"` // brokerName
ListenPort string `form:"listen_port" json:"listen_port" validate:"number && min:1 && max:65535"` // listenPort
NamesrvAddr string `form:"namesrv_addr" json:"namesrv_addr"` // namesrvAddr
BrokerRole string `form:"broker_role" json:"broker_role" validate:"in:ASYNC_MASTER,SYNC_MASTER,SLAVE"` // brokerRole
FlushDiskType string `form:"flush_disk_type" json:"flush_disk_type" validate:"in:ASYNC_FLUSH,SYNC_FLUSH"` // flushDiskType
// 存储
StorePathRootDir string `form:"store_path_root_dir" json:"store_path_root_dir" validate:"unix_path"` // storePathRootDir
StorePathCommitLog string `form:"store_path_commit_log" json:"store_path_commit_log" validate:"unix_path"` // storePathCommitLog
MaxMessageSize string `form:"max_message_size" json:"max_message_size" validate:"number"` // maxMessageSize
// JVM - NameServer
NamesrvHeapInitSize string `form:"namesrv_heap_init_size" json:"namesrv_heap_init_size"` // -Xms (namesrv)
NamesrvHeapMaxSize string `form:"namesrv_heap_max_size" json:"namesrv_heap_max_size"` // -Xmx (namesrv)
// JVM - Broker
BrokerHeapInitSize string `form:"broker_heap_init_size" json:"broker_heap_init_size"` // -Xms (broker)
BrokerHeapMaxSize string `form:"broker_heap_max_size" json:"broker_heap_max_size"` // -Xmx (broker)
}
ConfigTune RocketMQ 配置调整
type UpdateConfig ¶
type UpdateConfig struct {
Config string `form:"config" json:"config" validate:"required"`
}
UpdateConfig RocketMQ 配置更新
Click to show internal directories.
Click to hide internal directories.