motrace

package
v1.2.4 Latest Latest
Warning

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

Go to latest
Published: Sep 20, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MOStatementType = "statement"
	MOSpanType      = "span"
	MOLogType       = "log"
	MOErrorType     = "error"
	MORawLogType    = "rawlog"
)
View Source
const (
	SystemDBConst = "system"
	StatsDatabase = SystemDBConst
)
View Source
const (
	RawLogTbl = "rawlog"

	SqlStatementHotspotTbl = "sql_statement_hotspot"
)
View Source
const Decimal128Scale = 0
View Source
const Decimal128ScalePrice = 26
View Source
const Decimal128Width = 38
View Source
const DecimalNSThreshold = 100e9

DecimalNSThreshold default 100 sec

View Source
const (
	DurationKey key = iota
)
View Source
const ResponseErrPacketSize = TcpIpv4HeaderSize + 13

ResponseErrPacketSize avg prefix size for mysql packet response error. 66: default tcp header bytes. 13: avg payload prefix of err response

View Source
const TcpIpv4HeaderSize = 66

TcpIpv4HeaderSize default tcp header bytes.

Variables

View Source
var (
	SingleStatementTable = &table.Table{
		Account:  table.AccountSys,
		Database: StatsDatabase,
		Table:    statementInfoTbl,
		Columns: []table.Column{
			stmtIDCol,
			txnIDCol,
			sesIDCol,
			accountCol,
			userCol,
			hostCol,
			dbCol,
			stmtCol,
			stmtTagCol,
			stmtFgCol,
			nodeUUIDCol,
			nodeTypeCol,
			reqAtCol,
			respAtCol,
			durationCol,
			statusCol,
			errCodeCol,
			errorCol,
			execPlanCol,
			rowsReadCol,
			bytesScanCol,
			statsCol,
			stmtTypeCol,
			queryTypeCol,
			roleIdCol,
			sqlTypeCol,
			aggrCntCol,
			resultCntCol,
		},
		PrimaryKeyColumn: nil,
		ClusterBy:        []table.Column{reqAtCol},

		Engine:        table.NormalTableEngine,
		Comment:       "record each statement and stats info" + catalog.MO_COMMENT_NO_DEL_HINT,
		PathBuilder:   table.NewAccountDatePathBuilder(),
		AccountColumn: &accountCol,

		TimestampColumn: &respAtCol,

		SupportUserAccess: true,

		SupportConstAccess: true,
	}

	UpgradeColumns = map[string]map[string][]table.Column{
		"1.0": {
			"ADD": {
				statementIDCol,
				sessionIDCol,
			},
		},
	}

	SingleRowLogTable = &table.Table{
		Account:  table.AccountSys,
		Database: StatsDatabase,
		Table:    RawLogTbl,
		Columns: []table.Column{
			rawItemCol,
			nodeUUIDCol,
			nodeTypeCol,
			spanIDCol,
			traceIDCol,
			loggerNameCol,
			timestampCol,
			levelCol,
			callerCol,
			messageCol,
			extraCol,
			errCodeCol,
			errorCol,
			stackCol,
			spanNameCol,
			parentSpanIDCol,
			startTimeCol,
			endTimeCol,
			durationCol,
			resourceCol,
			spanKindCol,
			statementIDCol,
			sessionIDCol,
		},
		PrimaryKeyColumn: nil,
		ClusterBy:        []table.Column{timestampCol},
		Engine:           table.NormalTableEngine,
		Comment:          "read merge data from log, error, span" + catalog.MO_COMMENT_NO_DEL_HINT,
		PathBuilder:      table.NewAccountDatePathBuilder(),
		AccountColumn:    nil,

		TimestampColumn: &timestampCol,

		SupportUserAccess: false,

		SupportConstAccess: true,
	}

	SqlStatementHotspotView = &table.View{
		Database:    StatsDatabase,
		Table:       SqlStatementHotspotTbl,
		OriginTable: SingleStatementTable,
		Columns: []table.Column{
			table.StringColumn("statement_id", "the statement's uuid"),
			table.StringColumn("statement", "query's statement"),
			table.ValueColumn("timeconsumed", "query's exec time (unit: ms)"),
			table.ValueColumn("memorysize", "query's consume mem size (unit: MiB)"),
			table.DatetimeColumn("collecttime", "collected time, same as query's response time"),
			table.StringColumn("node", "cn node uuid"),
			table.StringColumn("account", "account id "),
			table.StringColumn("user", "user name"),
			table.StringColumn("type", "statement type, like: [Insert, Delete, Update, Select, ...]"),
		},
		CreateSql: table.ViewCreateSqlString(fmt.Sprintf(`CREATE VIEW IF NOT EXISTS system.sql_statement_hotspot AS
select statement_id, statement, duration / 1e6 as timeconsumed,
cast(json_unquote(json_extract(stats, '$[%d]')) / 1048576.00 as decimal(38,3)) as memorysize,
response_at as collecttime,
node_uuid as node,
account,
user,
statement_type as type
 from system.statement_info
 where response_at > date_sub(now(), interval 10 minute) and response_at < now()
and aggr_count = 0 order by duration desc limit 10;`, statistic.StatsArrayIndexMemorySize)),
		SupportUserAccess: false,
	}
)
View Source
var ErrFilteredOut = moerr.NewInternalError(context.Background(), "filtered out")
View Source
var GetTracerProvider = func() *MOTracerProvider {
	return gTracerProvider.Load().(*MOTracerProvider)
}

