metrics

package
Version: v1.8.1 Latest Latest
Warning

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

Go to latest
Published: Dec 19, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMetrics = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetrics   = fmt.Errorf("proto: integer overflow")
)

Functions

func FinishReportAndFlushUserAction added in v1.5.0

func FinishReportAndFlushUserAction(action string, err error, start time.Time) func()

FinishReportAndFlushUserAction immediately reports the metric but does not block execution. It returns a wait function which waits or times out after 5s. It is used by the pachctl binary and runs on users' machines

func ReportUserAction added in v1.2.4

func ReportUserAction(ctx context.Context, r *Reporter, action string) func(time.Time, error)

ReportUserAction pushes the action into a queue for reporting, and reports the start, finish, and error conditions

func StartReportAndFlushUserAction added in v1.5.0

func StartReportAndFlushUserAction(action string, value interface{}) func()

StartReportAndFlushUserAction immediately reports the metric but does not block execution. It returns a wait function which waits or times out after 5s. It is used by the pachctl binary and runs on users' machines

Types

type Metrics

type Metrics struct {
	ClusterID            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	PodID                string   `protobuf:"bytes,2,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty"`
	Nodes                int64    `protobuf:"varint,3,opt,name=nodes,proto3" json:"nodes,omitempty"`
	Version              string   `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Repos                int64    `protobuf:"varint,5,opt,name=repos,proto3" json:"repos,omitempty"`
	Commits              int64    `protobuf:"varint,6,opt,name=commits,proto3" json:"commits,omitempty"`
	Files                int64    `protobuf:"varint,7,opt,name=files,proto3" json:"files,omitempty"`
	Bytes                int64    `protobuf:"varint,8,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Jobs                 int64    `protobuf:"varint,9,opt,name=jobs,proto3" json:"jobs,omitempty"`
	Pipelines            int64    `protobuf:"varint,10,opt,name=pipelines,proto3" json:"pipelines,omitempty"`
	ArchivedCommits      int64    `protobuf:"varint,11,opt,name=archived_commits,json=archivedCommits,proto3" json:"archived_commits,omitempty"`
	CancelledCommits     int64    `protobuf:"varint,12,opt,name=cancelled_commits,json=cancelledCommits,proto3" json:"cancelled_commits,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metrics) Descriptor

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

func (*Metrics) GetArchivedCommits added in v1.3.5

func (m *Metrics) GetArchivedCommits() int64

func (*Metrics) GetBytes added in v1.3.5

func (m *Metrics) GetBytes() int64

func (*Metrics) GetCancelledCommits added in v1.3.5

func (m *Metrics) GetCancelledCommits() int64

func (*Metrics) GetClusterID added in v1.3.5

func (m *Metrics) GetClusterID() string

func (*Metrics) GetCommits added in v1.3.5

func (m *Metrics) GetCommits() int64

func (*Metrics) GetFiles added in v1.3.5

func (m *Metrics) GetFiles() int64

func (*Metrics) GetJobs added in v1.3.5

func (m *Metrics) GetJobs() int64

func (*Metrics) GetNodes added in v1.3.5

func (m *Metrics) GetNodes() int64

func (*Metrics) GetPipelines added in v1.3.5

func (m *Metrics) GetPipelines() int64

func (*Metrics) GetPodID added in v1.3.5

func (m *Metrics) GetPodID() string

func (*Metrics) GetRepos added in v1.3.5

func (m *Metrics) GetRepos() int64

func (*Metrics) GetVersion added in v1.3.5

func (m *Metrics) GetVersion() string

func (*Metrics) Marshal added in v1.5.0

func (m *Metrics) Marshal() (dAtA []byte, err error)

func (*Metrics) MarshalTo added in v1.5.0

func (m *Metrics) MarshalTo(dAtA []byte) (int, error)

func (*Metrics) ProtoMessage

func (*Metrics) ProtoMessage()

func (*Metrics) Reset

func (m *Metrics) Reset()

func (*Metrics) Size added in v1.5.0

func (m *Metrics) Size() (n int)

func (*Metrics) String

func (m *Metrics) String() string

func (*Metrics) Unmarshal added in v1.5.0

func (m *Metrics) Unmarshal(dAtA []byte) error

func (*Metrics) XXX_DiscardUnknown added in v1.8.1

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal added in v1.8.1

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge added in v1.8.1

func (dst *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size added in v1.8.1

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal added in v1.8.1

func (m *Metrics) XXX_Unmarshal(b []byte) error

type Reporter added in v1.2.4

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

Reporter is used to submit user & cluster metrics to segment

func NewReporter added in v1.2.4

func NewReporter(clusterID string, kubeClient *kube.Clientset) *Reporter

NewReporter creates a new reporter and kicks off the loop to report cluster metrics

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL