syscontrol

package

v1.0.1 Latest Latest Go to latest Published: Mar 29, 2023 License: Apache-2.0 Imports: 9 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 GetDurationValue(param map[string]string, key string) (time.Duration, error)
func GetIntValue(param map[string]string, key string) (int64, error)
func GetQuerySeriesLimit() int
func ProcessRequest(req netstorage.SysCtrlRequest, resp *strings.Builder) (err error)
func SetLogRowsRuleSwitch(switchon bool, rules string) error
func SetQueryParallel(limit int64)
func SetQuerySeriesLimit(limit int)
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"
)

Variables ¶

View Source

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

View Source

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

View Source

var (
	QueryParallel int32 = -1
)

Functions ¶

func GetBoolValue ¶ added in v1.0.0

func GetBoolValue(param map[string]string, key string) (bool, 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 GetQuerySeriesLimit ¶ added in v1.0.0

func GetQuerySeriesLimit() int

func ProcessRequest ¶

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

func SetLogRowsRuleSwitch ¶

func SetLogRowsRuleSwitch(switchon bool, rules string) error

func SetQueryParallel ¶

func SetQueryParallel(limit int64)

func SetQuerySeriesLimit ¶ added in v1.0.0

func SetQuerySeriesLimit(limit int)

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