GetTracerProvider returns the global TracerProvider. It will be initialized at startup.

View Source
var NilSesID [16]byte
View Source
var NilStmtID [16]byte
View Source
var NilTxnID [16]byte
View Source
var ReportStatement = func(ctx context.Context, s *StatementInfo) error {
	if !GetTracerProvider().IsEnable() {
		return nil
	}

	if s.Status == StatementStatusRunning {
		if GetTracerProvider().skipRunningStmt {
			return nil
		} else {
			s = s.CloneWithoutExecPlan()
		}
	}

	if s.Statement == "" {
		goto DiscardAndFreeL
	}

	if s.exported || s.reported {
		goto DiscardAndFreeL
	}

	if s.User == "internal" && s.Account == "sys" {
		if s.StatementType == "Commit" || s.StatementType == "Start Transaction" || s.StatementType == "Use" {
			goto DiscardAndFreeL
		}
	}

	if s.exported || s.reported || s.Statement == "" {
		logutil.Error("StatementInfo should not be here anymore", zap.String("StatementInfo", s.Statement), zap.String("statement_id", uuid.UUID(s.StatementID).String()), zap.String("user", s.User), zap.Bool("exported", s.exported), zap.Bool("reported", s.reported))
	}

	s.reported = true
	return GetGlobalBatchProcessor().Collect(ctx, s)
DiscardAndFreeL:
	s.freeNoLocked()
	return nil
}

Functions

func CalculateCU added in v1.1.2

func CalculateCU(stats statistic.StatsArray, durationNS int64) float64

CalculateCU calculate CU cost the result only keep 3 decimal places Tips: CU is long-tailed numbers

func CalculateCUCpu added in v1.1.2

func CalculateCUCpu(cpuRuntimeNS int64, cfg *config.OBCUConfig) float64

CalculateCUCpu Be careful of the number overflow

func CalculateCUIOIn added in v1.1.2

func CalculateCUIOIn(ioCnt int64, cfg *config.OBCUConfig) float64

func CalculateCUIOOut added in v1.1.2

func CalculateCUIOOut(ioCnt int64, cfg *config.OBCUConfig) float64

func CalculateCUMem added in v1.1.2

func CalculateCUMem(memByte int64, durationNS int64, cfg *config.OBCUConfig) float64

CalculateCUMem Be careful of the number overflow

