store

package
v0.0.0-...-1f1d885 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MetricNameInstance         = "instance"
	MetricNameCPUTime          = "cpu_time"
	MetricNameReadRow          = "read_row"
	MetricNameReadIndex        = "read_index"
	MetricNameWriteRow         = "write_row"
	MetricNameWriteIndex       = "write_index"
	MetricNameSQLExecCount     = "sql_exec_count"
	MetricNameSQLDurationSum   = "sql_duration_sum"
	MetricNameSQLDurationCount = "sql_duration_count"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultStore

type DefaultStore struct {
	// contains filtered or unexported fields
}

func NewDefaultStore

func NewDefaultStore(vminsertHandler http.HandlerFunc, documentDB *genji.DB) (*DefaultStore, error)

func (*DefaultStore) Close

func (ds *DefaultStore) Close()

func (*DefaultStore) Instances

func (ds *DefaultStore) Instances(items []InstanceItem) error

func (*DefaultStore) PlanMeta

func (ds *DefaultStore) PlanMeta(meta *tipb.PlanMeta) error

func (*DefaultStore) ResourceMeteringRecord

func (ds *DefaultStore) ResourceMeteringRecord(
	instance, instanceType string,
	record *rsmetering.ResourceUsageRecord,
) error

func (*DefaultStore) SQLMeta

func (ds *DefaultStore) SQLMeta(meta *tipb.SQLMeta) error

func (*DefaultStore) TopSQLRecord

func (ds *DefaultStore) TopSQLRecord(instance, instanceType string, record *tipb.TopSQLRecord) error

type InstanceItem

type InstanceItem struct {
	Instance     string `json:"instance"`
	InstanceType string `json:"instance_type"`
	TimestampSec uint64 `json:"timestamp"`
}

type Metric

type Metric struct {
	Metric      interface{} `json:"metric"`
	TimestampMs []uint64    `json:"timestamps"`
	Values      []uint64    `json:"values"`
}

type PrepareSlicePool

type PrepareSlicePool struct {
	// contains filtered or unexported fields
}

func (*PrepareSlicePool) Get

func (psp *PrepareSlicePool) Get() *[]interface{}

func (*PrepareSlicePool) Put

func (psp *PrepareSlicePool) Put(ps *[]interface{})

type Store

type Store interface {
	Instances(items []InstanceItem) error
	TopSQLRecord(instance, instanceType string, record *tipb.TopSQLRecord) error
	ResourceMeteringRecord(instance, instanceType string, record *rsmetering.ResourceUsageRecord) error
	SQLMeta(meta *tipb.SQLMeta) error
	PlanMeta(meta *tipb.PlanMeta) error
	Close()
}

type StringBuilderPool

type StringBuilderPool struct {
	// contains filtered or unexported fields
}

func (*StringBuilderPool) Get

func (sbp *StringBuilderPool) Get() *strings.Builder

func (*StringBuilderPool) Put

func (sbp *StringBuilderPool) Put(sb *strings.Builder)

Jump to

Keyboard shortcuts

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