motrace

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 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",
		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",
		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 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 && GetTracerProvider().skipRunningStmt {
		return nil
	}

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

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

	if s.User == "internal" {
		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 ContextWithStatement 

func ContextWithStatement(parent context.Context, s *StatementInfo) context.Context

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 EndStatement 

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

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 InitWithConfig 

func InitWithConfig(ctx context.Context, SV *config.ObservabilityParameters, opts ...TracerProviderOption) (error, bool)

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 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
}

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 GetTracerProvider 

func GetTracerProvider() *MOTracerProvider

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   [16]byte `json:"session_id"`
	StatementID [16]byte `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 (n NoopBatchProcessor) Collect(context.Context, batchpipe.HasName) error

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 PipeImpl 

type PipeImpl batchpipe.PipeImpl[batchpipe.HasName, any]

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 StatementFromContext 

func StatementFromContext(ctx context.Context) *StatementInfo

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) interface{}

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)

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
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.