func CalculateCUMemDecimal added in v1.1.2

func CalculateCUMemDecimal(memByte, durationNS int64, memPrice, cuUnit float64) (float64, error)

func CalculateCUTraffic added in v1.1.2

func CalculateCUTraffic(bytes int64, connType float64, cfg *config.OBCUConfig) float64

func CalculateCUWithCfg added in v1.1.2

func CalculateCUWithCfg(stats statistic.StatsArray, durationNS int64, cfg *config.OBCUConfig) float64

func CalculateCUv1 added in v1.1.2

func CalculateCUv1(stats statistic.StatsArray, durationNS int64) float64

CalculateCUv1 calculate CU cost

func DebugMode

func DebugMode(debug bool) tracerProviderOption

func DefaultContext

func DefaultContext() context.Context

func DefaultSpanContext

func DefaultSpanContext() *trace.SpanContext

func DisableLogErrorReport

func DisableLogErrorReport(disable bool)

func EnableTracer

func EnableTracer(enable bool) tracerProviderOption

func GetAllTables deprecated added in v1.0.0

func GetAllTables() []*table.Table

GetAllTables

Deprecated: use table.GetAllTables() instead.

func GetCUConfig added in v1.1.2

func GetCUConfig() *config.OBCUConfig

func GetCUConfigV1 added in v1.1.2

func GetCUConfigV1() *config.OBCUConfig

func GetLongQueryTime added in v0.8.0

func GetLongQueryTime() time.Duration

func GetNodeResource

func GetNodeResource() *trace.MONodeResource

func GetSQLExecutorFactory added in v1.0.0

func GetSQLExecutorFactory() func() ie.InternalExecutor

func GetSchemaForAccount

func GetSchemaForAccount(ctx context.Context, account string) []string

GetSchemaForAccount return account's table, and view's schema

func Init

func Init(ctx context.Context, opts ...TracerProviderOption) (err error, act bool)

Init initializes the tracer with the given options. If EnableTracer is set to false, this function does nothing. If EnableTracer is set to true, the tracer is initialized. Init only allow called once.

func InitSchema

func InitSchema(ctx context.Context, sqlExecutor func() ie.InternalExecutor) error

InitSchema PS: only in standalone or CN node can init schema

func InitSchemaByInnerExecutor

func InitSchemaByInnerExecutor(ctx context.Context, ieFactory func() ie.InternalExecutor) error

InitSchemaByInnerExecutor init schema, which can access db by io.InternalExecutor on any Node.

func InitSchemaWithTxn added in v1.2.0

func InitSchemaWithTxn(ctx context.Context, txn executor.TxnExecutor) error

InitSchema2 PS: only in system bootstrap init schema with `executor.TxnExecutor`

func NewBatchSpanProcessor

func NewBatchSpanProcessor(exporter BatchProcessor) trace.SpanProcessor

func NewBufferPipe2CSVWorker

func NewBufferPipe2CSVWorker(opt ...BufferOption) bp.PipeImpl[bp.HasName, any]

func NewItemBuffer added in v0.8.0

func NewItemBuffer(opts ...BufferOption) *itemBuffer

func ReportError

func ReportError(ctx context.Context, err error, depth int)

ReportError send to BatchProcessor

func ReportZap

func ReportZap(jsonEncoder zapcore.Encoder, entry zapcore.Entry, fields []zapcore.Field) (*buffer.Buffer, error)

func SetCuConfig added in v1.1.2

func SetCuConfig(cu, cuv1 *config.OBCUConfig)

func SetDefaultContext

func SetDefaultContext(ctx context.Context)

func SetDefaultSpanContext

func SetDefaultSpanContext(sc *trace.SpanContext)

func SetTracerProvider

func SetTracerProvider(p *MOTracerProvider)

func Shutdown

func Shutdown(ctx context.Context) error

func StatementInfoFilter added in v0.8.0

func StatementInfoFilter(i Item) bool

func StatementInfoUpdate added in v0.8.0

