lib

package
v29.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 14, 2020 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const AllDbs = "_all_dbs"

Variables

This section is empty.

Functions

This section is empty.

Types

type ActiveTask 

type ActiveTask struct {
	Type       string  `json:"type"`
	Node       string  `json:"node,omitempty"`
	Continuous bool    `json:"continuous,omitempty"`
	UpdatedOn  float64 `json:"updated_on,omitempty"`
	Source     string  `json:"source,omitempty"`
	Target     string  `json:"target,omitempty"`
	DocId      string  `json:"doc_id,omitempty"`
}

type ActiveTaskTypes 

type ActiveTaskTypes struct {
	DatabaseCompaction float64
	ViewCompaction     float64
	Indexer            float64
	Replication        float64
	Sum                float64
}

type ActiveTaskTypesByNodeName 

type ActiveTaskTypesByNodeName map[string]ActiveTaskTypes

type ActiveTasksResponse 

type ActiveTasksResponse []ActiveTask

type BasicAuth 

type BasicAuth struct {
	Username string
	Password string
}

type CollectorConfig 

type CollectorConfig struct {
	Databases            []string
	ObservedDatabases    []string
	CollectViews         bool
	CollectSchedulerJobs bool
	ConcurrentRequests   uint
}

type CouchReplicator 

type CouchReplicator struct {
	ChangesReadFailures  Counter            `json:"changes_read_failures"`
	ChangesReaderDeaths  Counter            `json:"changes_reader_deaths"`
	ChangesManagerDeaths Counter            `json:"changes_manager_deaths"`
	ChangesQueueDeaths   Counter            `json:"changes_queue_deaths"`
	Checkpoints          map[string]Counter `json:"checkpoints"`
	FailedStarts         Counter            `json:"failed_starts"`
	Requests             Counter            `json:"requests"`
	Responses            map[string]Counter `json:"responses"`
	StreamResponses      map[string]Counter `json:"stream_responses"`
	WorkerDeaths         Counter            `json:"worker_deaths"`
	WorkersStarted       Counter            `json:"workers_started"`
	ClusterIsStable      Counter            `json:"cluster_is_stable"`
	DbScans              Counter            `json:"db_scans"`
	Docs                 map[string]Counter `json:"docs"`
	Jobs                 map[string]Counter `json:"jobs"`
	Connection           map[string]Counter `json:"connection"`
}

type CouchdbClient 

type CouchdbClient struct {
	BaseUri string

	ResetRequestCount func()
	GetRequestCount   func() int
	// contains filtered or unexported fields
}

func NewCouchdbClient 

func NewCouchdbClient(uri string, basicAuth BasicAuth, insecure bool) *CouchdbClient

func (*CouchdbClient) GetNodeNames 

func (c *CouchdbClient) GetNodeNames() ([]string, error)

func (*CouchdbClient) Request 

func (c *CouchdbClient) Request(method string, uri string, body io.Reader) (respData []byte, err error)

type CouchdbStats 

type CouchdbStats struct {
	// v1.x, and v2.x api
	AuthCacheHits   Counter   `json:"auth_cache_hits"`
	AuthCacheMisses Counter   `json:"auth_cache_misses"`
	DatabaseReads   Counter   `json:"database_reads"`
	DatabaseWrites  Counter   `json:"database_writes"`
	OpenDatabases   Counter   `json:"open_databases"`
	OpenOsFiles     Counter   `json:"open_os_files"`
	RequestTime     Histogram `json:"request_time"`
	// v2.x api
	Httpd               Httpd               `json:"httpd"`
	HttpdRequestMethods HttpdRequestMethods `json:"httpd_request_methods"`
	HttpdStatusCodes    HttpdStatusCodes    `json:"httpd_status_codes"`
}

type Counter 

type Counter struct {
	// v1.x api
	Description string
	Current     float64
	// v2.x api
	Value float64
	Type  string
	Desc  string
}

type DatabaseProps 

type DatabaseProps struct {
	Partitioned bool `json:"partitioned"`
}

v3.x api

type DatabaseSizes 

type DatabaseSizes struct {
	Active   float64 `json:"active"`   // data_size
	File     float64 `json:"file"`     // disk_size
	External float64 `json:"external"` // uncompressed database content size
}

v2.x api

type DatabaseStats 

