Documentation
¶
Index ¶
Constants ¶
View Source
const ( DataFlush = "flush" 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 (
QueryParallel int32 = -1
)
Functions ¶
func ProcessRequest ¶
func ProcessRequest(req netstorage.SysCtrlRequest, resp *strings.Builder) (err error)
func SetLogRowsRuleSwitch ¶
func SetQueryParallel ¶
func SetQueryParallel(limit int64)
Types ¶
type LogRowsRule ¶
type SysControl ¶
type SysControl struct {
MetaClient meta.MetaClient
NetStore netstorage.Storage
}
var SysCtrl *SysControl
func NewSysControl ¶
func NewSysControl() *SysControl
Click to show internal directories.
Click to hide internal directories.