func StatementInfoUpdate(ctx context.Context, existing, new Item)

func Time2DatetimeString

func Time2DatetimeString(t time.Time) string

func WithAggregatorDisable added in v0.8.0

func WithAggregatorDisable(disable bool) tracerProviderOption

func WithAggregatorWindow added in v0.8.0

func WithAggregatorWindow(window time.Duration) tracerProviderOption

func WithBatchProcessor

func WithBatchProcessor(p BatchProcessor) tracerProviderOption

func WithBufferSizeThreshold added in v0.8.0

func WithBufferSizeThreshold(size int64) tracerProviderOption

func WithCUConfig added in v1.1.2

func WithCUConfig(cu config.OBCUConfig, cuv1 config.OBCUConfig) tracerProviderOption

func WithErrorDisable added in v1.2.0

func WithErrorDisable(disable bool) tracerProviderOption

func WithExportInterval

func WithExportInterval(secs int) tracerProviderOption

func WithFSWriterFactory

func WithFSWriterFactory(f table.WriterFactory) tracerProviderOption

func WithInitAction

func WithInitAction(init bool) tracerProviderOption

func WithLabels added in v1.1.2

func WithLabels(l map[string]string) tracerProviderOption

func WithLongQueryTime

func WithLongQueryTime(secs float64) tracerProviderOption

func WithLongSpanTime added in v0.8.0

func WithLongSpanTime(d time.Duration) tracerProviderOption

func WithNode

func WithNode(uuid string, t string) tracerProviderOption

WithNode give id as NodeId, t as NodeType

func WithSQLExecutor

func WithSQLExecutor(f func() ie.InternalExecutor) tracerProviderOption

func WithSQLWriterDisable added in v0.8.0

func WithSQLWriterDisable(disable bool) tracerProviderOption

func WithSelectThreshold added in v0.8.0

func WithSelectThreshold(window time.Duration) tracerProviderOption

func WithSkipRunningStmt added in v0.8.0

func WithSkipRunningStmt(skip bool) tracerProviderOption

func WithSpanDisable added in v0.8.0

func WithSpanDisable(disable bool) tracerProviderOption

func WithStmtMergeEnable added in v0.8.0

func WithStmtMergeEnable(enable bool) tracerProviderOption

func WithTCPPacket added in v1.1.2

func WithTCPPacket(count bool) tracerProviderOption

Types

type Aggregator added in v0.8.0

type Aggregator struct {
	Grouped     map[interface{}]Item
	WindowSize  time.Duration
	NewItemFunc func(i Item, ctx context.Context) Item
	UpdateFunc  func(ctx context.Context, existing, new Item)
	FilterFunc  func(i Item) bool
	// contains filtered or unexported fields
}

func NewAggregator added in v0.8.0

func NewAggregator(ctx context.Context, windowSize time.Duration, newItemFunc func(i Item, ctx context.Context) Item, updateFunc func(ctx context.Context, existing, new Item), filterFunc func(i Item) bool) *Aggregator

func (*Aggregator) AddItem added in v0.8.0

func (a *Aggregator) AddItem(i Item) (Item, error)

func (*Aggregator) Close added in v0.8.0

func (a *Aggregator) Close()

func (*Aggregator) GetResults added in v0.8.0

func (a *Aggregator) GetResults() []Item

type BatchProcessor

type BatchProcessor interface {
	Collect(context.Context, batchpipe.HasName) error
	Start() bool
	Stop(graceful bool) error
	Register(name batchpipe.HasName, impl PipeImpl)
}

func GetGlobalBatchProcessor

func GetGlobalBatchProcessor() BatchProcessor

type BufferOption

type BufferOption interface {
	// contains filtered or unexported methods
}

func BufferWithFilterItemFunc

func BufferWithFilterItemFunc(f filterItemFunc) BufferOption

func BufferWithGenBatchFunc

func BufferWithGenBatchFunc(f genBatchFunc) BufferOption

func BufferWithReminder

func BufferWithReminder(reminder bp.Reminder) BufferOption

func BufferWithSizeThreshold

func BufferWithSizeThreshold(size int64) BufferOption

func BufferWithType

func BufferWithType(name string) BufferOption

type DiscardableCollector added in v1.0.0

type DiscardableCollector interface {
	DiscardableCollect(context.Context, batchpipe.HasName) error
}

type IBuffer2SqlItem

type IBuffer2SqlItem interface {
	bp.HasName
	Size() int64
	Free()
}

type Item added in v0.8.0

type Item interface {
	Key(duration time.Duration) interface{}
}

func StatementInfoNew added in v0.8.0

func StatementInfoNew(i Item, ctx context.Context) Item

type ItemSyncer added in v0.8.0

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

func NewItemSyncer added in v0.8.0

func NewItemSyncer(item NamedItemRow) *ItemSyncer

func (*ItemSyncer) FillRow added in v0.8.0

func (s *ItemSyncer) FillRow(ctx context.Context, row *table.Row)

FillRow implements table.RowField

func (*ItemSyncer) Free added in v0.8.0

func (s *ItemSyncer) Free()

Free implements IBuffer2SqlItem

func (*ItemSyncer) GetCheckWriteHook added in v0.8.0

func (s *ItemSyncer) GetCheckWriteHook() table.CheckWriteHook

GetCheckWriteHook implements NeedCheckWrite and NeedSyncWrite

func (*ItemSyncer) GetName added in v0.8.0

func (s *ItemSyncer) GetName() string

GetName implements IBuffer2SqlItem and batchpipe.HasName

func (*ItemSyncer) GetTable added in v0.8.0

func (s *ItemSyncer) GetTable() *table.Table

GetTable implements table.RowField

func (*ItemSyncer) NeedCheckWrite added in v0.8.0

func (s *ItemSyncer) NeedCheckWrite() bool

NeedCheckWrite implements NeedCheckWrite

func (*ItemSyncer) NeedSyncWrite added in v0.8.0

func (s *ItemSyncer) NeedSyncWrite() bool

NeedSyncWrite implements NeedSyncWrite

func (*ItemSyncer) Size added in v0.8.0

func (s *ItemSyncer) Size() int64

Size implements IBuffer2SqlItem

func (*ItemSyncer) Wait added in v0.8.0

func (s *ItemSyncer) Wait()

Wait cooperate with NeedSyncWrite and NeedSyncWrite

type Key added in v0.8.0

type Key struct {
	SessionID     [16]byte
	StatementType string
	Window        time.Time
	Status        StatementInfoStatus
	SqlSourceType string
	Error         string
}

type MOErrorHolder

type MOErrorHolder struct {
	Error     error     `json:"error"`
	Timestamp time.Time `json:"timestamp"`
}

MOErrorHolder implement export.IBuffer2SqlItem and export.CsvFields

func (*MOErrorHolder) FillRow

func (h *MOErrorHolder) FillRow(ctx context.Context, row *table.Row)

func (*MOErrorHolder) Format

func (h *MOErrorHolder) Format(s fmt.State, verb rune)

func (*MOErrorHolder) Free

func (h *MOErrorHolder) Free()

func (*MOErrorHolder) GetName

func (h *MOErrorHolder) GetName() string

func (*MOErrorHolder) GetTable

func (h *MOErrorHolder) GetTable() *table.Table

func (*MOErrorHolder) Size

func (h *MOErrorHolder) Size() int64

type MOHungSpan added in v1.0.0

type MOHungSpan struct {
	*MOSpan
	// contains filtered or unexported fields
}

func (*MOHungSpan) End added in v1.0.0

func (s *MOHungSpan) End(options ...trace.SpanEndOption)

type MOSpan

