syscontrol

package
v1.5.1 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DataFlush         = "flush"
	DownSampleInOrder = "downsample_in_order"

	ChunkReaderParallel = "chunk_reader_parallel"
	BinaryTreeMerge     = "binary_tree_merge"
	PrintLogicalPlan    = "print_logical_plan"
	SlidingWindowPushUp = "sliding_window_push_up"
	ForceBroadcastQuery = "force_broadcast_query"
	Failpoint           = "failpoint"
	NodeReadonly        = "readonly"
	LogRows             = "log_rows"

	TimeFilterProtection = "time_filter_protection"

	BackgroundReadLimiter = "backgroundReadLimiter"

	NodeInterruptQuery = "interruptquery"
	UpperMemUsePct     = "uppermemusepct"
	ParallelQuery      = "parallelbatch"
	Backup             = "backup"
	AbortBackup        = "abort_backup"
	BackupStatus       = "backup_status"

	WriteStreamPointsEnable = "write_stream_points_enable"
	DBLimit                 = "db_num_limit"

	ObsAkSk            = "obsaksk"
	ObsHostName        = "obshostname"
	ShardGroupTimeZone = "shard_group_timezone"

	LastRowCache = "last_row_cache"
)
View Source 
const (
	LastRowCacheEnable        = "last-row-cache-enabled"
	LastRowCacheMetricsEnable = "last-row-cache-metrics-enabled"
	LastRowCacheMaxCost       = "last-row-cache-max-cost"
)
View Source 
const (
	ParquetTask               = "parquet_task"
	ParquetLevel              = "tssp-to-parquet-level"
	ParquetGroupLen           = "max-group-len"
	ParquetPageSize           = "page-size"
	ParquetBatchSize          = "write-batch-size"
	ParquetItrSize            = "itr-batch-size"
	ParquetDictCompressEnable = "dict-compress-enable"
	ParquetCompressAlg        = "compress-alg"
	ParquetEnableMst          = "enable-mst"
	ParquetMaxStatsSize       = "max-stats-size"
)
View Source 
const (
	QueryShardStatus queryRequestMod = "queryShardStatus"
)

Variables

View Source 
var (
	QueryParallel int32 = -1

	DisableReads  = false
	DisableWrites = false

	ParallelQueryInBatch int32 = 0 // this determines whether to use parallel query when a query is combined with multi queries

	Readonly = false

	HierarchicalStorageEnabled int32 = 0

	HierarchicalIndexStorageEnabled int32 = 0

	WriteColdShardEnable int32 = 0

	DatabaseNumLimit int32 = 0
)
View Source 
var (
	LogRowsRuleSwitch int32 // 0: disable, 1: enable
	MuLogRowsRule     sync.RWMutex
	MyLogRowsRule     = &LogRowsRule{
		Mst: "",
	}
)
View Source 
var (
	ErrNoSuchParam = fmt.Errorf("no parameter found")
)

Functions

func CheckUpdateAsSkParamValid added in v1.5.0 

func CheckUpdateAsSkParamValid(params map[string]string) error

func CheckUpdateParquetTaskParamValid added in v1.5.0 

func CheckUpdateParquetTaskParamValid(params map[string]string) error

func CheckUpdateStreamConfParamValid added in v1.5.0 

func CheckUpdateStreamConfParamValid(params map[string]string) error

func GetBoolValue added in v1.0.0 

func GetBoolValue(param map[string]string, key string) (bool, error)

func GetBytesValue added in v1.1.0 

func GetBytesValue(param map[string]string, key string) (int64, error)

func GetDurationValue added in v1.0.0 

func GetDurationValue(param map[string]string, key string) (time.Duration, error)

func GetIntValue added in v1.0.0 

func GetIntValue(param map[string]string, key string) (int64, error)

func GetQueryEnabledWhenExceedSeries added in v1.1.0 

func GetQueryEnabledWhenExceedSeries() bool

func GetQuerySeriesLimit added in v1.0.0 

func GetQuerySeriesLimit() int

func GetTimeFilterProtection added in v1.1.0 

func GetTimeFilterProtection() bool

func IsHierarchicalIndexStorageEnabled added in v1.5.0 

func IsHierarchicalIndexStorageEnabled() bool

func IsHierarchicalStorageEnabled added in v1.2.0 

func IsHierarchicalStorageEnabled() bool

func IsIndexReadCachePersistent added in v1.2.0 

func IsIndexReadCachePersistent() bool

func IsReadonly added in v1.1.1 

func IsReadonly() bool

func IsWriteColdShardEnabled added in v1.2.0 

func IsWriteColdShardEnabled() bool

func ProcessBackup added in v1.3.0 

func ProcessBackup(req msgservice.SysCtrlRequest, resp *bufio.Writer, sqlHost []string) (err error)

func ProcessQueryRequest added in v1.1.0 

func ProcessQueryRequest(mod queryRequestMod, param map[string]string) (string, error)

ProcessQueryRequest only process get method

func ProcessRequest 

func ProcessRequest(req msgservice.SysCtrlRequest, resp *bufio.Writer) (err error)

func SetDatabaselimit added in v1.5.0 

func SetDatabaselimit(limit int32)

func SetDisableRead added in v1.1.0 

func SetDisableRead(en bool)

func SetDisableWrite added in v1.1.0 

func SetDisableWrite(en bool)

func SetHierarchicalStorageEnabled added in v1.2.0 

func SetHierarchicalStorageEnabled(en bool)

func SetIndexHierarchicalStorageEnabled added in v1.5.0 

func SetIndexHierarchicalStorageEnabled(en bool)

func SetIndexReadCachePersistent added in v1.2.0 

func SetIndexReadCachePersistent(persist bool)

func SetLogRowsRuleSwitch 

func SetLogRowsRuleSwitch(switchon bool, rules string) error

func SetParallelQueryInBatch added in v1.1.0 

func SetParallelQueryInBatch(en bool)

func SetQueryEnabledWhenExceedSeries added in v1.1.0 

func SetQueryEnabledWhenExceedSeries(enabled bool)

func SetQueryParallel 

func SetQueryParallel(limit int64)

func SetQuerySchemaLimit added in v1.1.0 

func SetQuerySchemaLimit(limit int)

func SetQuerySeriesLimit added in v1.0.0 

func SetQuerySeriesLimit(limit int)

func SetTimeFilterProtection added in v1.1.0 

func SetTimeFilterProtection(enabled bool)

func SetWriteColdShardEnabled added in v1.2.0 

func SetWriteColdShardEnabled(en bool)

func UpdateNodeReadonly added in v1.1.1 

func UpdateNodeReadonly(switchOn bool)

func WriteString added in v1.5.0 

func WriteString(w *bufio.Writer, content string)

Types

type LogRowsRule 

type LogRowsRule struct {
	Mst  string
	Tags map[string]string
}

type SysControl 

type SysControl struct {
	MetaClient meta.MetaClient
}
var SysCtrl *SysControl

func NewSysControl 

func NewSysControl() *SysControl

func (*SysControl) SendQueryRequestOnNode added in v1.5.0 

func (s *SysControl) SendQueryRequestOnNode(nodeID uint64, req msgservice.SysCtrlRequest) (map[string]string, error)

func (*SysControl) SendSysCtrlOnNode added in v1.5.0 

func (s *SysControl) SendSysCtrlOnNode(nodeID uint64, req msgservice.SysCtrlRequest) (map[string]string, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.