postgresql

README

PostgreSQL Output Plugin

This output plugin writes all metrics to PostgreSQL.

Configuration:

# Send metrics to postgres
[[outputs.postgresql]]
  address = "host=localhost user=postgres sslmode=verify-full"

  ## A list of tags to exclude from storing. If not specified, all tags are stored.
  # ignored_tags = ["foo", "bar"]

  ## Store tags as foreign keys in the metrics table. Default is false.
  # tags_as_foreignkeys = false

Documentation

Index

• func PostgreSQL_Copy(txn *sql.Tx, insertItem InsertItem) error
• type InsertItem
• type InsertKey
• type MetricGroup
• type Postgresql
  • func (p *Postgresql) AddColumn(table string, column string) error
  • func (p *Postgresql) Close() error
  • func (p *Postgresql) ColumnExists(err error) (bool, string, string)
  • func (p *Postgresql) Connect() error
  • func (p *Postgresql) Description() string
  • func (p *Postgresql) HandleInserts_Batch(i int, insertItems map[string]InsertItem) error
  • func (p *Postgresql) HandleInserts_Copy(i int, insertItem InsertItem, pwg *sync.WaitGroup) error
  • func (p *Postgresql) PostgreSQL_Batch(txn *sql.Tx, insertItems map[string]InsertItem) error
  • func (p *Postgresql) SampleConfig() string
  • func (p *Postgresql) Write(metrics []telegraf.Metric) error
  • func (p *Postgresql) WriteMetrics(id int)

Functions

func PostgreSQL_Copy

func PostgreSQL_Copy(txn *sql.Tx, insertItem InsertItem) error

Types

type InsertItem

type InsertItem struct {
	TableName string
	Columns   []string
	Values    []interface{}
	Types     map[string]string
}

type InsertKey

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

type MetricGroup

type MetricGroup struct {
	Metrics   []telegraf.Metric
	Timestamp time.Time
}

type Postgresql

type Postgresql struct {
	Address           string
	TagsAsForeignkeys bool
	TagsAsJsonb       bool
	FieldsAsJsonb     bool
	Timestamp         string
	TableTemplate     string
	TagTableSuffix    string
	Tables            map[string]bool
	QueueDataDir      string
	Connections       int
	MaxItems          uint64
	TagKey            []string
	Strategy          string
	Exclude           []string
	// contains filtered or unexported fields
}

func (*Postgresql) AddColumn

func (p *Postgresql) AddColumn(table string, column string) error

func (*Postgresql) Close

func (p *Postgresql) Close() error

func (*Postgresql) ColumnExists

func (p *Postgresql) ColumnExists(err error) (bool, string, string)

func (*Postgresql) Connect

func (p *Postgresql) Connect() error

func (*Postgresql) Description

func (p *Postgresql) Description() string

func (*Postgresql) HandleInserts_Batch

func (p *Postgresql) HandleInserts_Batch(i int, insertItems map[string]InsertItem) error

func (*Postgresql) HandleInserts_Copy

func (p *Postgresql) HandleInserts_Copy(i int, insertItem InsertItem, pwg *sync.WaitGroup) error

func (*Postgresql) PostgreSQL_Batch

func (p *Postgresql) PostgreSQL_Batch(txn *sql.Tx, insertItems map[string]InsertItem) error

func (*Postgresql) SampleConfig

func (p *Postgresql) SampleConfig() string

func (*Postgresql) Write

func (p *Postgresql) Write(metrics []telegraf.Metric) error

func (*Postgresql) WriteMetrics

func (p *Postgresql) WriteMetrics(id int)