type MOSpan struct {
	trace.SpanConfig
	Name      string    `json:"name"`
	StartTime time.Time `json:"start_time"`
	EndTime   time.Time `jons:"end_time"`
	// Duration
	Duration time.Duration `json:"duration"`
	// ExtraFields
	ExtraFields []zap.Field `json:"extra"`
	// contains filtered or unexported fields
}

MOSpan implement export.IBuffer2SqlItem and export.CsvFields

func (*MOSpan) AddExtraFields added in v0.8.0

func (s *MOSpan) AddExtraFields(fields ...zap.Field)

func (*MOSpan) End

func (s *MOSpan) End(options ...trace.SpanEndOption)

End completes the Span. Span will be recorded if meets the following condition: 1. If set Deadline in ctx, which specified at the MOTracer.Start, just check if encounters the Deadline. 2. If NOT set Deadline, then check condition: MOSpan.Duration >= MOSpan.GetLongTimeThreshold().

func (*MOSpan) FillRow

func (s *MOSpan) FillRow(ctx context.Context, row *table.Row)

func (*MOSpan) Free

func (s *MOSpan) Free()

func (*MOSpan) GetName

func (s *MOSpan) GetName() string

func (*MOSpan) GetTable

func (s *MOSpan) GetTable() *table.Table

func (*MOSpan) NeedRecord added in v1.0.0

func (s *MOSpan) NeedRecord() (bool, error)

func (*MOSpan) ParentSpanContext

func (s *MOSpan) ParentSpanContext() trace.SpanContext

func (*MOSpan) Size

func (s *MOSpan) Size() int64

func (*MOSpan) SpanContext

func (s *MOSpan) SpanContext() trace.SpanContext

type MOTracer

type MOTracer struct {
	trace.TracerConfig
	// contains filtered or unexported fields
}

MOTracer is the creator of Spans.

func (*MOTracer) Debug

