rethinkdb

Documentation

Index

• Variables
• type Address
• type Cache
• type Disk
• type Engine
  • func (e *Engine) AddEngineStats(keys []string, acc telegraf.Accumulator, tags map[string]string)
• type RethinkDB
  • func (r *RethinkDB) Description() string
  • func (r *RethinkDB) Gather(acc telegraf.Accumulator) error
  • func (r *RethinkDB) SampleConfig() string
• type Server
• type SpaceUsage
• type Storage
  • func (s *Storage) AddStats(acc telegraf.Accumulator, tags map[string]string)

Variables

var ClusterTracking = []string{
	"active_clients",
	"clients",
	"queries_per_sec",
	"read_docs_per_sec",
	"written_docs_per_sec",
}

var MemberTracking = []string{
	"active_clients",
	"clients",
	"queries_per_sec",
	"total_queries",
	"read_docs_per_sec",
	"total_reads",
	"written_docs_per_sec",
	"total_writes",
}

var TableTracking = []string{
	"read_docs_per_sec",
	"total_reads",
	"written_docs_per_sec",
	"total_writes",
}

Types

type Address

type Address struct {
	Host string `gorethink:"host"`
	Port int    `gorethink:"port"`
}

type Cache

type Cache struct {
	BytesInUse int64 `gorethink:"in_use_bytes"`
}

type Disk

type Disk struct {
	ReadBytesPerSec  int64      `gorethink:"read_bytes_per_sec"`
	ReadBytesTotal   int64      `gorethink:"read_bytes_total"`
	WriteBytesPerSec int64      `gorethik:"written_bytes_per_sec"`
	WriteBytesTotal  int64      `gorethink:"written_bytes_total"`
	SpaceUsage       SpaceUsage `gorethink:"space_usage"`
}

type Engine

type Engine struct {
	ClientConns   int64 `gorethink:"client_connections,omitempty"`
	ClientActive  int64 `gorethink:"clients_active,omitempty"`
	QueriesPerSec int64 `gorethink:"queries_per_sec,omitempty"`
	TotalQueries  int64 `gorethink:"queries_total,omitempty"`
	ReadsPerSec   int64 `gorethink:"read_docs_per_sec,omitempty"`
	TotalReads    int64 `gorethink:"read_docs_total,omitempty"`
	WritesPerSec  int64 `gorethink:"written_docs_per_sec,omitempty"`
	TotalWrites   int64 `gorethink:"written_docs_total,omitempty"`
}

func (*Engine) AddEngineStats

func (e *Engine) AddEngineStats(
	keys []string,
	acc telegraf.Accumulator,
	tags map[string]string,
)

type RethinkDB

type RethinkDB struct {
	Servers []string
}

func (*RethinkDB) Description

func (r *RethinkDB) Description() string

func (*RethinkDB) Gather

func (r *RethinkDB) Gather(acc telegraf.Accumulator) error

Reads stats from all configured servers accumulates stats. Returns one of the errors encountered while gather stats (if any).

func (*RethinkDB) SampleConfig

func (r *RethinkDB) SampleConfig() string

type Server

type Server struct {
	Url *url.URL
	// contains filtered or unexported fields
}

type SpaceUsage

type SpaceUsage struct {
	Data     int64 `gorethink:"data_bytes"`
	Garbage  int64 `gorethink:"garbage_bytes"`
	Metadata int64 `gorethink:"metadata_bytes"`
	Prealloc int64 `gorethink:"preallocated_bytes"`
}

type Storage

type Storage struct {
	Cache Cache `gorethink:"cache"`
	Disk  Disk  `gorethink:"disk"`
}

func (*Storage) AddStats

func (s *Storage) AddStats(acc telegraf.Accumulator, tags map[string]string)