collector

Documentation

Index

• Constants
• func ExtractTableNames(logger log.Logger, digest string, stmt sqlparser.Statement) []string
• func ParseSql(sql string) (sqlparser.Statement, error)
• func ParseTableName(t sqlparser.TableName) string
• func RedactSQL(sql string) (string, error)
• func StmtType(stmt sqlparser.Statement) string
• type ConnectionInfo
  • func NewConnectionInfo(args ConnectionInfoArguments) (*ConnectionInfo, error)
  • func (c *ConnectionInfo) Name() string
  • func (c *ConnectionInfo) Start(ctx context.Context) error
  • func (c *ConnectionInfo) Stop()
  • func (c *ConnectionInfo) Stopped() bool
• type ConnectionInfoArguments
• type QuerySample
  • func NewQuerySample(args QuerySampleArguments) (*QuerySample, error)
  • func (c *QuerySample) Name() string
  • func (c *QuerySample) Start(ctx context.Context) error
  • func (c *QuerySample) Stop()
  • func (c *QuerySample) Stopped() bool
• type QuerySampleArguments
• type SchemaTable
  • func NewSchemaTable(args SchemaTableArguments) (*SchemaTable, error)
  • func (c *SchemaTable) Name() string
  • func (c *SchemaTable) Start(ctx context.Context) error
  • func (c *SchemaTable) Stop()
  • func (c *SchemaTable) Stopped() bool
• type SchemaTableArguments

Constants

const (
	OP_QUERY_SAMPLE            = "query_sample"
	OP_QUERY_PARSED_TABLE_NAME = "query_parsed_table_name"
	QuerySampleName            = "query_sample"
)

const (
	OP_SCHEMA_DETECTION = "schema_detection"
	OP_TABLE_DETECTION  = "table_detection"
	OP_CREATE_STATEMENT = "create_statement"
	SchemaTableName     = "schema_table"
)

const ConnectionInfoName = "connection_info"

Functions

func ExtractTableNames

func ExtractTableNames(logger log.Logger, digest string, stmt sqlparser.Statement) []string

func ParseSql

func ParseSql(sql string) (sqlparser.Statement, error)

func ParseTableName

func ParseTableName(t sqlparser.TableName) string

func RedactSQL

func RedactSQL(sql string) (string, error)

func StmtType

func StmtType(stmt sqlparser.Statement) string

Types

type ConnectionInfo

type ConnectionInfo struct {
	DSN        string
	Registry   *prometheus.Registry
	InfoMetric *prometheus.GaugeVec
	// contains filtered or unexported fields
}

func NewConnectionInfo

func NewConnectionInfo(args ConnectionInfoArguments) (*ConnectionInfo, error)

func (*ConnectionInfo) Name

func (c *ConnectionInfo) Name() string

func (*ConnectionInfo) Start

func (c *ConnectionInfo) Start(ctx context.Context) error

func (*ConnectionInfo) Stop

func (c *ConnectionInfo) Stop()

func (*ConnectionInfo) Stopped

func (c *ConnectionInfo) Stopped() bool

type ConnectionInfoArguments

type ConnectionInfoArguments struct {
	DSN      string
	Registry *prometheus.Registry
}

type QuerySample

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

func NewQuerySample

func NewQuerySample(args QuerySampleArguments) (*QuerySample, error)

func (*QuerySample) Name

func (c *QuerySample) Name() string

func (*QuerySample) Start

func (c *QuerySample) Start(ctx context.Context) error

func (*QuerySample) Stop

func (c *QuerySample) Stop()

Stop should be kept idempotent

func (*QuerySample) Stopped

func (c *QuerySample) Stopped() bool

type QuerySampleArguments

type QuerySampleArguments struct {
	DB              *sql.DB
	InstanceKey     string
	CollectInterval time.Duration
	EntryHandler    loki.EntryHandler

	Logger log.Logger
}

type SchemaTable

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

func NewSchemaTable

func NewSchemaTable(args SchemaTableArguments) (*SchemaTable, error)

func (*SchemaTable) Name

func (c *SchemaTable) Name() string

func (*SchemaTable) Start

func (c *SchemaTable) Start(ctx context.Context) error

func (*SchemaTable) Stop

func (c *SchemaTable) Stop()

Stop should be kept idempotent

func (*SchemaTable) Stopped

func (c *SchemaTable) Stopped() bool

type SchemaTableArguments

type SchemaTableArguments struct {
	DB              *sql.DB
	InstanceKey     string
	CollectInterval time.Duration
	EntryHandler    loki.EntryHandler

	CacheEnabled bool
	CacheSize    int
	CacheTTL     time.Duration

	Logger log.Logger
}