func (t *MOTracer) Debug(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

func (*MOTracer) IsEnable

func (t *MOTracer) IsEnable(opts ...trace.SpanStartOption) bool

func (*MOTracer) Start

func (t *MOTracer) Start(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

Start starts a Span and returns it along with a context containing it.

The Span is created with the provided name and as a child of any existing span context found in passed context. The created Span will be configured appropriately by any SpanOption passed.

Only timeout Span can be recorded, hold in SpanConfig.LongTimeThreshold. There are 4 diff ways to setting threshold value: 1. using default val, which was hold by MOTracerProvider.longSpanTime. 2. using `WithLongTimeThreshold()` SpanOption, that will override the default val. 3. passing the Deadline context, then it will check the Deadline at Span ended instead of checking Threshold. 4. using `WithHungThreshold()` SpanOption, that will override the passed context with context.WithTimeout(ctx, hungThreshold) and create a new work goroutine to check Deadline event.

When Span pass timeout threshold or got the deadline event, not only the Span will be recorded, but also trigger profile dump specify by `WithProfileGoroutine()`, `WithProfileHeap()`, `WithProfileThreadCreate()`, `WithProfileAllocs()`, `WithProfileBlock()`, `WithProfileMutex()`, `WithProfileCpuSecs()`, `WithProfileTraceSecs()` SpanOption.

type MOTracerProvider

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

func (*MOTracerProvider) GetSqlExecutor

func (cfg *MOTracerProvider) GetSqlExecutor() func() ie.InternalExecutor

func (*MOTracerProvider) IsEnable

func (cfg *MOTracerProvider) IsEnable() bool

func (*MOTracerProvider) SetEnable

func (cfg *MOTracerProvider) SetEnable(enable bool)

func (*MOTracerProvider) Tracer

func (p *MOTracerProvider) Tracer(instrumentationName string, opts ...trace.TracerOption) trace.Tracer

type MOZapLog

type MOZapLog struct {
	Level       zapcore.Level      `json:"Level"`
	SpanContext *trace.SpanContext `json:"span"`
	Timestamp   time.Time          `json:"timestamp"`
	LoggerName  string
	Caller      string `json:"caller"` // like "util/trace/trace.go:666"
	Message     string `json:"message"`
	Extra       string `json:"extra"` // like json text
	Stack       string `json:"stack"`

	SessionID   string `json:"session_id"`
	StatementID string `json:"statement_id"`
}

MOZapLog implement export.IBuffer2SqlItem and export.CsvFields

func (*MOZapLog) FillRow

func (m *MOZapLog) FillRow(ctx context.Context, row *table.Row)

func (*MOZapLog) Free

func (m *MOZapLog) Free()

func (*MOZapLog) GetName

func (m *MOZapLog) GetName() string

func (*MOZapLog) GetTable

func (m *MOZapLog) GetTable() *table.Table

func (*MOZapLog) Size

func (m *MOZapLog) Size() int64

Size 计算近似值

type NamedItemRow added in v0.8.0

type NamedItemRow interface {
	IBuffer2SqlItem
	table.RowField
}

type NoopBatchProcessor

type NoopBatchProcessor struct {
}

func (NoopBatchProcessor) Collect

func (NoopBatchProcessor) Register

func (NoopBatchProcessor) Start

func (n NoopBatchProcessor) Start() bool

func (NoopBatchProcessor) Stop

func (n NoopBatchProcessor) Stop(bool) error

type SerializableExecPlan added in v0.8.0

type SerializableExecPlan interface {
	Marshal(context.Context) []byte
	Free()
	Stats(ctx context.Context) (statistic.StatsArray, Statistic)
}

type SerializeExecPlanFunc

type SerializeExecPlanFunc func(ctx context.Context, plan any, uuid2 uuid.UUID) (jsonByte []byte, statsJson statistic.StatsArray, stats Statistic)

type StatementInfo

type StatementInfo struct {
	StatementID          [16]byte `json:"statement_id"`
	TransactionID        [16]byte `json:"transaction_id"`
	SessionID            [16]byte `jons:"session_id"`
	Account              string   `json:"account"`
	User                 string   `json:"user"`
	Host                 string   `json:"host"`
	RoleId               uint32   `json:"role_id"`
	Database             string   `json:"database"`
	Statement            string   `json:"statement"`
	StmtBuilder          strings.Builder
	StatementFingerprint string    `json:"statement_fingerprint"`
	StatementTag         string    `json:"statement_tag"`
	SqlSourceType        string    `json:"sql_source_type"`
	RequestAt            time.Time `json:"request_at"` // see WithRequestAt

	StatementType string `json:"statement_type"`
	QueryType     string `json:"query_type"`

	// after
	Status     StatementInfoStatus `json:"status"`
	Error      error               `json:"error"`
	ResponseAt time.Time           `json:"response_at"`
	Duration   time.Duration       `json:"duration"` // unit: ns
	// new ExecPlan
	ExecPlan SerializableExecPlan `json:"-"` // set by SetSerializableExecPlan
	// RowsRead, BytesScan generated from ExecPlan
	RowsRead  int64 `json:"rows_read"`  // see ExecPlan2Json
	BytesScan int64 `json:"bytes_scan"` // see ExecPlan2Json
	AggrCount int64 `json:"aggr_count"` // see EndStatement

	// AggrMemoryTime
	AggrMemoryTime types.Decimal128

	ResultCount int64 `json:"result_count"` // see EndStatement

	ConnType statistic.ConnType `json:"-"` // see frontend.RecordStatement
	// contains filtered or unexported fields
}

func NewStatementInfo added in v0.8.0

func NewStatementInfo() *StatementInfo

func (*StatementInfo) CloneWithoutExecPlan added in v1.2.1

func (s *StatementInfo) CloneWithoutExecPlan() *StatementInfo

func (*StatementInfo) EndStatement added in v1.2.1

func (s *StatementInfo) EndStatement(ctx context.Context, err error, sentRows int64, outBytes int64, outPacket int64)

func (*StatementInfo) ExecPlan2Json

func (s *StatementInfo) ExecPlan2Json(ctx context.Context) []byte

ExecPlan2Json return ExecPlan Serialized json-str // please used in s.mux.Lock()

func (*StatementInfo) ExecPlan2Stats added in v0.8.0

func (s *StatementInfo) ExecPlan2Stats(ctx context.Context) error

ExecPlan2Stats return Stats Serialized int array str and set RowsRead, BytesScan from ExecPlan and CalculateCU

func (*StatementInfo) FillRow

func (s *StatementInfo) FillRow(ctx context.Context, row *table.Row)

func (*StatementInfo) Free

func (s *StatementInfo) Free()

func (*StatementInfo) FreeExecPlan added in v1.0.0

func (s *StatementInfo) FreeExecPlan()

FreeExecPlan will free StatementInfo.ExecPlan. Please make sure it called after StatementInfo.ExecPlan2Stats

func (*StatementInfo) GetName

func (s *StatementInfo) GetName() string

func (*StatementInfo) GetStatsArrayBytes added in v1.1.2

func (s *StatementInfo) GetStatsArrayBytes() []byte

func (*StatementInfo) GetTable

func (s *StatementInfo) GetTable() *table.Table

func (*StatementInfo) IsMoLogger added in v1.1.2

func (s *StatementInfo) IsMoLogger() bool

func (*StatementInfo) IsZeroTxnID

func (s *StatementInfo) IsZeroTxnID() bool

func (*StatementInfo) Key added in v0.8.0

func (s *StatementInfo) Key(duration time.Duration) any

func (*StatementInfo) MarkResponseAt added in v1.0.0

func (s *StatementInfo) MarkResponseAt()

func (*StatementInfo) NeedSkipTxn added in v1.1.0

func (s *StatementInfo) NeedSkipTxn() bool

func (*StatementInfo) Report

func (s *StatementInfo) Report(ctx context.Context)

Report do report statement info to the Collector. Pls note that Report is only locked in EndStatement. Pls note that Report should only call twice at most: one for status:Running, one for status:Failed/Success.

func (*StatementInfo) SetSerializableExecPlan added in v0.8.0

func (s *StatementInfo) SetSerializableExecPlan(execPlan SerializableExecPlan)

func (*StatementInfo) SetSkipTxn added in v1.1.0

func (s *StatementInfo) SetSkipTxn(skip bool)

SetSkipTxn set skip txn flag, cooperate with SetSkipTxnId() usage: Step1: SetSkipTxn(true) Step2:

if NeedSkipTxn() {
	SetSkipTxn(false)
	SetSkipTxnId(target_txn_id)
} else SkipTxnId(current_txn_id) {
	// record current txn id
}

func (*StatementInfo) SetSkipTxnId added in v1.1.0

func (s *StatementInfo) SetSkipTxnId(id []byte)

func (*StatementInfo) SetTxnID

func (s *StatementInfo) SetTxnID(id []byte)

func (*StatementInfo) Size

func (s *StatementInfo) Size() int64

func (*StatementInfo) SkipTxnId added in v1.1.0

func (s *StatementInfo) SkipTxnId(id []byte) bool

type StatementInfoStatus

type StatementInfoStatus int
const (
	StatementStatusRunning StatementInfoStatus = iota
	StatementStatusSuccess
	StatementStatusFailed
)

func (StatementInfoStatus) String

func (s StatementInfoStatus) String() string

type StatementOption

type StatementOption interface {
	Apply(*StatementInfo)
}

type StatementOptionFunc

type StatementOptionFunc func(*StatementInfo)

type Statistic

type Statistic struct {
	RowsRead  int64
	BytesScan int64
}

type TracerProviderOption

type TracerProviderOption interface {
	// contains filtered or unexported methods
}

TracerProviderOption configures a TracerProvider.

type WriteFactoryConfig

type WriteFactoryConfig struct {
	Account     string
	Ts          time.Time
	PathBuilder table.PathBuilder
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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