rocketmq

package
v3.2.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 3, 2026 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation

Index

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 NewApp

func NewApp(t *gotext.Locale) *App

func (*App) GetConfig

func (s *App) GetConfig(w http.ResponseWriter, r *http.Request)

func (*App) GetConfigTune

func (s *App) GetConfigTune(w http.ResponseWriter, r *http.Request)

GetConfigTune 获取 RocketMQ 配置调整参数

func (*App) Load

func (s *App) Load(w http.ResponseWriter, r *http.Request)

func (*App) Route

func (s *App) Route(r chi.Router)

func (*App) Status added in v3.2.2

func (s *App) Status() string

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 配置更新

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL