sqlserver

Documentation

Index

• type InsertItem
• type InsertKey
• type MetricGroup
• type SqlServer
  • func (s *SqlServer) AddColumn(table string, column string) error
  • func (s *SqlServer) Close() error
  • func (s *SqlServer) ColumnExists(err error) (bool, string, string)
  • func (s *SqlServer) Connect() error
  • func (s *SqlServer) Description() string
  • func (s *SqlServer) HandleInserts_Batch(i int, insertItems []InsertItem) error
  • func (s *SqlServer) SampleConfig() string
  • func (s *SqlServer) Write(metrics []telegraf.Metric) error
  • func (s *SqlServer) WriteDB_Batch(txn *sql.Tx, insertItems []InsertItem) error
  • func (s *SqlServer) WriteMetrics(id int)

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 SqlServer

type SqlServer 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 (*SqlServer) AddColumn

func (s *SqlServer) AddColumn(table string, column string) error

func (*SqlServer) Close

func (s *SqlServer) Close() error

func (*SqlServer) ColumnExists

func (s *SqlServer) ColumnExists(err error) (bool, string, string)

func (*SqlServer) Connect

func (s *SqlServer) Connect() error

func (*SqlServer) Description

func (s *SqlServer) Description() string

func (*SqlServer) HandleInserts_Batch

func (s *SqlServer) HandleInserts_Batch(i int, insertItems []InsertItem) error

func (*SqlServer) SampleConfig

func (s *SqlServer) SampleConfig() string

func (*SqlServer) Write

func (s *SqlServer) Write(metrics []telegraf.Metric) error

func (*SqlServer) WriteDB_Batch

func (s *SqlServer) WriteDB_Batch(txn *sql.Tx, insertItems []InsertItem) error

func (*SqlServer) WriteMetrics

func (s *SqlServer) WriteMetrics(id int)