syscontrol

package

v1.1.0 Latest Latest Go to latest Published: Sep 28, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/openGemini/openGemini

Links

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 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 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 UpdateInterruptQuery(switchOn bool)
type LogRowsRule
type SysControl
- func NewSysControl() *SysControl

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"
	Readonly            = "readonly"
	LogRows             = "log_rows"

	TimeFilterProtection = "time_filter_protection"

	BackgroundReadLimiter = "backgroundReadLimiter"

	NodeInterruptQuery = "interruptquery"
	UpperMemUsePct     = "uppermemusepct"
	ParallelQuery      = "parallelbatch"
)

View Source

const (
	QueryShardStatus queryRequestMod = "queryShardStatus"
)

Variables ¶

View Source

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
)

View Source

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

View Source

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

Functions ¶

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 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 netstorage.SysCtrlRequest, resp *strings.Builder) (err error)

func SetDisableRead ¶ added in v1.1.0

func SetDisableRead(en bool)

func SetDisableWrite ¶ added in v1.1.0

func SetDisableWrite(en 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 SetUpperMemUsePct ¶ added in v1.1.0

func SetUpperMemUsePct(d int64)

func UpdateInterruptQuery ¶ added in v1.1.0

func UpdateInterruptQuery(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

Source Files ¶

View all Source files

syscontrol.go

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