rds

Documentation

Index

• type Collector
  • func NewCollector(sess *session.Session, i *rds.DBInstance, dbConf DbCollectorConf) (*Collector, error)
  • func (c *Collector) Close()
  • func (c *Collector) Collect(ch chan<- prometheus.Metric)
  • func (c *Collector) Describe(ch chan<- *prometheus.Desc)
• type DbCollector
• type DbCollectorConf
• type Discoverer
  • func NewDiscoverer(reg prometheus.Registerer, awsSession *session.Session, ...) *Discoverer
  • func (d *Discoverer) Run()
• type LogReader
  • func NewLogReader(api rdsiface.RDSAPI, instanceId *string, ch chan<- logparser.LogEntry, ...) *LogReader
  • func (r *LogReader) Stop()

Types

type Collector

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

func NewCollector

func NewCollector(sess *session.Session, i *rds.DBInstance, dbConf DbCollectorConf) (*Collector, error)

func (*Collector) Close

func (c *Collector) Close()

func (*Collector) Collect

func (c *Collector) Collect(ch chan<- prometheus.Metric)

func (*Collector) Describe

func (c *Collector) Describe(ch chan<- *prometheus.Desc)

type DbCollector

type DbCollector interface {
	prometheus.Collector
	Close() error
}

type DbCollectorConf

type DbCollectorConf struct {
	User           string
	Password       string
	ConnectTimeout time.Duration
	QueryTimeout   time.Duration

	LogsScrapeInterval time.Duration
	DbScrapeInterval   time.Duration
}

type Discoverer

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

func NewDiscoverer

func NewDiscoverer(reg prometheus.Registerer, awsSession *session.Session, discoveryInterval time.Duration, dbConf DbCollectorConf) *Discoverer

func (*Discoverer) Run

func (d *Discoverer) Run()

type LogReader

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

supports only Postgresql RDS log for now need more work to support for example Mysql RDS logs, because of rotation

func NewLogReader

func NewLogReader(api rdsiface.RDSAPI, instanceId *string, ch chan<- logparser.LogEntry, refreshInterval time.Duration, logger logger.Logger) *LogReader

func (*LogReader) Stop

func (r *LogReader) Stop()