Function newOmniQuerySpanExtractor

backend/plugin/parser/pg/query_span_omni.go:66–80

newOmniQuerySpanExtractor creates a new omni-based query span extractor.

(defaultDatabase string, searchPath []string, gCtx base.GetQuerySpanContext)

// newOmniQuerySpanExtractor creates a new omni-based query span extractor.
func newOmniQuerySpanExtractor(defaultDatabase string, searchPath []string, gCtx base.GetQuerySpanContext) *omniQuerySpanExtractor {
	if len(searchPath) == 0 {
		searchPath = []string{"public"}
	}
	return &omniQuerySpanExtractor{
		defaultDatabase:      defaultDatabase,
		searchPath:           searchPath,
		gCtx:                 gCtx,
		metaCache:            make(map[string]*model.DatabaseMetadata),
		funcBodyCache:        make(map[uint32]*funcBodyAnalysis),
		funcOrigDefs:         make(map[string]string),
		funcSourceColumns:    make(base.SourceColumnSet),
		funcPredicateColumns: make(base.SourceColumnSet),
	}
}

// getDatabaseMetadata returns cached database metadata, fetching it if not yet cached.
func (e *omniQuerySpanExtractor) getDatabaseMetadata(database string) (*model.DatabaseMetadata, error) {