collector

Documentation

Index

• Constants
• type ConnectionInfo
  • func NewConnectionInfo(args ConnectionInfoArguments) (*ConnectionInfo, error)
  • func (c *ConnectionInfo) Start(ctx context.Context) error
  • func (c *ConnectionInfo) Stop()
• type ConnectionInfoArguments
• type QuerySample
  • func NewQuerySample(args QuerySampleArguments) (*QuerySample, error)
  • 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) Start(ctx context.Context) error
  • func (c *SchemaTable) Stop()
• type SchemaTableArguments

Constants

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

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

Types

type ConnectionInfo

type ConnectionInfo struct {
	DSN        string
	Registry   *prometheus.Registry
	InfoMetric *prometheus.GaugeVec
}

func NewConnectionInfo

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

func (*ConnectionInfo) Start

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

func (*ConnectionInfo) Stop

func (c *ConnectionInfo) Stop()

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) 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
	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) Start

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

func (*SchemaTable) Stop

func (c *SchemaTable) Stop()

Stop should be kept idempotent

type SchemaTableArguments

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

	Logger log.Logger
}