Versions in this module Expand all Collapse all v0 v0.0.1 Jan 1, 2026 Changes in this version + const PgBigInt + const PgBool + const PgDoublePrecision + const PgInteger + const PgJSONb + const PgNumeric + const PgReal + const PgSerial + const PgSmallInt + const PgText + const PgTimestampWithTimeZone + const PgTimestampWithoutTimeZone + const PgUint8 + func NewTableSources(p *Postgresql, metrics []telegraf.Metric) map[string]*TableSource + type Postgresql struct + AddColumnTemplates []*sqltemplate.Template + ColumnNameLenLimit int + Connection config.Secret + CreateTemplates []*sqltemplate.Template + FieldsAsJsonb bool + ForeignTagConstraint bool + LogLevel string + Logger telegraf.Logger + RetryMaxBackoff config.Duration + Schema string + TagCacheSize int + TagTableAddColumnTemplates []*sqltemplate.Template + TagTableCreateTemplates []*sqltemplate.Template + TagTableSuffix string + TagsAsForeignKeys bool + TagsAsJsonb bool + TimestampColumnName string + TimestampColumnType string + Uint64Type string + func (*Postgresql) SampleConfig() string + func (p *Postgresql) Close() error + func (p *Postgresql) Connect() error + func (p *Postgresql) Init() error + func (p *Postgresql) Write(metrics []telegraf.Metric) error + type TableManager struct + func NewTableManager(postgresql *Postgresql) *TableManager + func (tm *TableManager) ClearTableCache() + func (tm *TableManager) EnsureStructure(ctx context.Context, db dbh, tbl *tableState, columns []utils.Column, ...) ([]utils.Column, error) + func (tm *TableManager) MatchSource(ctx context.Context, db dbh, rowSource *TableSource) error + type TableSource struct + func NewTableSource(postgresql *Postgresql, name string) *TableSource + func (*TableSource) Err() error + func (tsrc *TableSource) AddMetric(metric telegraf.Metric) + func (tsrc *TableSource) ColumnNames() []string + func (tsrc *TableSource) DropColumn(col utils.Column) error + func (tsrc *TableSource) FieldColumns() []utils.Column + func (tsrc *TableSource) MetricTableColumns() []utils.Column + func (tsrc *TableSource) Name() string + func (tsrc *TableSource) Next() bool + func (tsrc *TableSource) Reset() + func (tsrc *TableSource) TagColumns() []utils.Column + func (tsrc *TableSource) TagTableColumns() []utils.Column + func (tsrc *TableSource) Values() ([]interface{}, error) + type TagTableSource struct + func NewTagTableSource(tsrc *TableSource) *TagTableSource + func (*TagTableSource) Err() error + func (ttsrc *TagTableSource) ColumnNames() []string + func (ttsrc *TagTableSource) Name() string + func (ttsrc *TagTableSource) Next() bool + func (ttsrc *TagTableSource) Reset() + func (ttsrc *TagTableSource) UpdateCache() + func (ttsrc *TagTableSource) Values() ([]interface{}, error) + type Uint8 struct + Int uint64 + Status pgtype.Status + func (u *Uint8) AssignTo(dst interface{}) error + func (u *Uint8) DecodeBinary(_, src []byte) error + func (u *Uint8) DecodeText(_, src []byte) error + func (u *Uint8) EncodeBinary(_, buf []byte) ([]byte, error) + func (u *Uint8) EncodeText(_, buf []byte) ([]byte, error) + func (u *Uint8) Get() interface{} + func (u *Uint8) MarshalJSON() ([]byte, error) + func (u *Uint8) Scan(src interface{}) error + func (u *Uint8) Set(src interface{}) error + func (u *Uint8) UnmarshalJSON(b []byte) error + func (u *Uint8) Value() (driver.Value, error)
Go to main page