type DatabaseStats struct {
	DataSize           float64       `json:"data_size"`
	DiskSize           float64       `json:"disk_size"`
	Sizes              DatabaseSizes `json:"sizes,omitempty"`
	DiskSizeOverhead   float64
	DocCount           float64 `json:"doc_count"`
	DocDelCount        float64 `json:"doc_del_count"`
	CompactRunningBool bool    `json:"compact_running"`
	CompactRunning     float64
	DiskFormatVersion  float64         `json:"disk_format_version"`
	UpdateSeq          json.RawMessage `json:"update_seq"`
	Views              ViewStatsByDesignDocName
	Props              DatabaseProps `json:"props,omitempty"`
}

type DatabaseStatsByDbName 

type DatabaseStatsByDbName map[string]DatabaseStats

type Doc 

type Doc struct {
	Id    string          `json:"_id"`
	Views map[string]View `json:"views"`
}

type DocsResponse 

type DocsResponse struct {
	Rows Rows `json:"rows"`
}

type Exporter 

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

func NewExporter 

func NewExporter(uri string, basicAuth BasicAuth, collectorConfig CollectorConfig, insecure bool) *Exporter

func (*Exporter) Collect 

func (e *Exporter) Collect(ch chan<- prometheus.Metric)

Collect fetches the stats from configured couchdb location and delivers them as Prometheus metrics. It implements prometheus.Collector.

func (*Exporter) Describe 

func (e *Exporter) Describe(ch chan<- *prometheus.Desc)

Describe describes all the metrics ever exported by the couchdb exporter. It implements prometheus.Collector.

type Fabric 

type Fabric struct {
	Worker      map[string]Counter `json:"worker"`
	OpenShard   map[string]Counter `json:"open_shard"`
	ReadRepairs map[string]Counter `json:"read_repairs"`
	DocUpdate   map[string]Counter `json:"doc_update"`
}

type Histogram 

type Histogram struct {
	// v1.x api
	Description string
	Current     float64 `json:"current"`
	Min         float64 `json:"min"`
	Max         float64 `json:"max"`
	Mean        float64 `json:"mean"`
	Sum         float64 `json:"sum"`
	Stddev      float64 `json:"stddev"`

	// v2.x api
	Value HistogramValue
	Type  string
	Desc  string
}

type HistogramValue 

type HistogramValue struct {
	Min               float64     `json:"min"`
	Max               float64     `json:"max"`
	ArithmeticMean    float64     `json:"arithmetic_mean"`
	GeometricMean     float64     `json:"geometric_mean"`
	HarmonicMean      float64     `json:"harmonic_mean"`
	Median            float64     `json:"median"`
	Variance          float64     `json:"variance"`
	StandardDeviation float64     `json:"standard_deviation"`
	Skewness          float64     `json:"skewness"`
	Kurtosis          float64     `json:"kurtosis"`
	Percentile        [][]float64 `json:"percentile"`
	N                 float64     `json:"n"`
}

v2.x api

type HttpError 

type HttpError struct {
	Status     string
	StatusCode int
	RespBody   []byte
}

func (*HttpError) Error 

func (httpError *HttpError) Error() string

type Httpd 

type Httpd struct {
	BulkRequests             Counter `json:"bulk_requests"`
	ClientsRequestingChanges Counter `json:"clients_requesting_changes"`
	Requests                 Counter `json:"requests"`
	TemporaryViewReads       Counter `json:"temporary_view_reads"`
	ViewReads                Counter `json:"view_reads"`
}

type HttpdRequestMethods 

type HttpdRequestMethods struct {
	COPY   Counter `json:"COPY"`
	DELETE Counter `json:"DELETE"`
	GET    Counter `json:"GET"`
	HEAD   Counter `json:"HEAD"`
	POST   Counter `json:"POST"`
	PUT    Counter `json:"PUT"`
}

type HttpdStatusCodes 

type HttpdStatusCodes map[string]Counter

type LogLevel 

type LogLevel struct {
	Level map[string]Counter `json:"level"`
}

type MangoStats added in v29.3.0 

type MangoStats struct {
	UnindexedQueries   Counter   `json:"unindexed_queries"`
	QueryInvalidIndex  Counter   `json:"query_invalid_index"`
	TooManyDocs        Counter   `json:"too_many_docs_scanned"`
	DocsExamined       Counter   `json:"docs_examined"`
	QuorumDocsExamined Counter   `json:"quorum_docs_examined"`
	ResultsReturned    Counter   `json:"results_returned"`
	QueryTime          Histogram `json:"query_time"`
	EvaluateSelector   Counter   `json:"evaluate_selector"`
}

type MembershipResponse 

type MembershipResponse struct {
	AllNodes     []string `json:"all_nodes"`
	ClusterNodes []string `json:"cluster_nodes"`
}

type MemoryMetrics 

type MemoryMetrics struct {
	Other         float64
	Atom          float64
	AtomUsed      float64
	Processes     float64
	ProcessesUsed float64
	Binary        float64
	Code          float64
	Ets           float64
}

type MemoryStats 

type MemoryStats struct {
	// v2.x api
	Other         float64 `json:"other"`
	Atom          float64 `json:"atom"`
	AtomUsed      float64 `json:"atom_used"`
	Processes     float64 `json:"processes"`
	ProcessesUsed float64 `json:"processes_used"`
	Binary        float64 `json:"binary"`
	Code          float64 `json:"code"`
	Ets           float64 `json:"ets"`
}

type MemoryTypesByNodeName 

type MemoryTypesByNodeName map[string]MemoryMetrics

type NodeFeatures 

type NodeFeatures []string

type NodeInfo 

type NodeInfo struct {
	Couchdb  string       `json:"couchdb"`
	Features NodeFeatures `json:"features"`
	Vendor   Vendor       `json:"vendor"`
	Version  string       `json:"version"`
}

type Percent 

type Percent map[int]float64

type Row 

type Row struct {
	Id  string `json:"id"`
	Doc Doc    `json:"doc"`
}

type Rows 

type Rows []Row

type SchedulerJobsResponse 

type SchedulerJobsResponse struct {
	TotalRows int `json:"total_rows"`
	Offset    int `json:"offset"`
	Jobs      []struct {
		Database string `json:"database"`
		ID       string `json:"id"`
		Pid      string `json:"pid"`
		Source   string `json:"source"`
		Target   string `json:"target"`
		User     string `json:"user"`
		DocID    string `json:"doc_id"`
		History  []struct {
			Timestamp time.Time `json:"timestamp"`
			Type      string    `json:"type"`
		} `json:"history"`
		Node      string    `json:"node"`
		StartTime time.Time `json:"start_time"`
	} `json:"jobs"`
}

type Semaphore 

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

func NewSemaphore 

func NewSemaphore(concurrency uint) Semaphore

NewSemaphore for concurrency, concurrency == 0 means unlimited

func (Semaphore) Abort 

func (s Semaphore) Abort()

Signal abort for anyone waiting on the Semaphore

func (Semaphore) Acquire 

func (s Semaphore) Acquire() error

Acquire the semaphore; blocks until ready, or returns error to indicate the goroutine should abort

func (Semaphore) Release 

func (s Semaphore) Release()

type Stats 

type Stats struct {
	StatsByNodeName       map[string]StatsResponse
	DatabasesTotal        int
	DatabaseStatsByDbName DatabaseStatsByDbName
	ActiveTasksResponse   ActiveTasksResponse
	// SchedulerJobsResponse: CouchDB 2.x+ only
	SchedulerJobsResponse SchedulerJobsResponse
	SystemByNodeName      map[string]SystemResponse
	ApiVersion            string
}

type StatsResponse 

type StatsResponse struct {
	Couchdb  CouchdbStats `json:"couchdb"`
	Mango    MangoStats   `json:"mango"`
	Up       float64      `json:"-"`
	NodeInfo NodeInfo     `json:"-"`
	// v1.x api
	Httpd               Httpd               `json:"httpd"`
	HttpdRequestMethods HttpdRequestMethods `json:"httpd_request_methods"`
	HttpdStatusCodes    HttpdStatusCodes    `json:"httpd_status_codes"`
	// v2.x api
	CouchLog        LogLevel        `json:"couch_log"`
	Fabric          Fabric          `json:"fabric"`
	CouchReplicator CouchReplicator `json:"couch_replicator"`
}

type SystemResponse 

type SystemResponse struct {
	MemoryStatsResponse MemoryStats `json:"memory"`
}

type UpdateSequence 

type UpdateSequence struct {
	Node  string
	Range []*big.Int
	Seq   int
}

func DecodeUpdateSeq 

func DecodeUpdateSeq(updateSeq string) ([]UpdateSequence, error)

type Vendor 

type Vendor struct {
	Name string `json:"name"`
}

type View 

type View map[string]interface{}

type ViewResponse 

type ViewResponse struct {
	UpdateSeq json.RawMessage `json:"update_seq"`
	Error     string          `json:"error,omitempty"`
	Reason    string          `json:"reason,omitempty"`
}

type ViewStats 

type ViewStats map[string]string

type ViewStatsByDesignDocName 

type ViewStatsByDesignDocName map[string]ViewStats

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.