metrics

Documentation

Overview

Package metrics is a generated protocol buffer package.

It is generated from these files:

server/pkg/metrics/metrics.proto

It has these top-level messages:

Metrics

Index

• func ReportMetrics(clusterID string, kubeClient *kube.Client, address string, pfsDbName string, ...)
• type Metrics
  • func (*Metrics) Descriptor() ([]byte, []int)
  • func (*Metrics) ProtoMessage()
  • func (m *Metrics) Reset()
  • func (m *Metrics) String() string

Functions

func ReportMetrics

func ReportMetrics(clusterID string, kubeClient *kube.Client, address string, pfsDbName string, ppsDbName string)

ReportMetrics blocks and reports metrics, if modified, to the given kubernetes client every 15 seconds.

Types

type Metrics

type Metrics struct {
	ID               string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	PodID            string `protobuf:"bytes,2,opt,name=pod_id,json=podId" json:"pod_id,omitempty"`
	Nodes            int64  `protobuf:"varint,3,opt,name=nodes" json:"nodes,omitempty"`
	Version          string `protobuf:"bytes,4,opt,name=version" json:"version,omitempty"`
	Repos            int64  `protobuf:"varint,5,opt,name=repos" json:"repos,omitempty"`
	Commits          int64  `protobuf:"varint,6,opt,name=commits" json:"commits,omitempty"`
	Files            int64  `protobuf:"varint,7,opt,name=files" json:"files,omitempty"`
	Bytes            int64  `protobuf:"varint,8,opt,name=bytes" json:"bytes,omitempty"`
	Jobs             int64  `protobuf:"varint,9,opt,name=jobs" json:"jobs,omitempty"`
	Pipelines        int64  `protobuf:"varint,10,opt,name=pipelines" json:"pipelines,omitempty"`
	ArchivedCommits  int64  `protobuf:"varint,11,opt,name=archived_commits,json=archivedCommits" json:"archived_commits,omitempty"`
	CancelledCommits int64  `protobuf:"varint,12,opt,name=cancelled_commits,json=cancelledCommits" json:"cancelled_commits,omitempty"`
}

func (*Metrics) Descriptor

func (*Metrics) Descriptor() ([]byte, []int)

func (*Metrics) ProtoMessage

func (*Metrics) ProtoMessage()

func (*Metrics) Reset

func (m *Metrics) Reset()

func (*Metrics) String

func (m *Metrics) String() string