syscontrol

Documentation

Index

• Constants
• Variables
• func GetBoolValue(param map[string]string, key string) (bool, error)
• func GetBytesValue(param map[string]string, key string) (int64, error)
• func GetDurationValue(param map[string]string, key string) (time.Duration, error)
• func GetIntValue(param map[string]string, key string) (int64, error)
• func GetQueryEnabledWhenExceedSeries() bool
• func GetQuerySeriesLimit() int
• func GetTimeFilterProtection() bool
• func IsHierarchicalStorageEnabled() bool
• func IsIndexReadCachePersistent() bool
• func IsReadonly() bool
• func IsWriteColdShardEnabled() bool
• func ProcessQueryRequest(mod queryRequestMod, param map[string]string) (string, error)
• func ProcessRequest(req netstorage.SysCtrlRequest, resp *strings.Builder) (err error)
• func SetDisableRead(en bool)
• func SetDisableWrite(en bool)
• func SetHierarchicalStorageEnabled(en bool)
• func SetIndexReadCachePersistent(persist bool)
• func SetLogRowsRuleSwitch(switchon bool, rules string) error
• func SetParallelQueryInBatch(en bool)
• func SetQueryEnabledWhenExceedSeries(enabled bool)
• func SetQueryParallel(limit int64)
• func SetQuerySchemaLimit(limit int)
• func SetQuerySeriesLimit(limit int)
• func SetTimeFilterProtection(enabled bool)
• func SetUpperMemUsePct(d int64)
• func SetWriteColdShardEnabled(en bool)
• func UpdateInterruptQuery(switchOn bool)
• func UpdateNodeReadonly(switchOn bool)
• type LogRowsRule
• type SysControl
  • func NewSysControl() *SysControl

Constants

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"
)

const (
	QueryShardStatus queryRequestMod = "queryShardStatus"
)

Variables

var (
	QueryParallel int32 = -1

	DisableReads  = false
	DisableWrites = false

	InterruptQuery       = false
	UpperMemPct    int64 = 0

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

	Readonly = false

	HierarchicalStorageEnabled int32 = 0

	WriteColdShardEnable int32 = 0
)

var (
	LogRowsRuleSwitch int32 // 0: disable, 1: enable
	MuLogRowsRule     sync.RWMutex
	MyLogRowsRule     = &LogRowsRule{
		Mst: "",
	}
)

var (
	ErrNoSuchParam = fmt.Errorf("no parameter find")
)

Functions

func GetBoolValue

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

func GetBytesValue

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

func GetDurationValue

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

func GetIntValue

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

func GetQueryEnabledWhenExceedSeries

func GetQueryEnabledWhenExceedSeries() bool

func GetQuerySeriesLimit

func GetQuerySeriesLimit() int

func GetTimeFilterProtection

func GetTimeFilterProtection() bool

func IsHierarchicalStorageEnabled

func IsHierarchicalStorageEnabled() bool

func IsIndexReadCachePersistent

func IsIndexReadCachePersistent() bool

func IsReadonly

func IsReadonly() bool

func IsWriteColdShardEnabled

func IsWriteColdShardEnabled() bool

func ProcessQueryRequest

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

ProcessQueryRequest only process get method

func ProcessRequest

func ProcessRequest(req netstorage.SysCtrlRequest, resp *strings.Builder) (err error)

func SetDisableRead

func SetDisableRead(en bool)

func SetDisableWrite

func SetDisableWrite(en bool)

func SetHierarchicalStorageEnabled

func SetHierarchicalStorageEnabled(en bool)

func SetIndexReadCachePersistent

func SetIndexReadCachePersistent(persist bool)

func SetLogRowsRuleSwitch

func SetLogRowsRuleSwitch(switchon bool, rules string) error

func SetParallelQueryInBatch

func SetParallelQueryInBatch(en bool)

func SetQueryEnabledWhenExceedSeries

func SetQueryEnabledWhenExceedSeries(enabled bool)

func SetQueryParallel

func SetQueryParallel(limit int64)

func SetQuerySchemaLimit

func SetQuerySchemaLimit(limit int)

func SetQuerySeriesLimit

func SetQuerySeriesLimit(limit int)

func SetTimeFilterProtection

func SetTimeFilterProtection(enabled bool)

func SetUpperMemUsePct

func SetUpperMemUsePct(d int64)

func SetWriteColdShardEnabled

func SetWriteColdShardEnabled(en bool)

func UpdateInterruptQuery

func UpdateInterruptQuery(switchOn bool)

func UpdateNodeReadonly

func UpdateNodeReadonly(switchOn bool)

Types

type LogRowsRule

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

type SysControl

type SysControl struct {
	MetaClient meta.MetaClient
	NetStore   netstorage.Storage
}

var SysCtrl *SysControl

func NewSysControl

func NewSysControl() *SysControl