Documentation ¶
Index ¶
- Constants
- Variables
- func CalculateCU(stats statistic.StatsArray, durationNS int64) float64
- func CalculateCUCpu(cpuRuntimeNS int64, cfg *config.OBCUConfig) float64
- func CalculateCUIOIn(ioCnt int64, cfg *config.OBCUConfig) float64
- func CalculateCUIOOut(ioCnt int64, cfg *config.OBCUConfig) float64
- func CalculateCUMem(memByte int64, durationNS int64, cfg *config.OBCUConfig) float64
- func CalculateCUMemDecimal(memByte, durationNS int64, memPrice, cuUnit float64) (float64, error)
- func CalculateCUTraffic(bytes int64, connType float64, cfg *config.OBCUConfig) float64
- func CalculateCUWithCfg(stats statistic.StatsArray, durationNS int64, cfg *config.OBCUConfig) float64
- func CalculateCUv1(stats statistic.StatsArray, durationNS int64) float64
- func DebugMode(debug bool) tracerProviderOption
- func DefaultContext() context.Context
- func DefaultSpanContext() *trace.SpanContext
- func DisableLogErrorReport(disable bool)
- func EnableTracer(enable bool) tracerProviderOption
- func GetAllTables() []*table.Tabledeprecated
- func GetCUConfig() *config.OBCUConfig
- func GetCUConfigV1() *config.OBCUConfig
- func GetLongQueryTime() time.Duration
- func GetNodeResource() *trace.MONodeResource
- func GetSQLExecutorFactory() func() ie.InternalExecutor
- func GetSchemaForAccount(ctx context.Context, account string) []string
- func Init(ctx context.Context, opts ...TracerProviderOption) (err error, act bool)
- func InitSchema(ctx context.Context, sqlExecutor func() ie.InternalExecutor) error
- func InitSchemaByInnerExecutor(ctx context.Context, ieFactory func() ie.InternalExecutor) error
- func InitSchemaWithTxn(ctx context.Context, txn executor.TxnExecutor) error
- func InitWithConfig(ctx context.Context, SV *config.ObservabilityParameters, ...) (error, bool)
- func NewBatchSpanProcessor(exporter BatchProcessor) trace.SpanProcessor
- func NewBufferPipe2CSVWorker(opt ...BufferOption) bp.PipeImpl[bp.HasName, any]
- func NewItemBuffer(opts ...BufferOption) *itemBuffer
- func ReportError(ctx context.Context, err error, depth int)
- func ReportZap(jsonEncoder zapcore.Encoder, entry zapcore.Entry, fields []zapcore.Field) (*buffer.Buffer, error)
- func SetCuConfig(cu, cuv1 *config.OBCUConfig)
- func SetDefaultContext(ctx context.Context)
- func SetDefaultSpanContext(sc *trace.SpanContext)
- func SetTracerProvider(p *MOTracerProvider)
- func Shutdown(ctx context.Context) error
- func StatementInfoFilter(i Item) bool
- func StatementInfoUpdate(ctx context.Context, existing, new Item)
- func Time2DatetimeString(t time.Time) string
- func WithAggregatorDisable(disable bool) tracerProviderOption
- func WithAggregatorWindow(window time.Duration) tracerProviderOption
- func WithBatchProcessor(p BatchProcessor) tracerProviderOption
- func WithBufferSizeThreshold(size int64) tracerProviderOption
- func WithCUConfig(cu config.OBCUConfig, cuv1 config.OBCUConfig) tracerProviderOption
- func WithErrorDisable(disable bool) tracerProviderOption
- func WithExportInterval(secs int) tracerProviderOption
- func WithFSWriterFactory(f table.WriterFactory) tracerProviderOption
- func WithInitAction(init bool) tracerProviderOption
- func WithLabels(l map[string]string) tracerProviderOption
- func WithLongQueryTime(secs float64) tracerProviderOption
- func WithLongSpanTime(d time.Duration) tracerProviderOption
- func WithNode(uuid string, t string) tracerProviderOption
- func WithSQLExecutor(f func() ie.InternalExecutor) tracerProviderOption
- func WithSQLWriterDisable(disable bool) tracerProviderOption
- func WithSelectThreshold(window time.Duration) tracerProviderOption
- func WithSkipRunningStmt(skip bool) tracerProviderOption
- func WithSpanDisable(disable bool) tracerProviderOption
- func WithStmtMergeEnable(enable bool) tracerProviderOption
- func WithTCPPacket(count bool) tracerProviderOption
- type Aggregator
- type BatchProcessor
- type BufferOption
- type DiscardableCollector
- type IBuffer2SqlItem
- type Item
- type ItemSyncer
- func (s *ItemSyncer) FillRow(ctx context.Context, row *table.Row)
- func (s *ItemSyncer) Free()
- func (s *ItemSyncer) GetCheckWriteHook() table.CheckWriteHook
- func (s *ItemSyncer) GetName() string
- func (s *ItemSyncer) GetTable() *table.Table
- func (s *ItemSyncer) NeedCheckWrite() bool
- func (s *ItemSyncer) NeedSyncWrite() bool
- func (s *ItemSyncer) Size() int64
- func (s *ItemSyncer) Wait()
- type Key
- type MOErrorHolder
- type MOHungSpan
- type MOSpan
- func (s *MOSpan) AddExtraFields(fields ...zap.Field)
- func (s *MOSpan) End(options ...trace.SpanEndOption)
- func (s *MOSpan) FillRow(ctx context.Context, row *table.Row)
- func (s *MOSpan) Free()
- func (s *MOSpan) GetName() string
- func (s *MOSpan) GetTable() *table.Table
- func (s *MOSpan) NeedRecord() (bool, error)
- func (s *MOSpan) ParentSpanContext() trace.SpanContext
- func (s *MOSpan) Size() int64
- func (s *MOSpan) SpanContext() trace.SpanContext
- type MOTracer
- func (t *MOTracer) Debug(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, trace.Span)
- func (t *MOTracer) IsEnable(opts ...trace.SpanStartOption) bool
- func (t *MOTracer) Start(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, trace.Span)
- type MOTracerProvider
- type MOZapLog
- type NamedItemRow
- type NoopBatchProcessor
- type PipeImpl
- type SerializableExecPlan
- type SerializeExecPlanFunc
- type StatementInfo
- func (s *StatementInfo) CloneWithoutExecPlan() *StatementInfo
- func (s *StatementInfo) EndStatement(ctx context.Context, err error, sentRows int64, outBytes int64, ...)
- func (s *StatementInfo) ExecPlan2Json(ctx context.Context) []byte
- func (s *StatementInfo) ExecPlan2Stats(ctx context.Context) error
- func (s *StatementInfo) FillRow(ctx context.Context, row *table.Row)
- func (s *StatementInfo) Free()
- func (s *StatementInfo) FreeExecPlan()
- func (s *StatementInfo) GetName() string
- func (s *StatementInfo) GetStatsArrayBytes() []byte
- func (s *StatementInfo) GetTable() *table.Table
- func (s *StatementInfo) IsMoLogger() bool
- func (s *StatementInfo) IsZeroTxnID() bool
- func (s *StatementInfo) Key(duration time.Duration) any
- func (s *StatementInfo) MarkResponseAt()
- func (s *StatementInfo) NeedSkipTxn() bool
- func (s *StatementInfo) Report(ctx context.Context)
- func (s *StatementInfo) SetSerializableExecPlan(execPlan SerializableExecPlan)
- func (s *StatementInfo) SetSkipTxn(skip bool)
- func (s *StatementInfo) SetSkipTxnId(id []byte)
- func (s *StatementInfo) SetTxnID(id []byte)
- func (s *StatementInfo) Size() int64
- func (s *StatementInfo) SkipTxnId(id []byte) bool
- type StatementInfoStatus
- type StatementOption
- type StatementOptionFunc
- type Statistic
- type TracerProviderOption
- type WriteFactoryConfig
Constants ¶
const ( MOStatementType = "statement" MOSpanType = "span" MOLogType = "log" MOErrorType = "error" MORawLogType = "rawlog" )
const ( SystemDBConst = "system" StatsDatabase = SystemDBConst )
const ( RawLogTbl = "rawlog" SqlStatementHotspotTbl = "sql_statement_hotspot" )
const Decimal128Scale = 0
const Decimal128ScalePrice = 26
const Decimal128Width = 38
const DecimalNSThreshold = 100e9
DecimalNSThreshold default 100 sec
const (
DurationKey key = iota
)
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
const TcpIpv4HeaderSize = 66
TcpIpv4HeaderSize default tcp header bytes.
Variables ¶
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: ×tampCol, 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, } )
var ErrFilteredOut = moerr.NewInternalError(context.Background(), "filtered out")
var GetTracerProvider = func() *MOTracerProvider { return gTracerProvider.Load().(*MOTracerProvider) }
GetTracerProvider returns the global TracerProvider. It will be initialized at startup.
var NilSesID [16]byte
var NilStmtID [16]byte
var NilTxnID [16]byte
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 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 DefaultContext ¶
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 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 GetNodeResource ¶
func GetNodeResource() *trace.MONodeResource
func GetSQLExecutorFactory ¶ added in v1.0.0
func GetSQLExecutorFactory() func() ie.InternalExecutor
func GetSchemaForAccount ¶
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 InitWithConfig ¶
func InitWithConfig(ctx context.Context, SV *config.ObservabilityParameters, opts ...TracerProviderOption) (error, bool)
func NewBatchSpanProcessor ¶
func NewBatchSpanProcessor(exporter BatchProcessor) trace.SpanProcessor
func NewBufferPipe2CSVWorker ¶
func NewItemBuffer ¶ added in v0.8.0
func NewItemBuffer(opts ...BufferOption) *itemBuffer
func ReportError ¶
ReportError send to BatchProcessor
func SetCuConfig ¶ added in v1.1.2
func SetCuConfig(cu, cuv1 *config.OBCUConfig)
func SetDefaultContext ¶
func SetDefaultSpanContext ¶
func SetDefaultSpanContext(sc *trace.SpanContext)
func SetTracerProvider ¶
func SetTracerProvider(p *MOTracerProvider)
func StatementInfoFilter ¶ added in v0.8.0
func StatementInfoUpdate ¶ added in v0.8.0
func Time2DatetimeString ¶
func WithAggregatorDisable ¶ added in v0.8.0
func WithAggregatorDisable(disable bool) tracerProviderOption
func WithAggregatorWindow ¶ added in v0.8.0
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 WithLongQueryTime ¶
func WithLongQueryTime(secs float64) tracerProviderOption
func WithLongSpanTime ¶ added in v0.8.0
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 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 (*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 IBuffer2SqlItem ¶
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 MOErrorHolder ¶
MOErrorHolder implement export.IBuffer2SqlItem and export.CsvFields
func (*MOErrorHolder) FillRow ¶
func (h *MOErrorHolder) FillRow(ctx context.Context, row *table.Row)
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 (*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) NeedRecord ¶ added in v1.0.0
func (*MOSpan) ParentSpanContext ¶
func (s *MOSpan) ParentSpanContext() trace.SpanContext
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) 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) 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
type NamedItemRow ¶ added in v0.8.0
type NamedItemRow interface { IBuffer2SqlItem table.RowField }
type NoopBatchProcessor ¶
type NoopBatchProcessor struct { }
func (NoopBatchProcessor) Register ¶
func (n NoopBatchProcessor) Register(batchpipe.HasName, PipeImpl)
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 SerializeExecPlanFunc ¶
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 (*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) 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 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 }