Documentation ¶
Index ¶
- Variables
- func FinishReportAndFlushUserAction(action string, err error, start time.Time) func()
- func ReportUserAction(ctx context.Context, r *Reporter, action string) func(time.Time, error)
- func StartReportAndFlushUserAction(action string, value interface{}) func()
- type Metrics
- func (*Metrics) Descriptor() ([]byte, []int)
- func (m *Metrics) GetActivationCode() string
- func (m *Metrics) GetArchivedCommits() int64
- func (m *Metrics) GetBytes() int64
- func (m *Metrics) GetCancelledCommits() int64
- func (m *Metrics) GetClusterID() string
- func (m *Metrics) GetCommits() int64
- func (m *Metrics) GetFiles() int64
- func (m *Metrics) GetJobs() int64
- func (m *Metrics) GetNodes() int64
- func (m *Metrics) GetPipelines() int64
- func (m *Metrics) GetPodID() string
- func (m *Metrics) GetRepos() int64
- func (m *Metrics) GetVersion() string
- func (m *Metrics) Marshal() (dAtA []byte, err error)
- func (m *Metrics) MarshalTo(dAtA []byte) (int, error)
- func (*Metrics) ProtoMessage()
- func (m *Metrics) Reset()
- func (m *Metrics) Size() (n int)
- func (m *Metrics) String() string
- func (m *Metrics) Unmarshal(dAtA []byte) error
- func (m *Metrics) XXX_DiscardUnknown()
- func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metrics) XXX_Merge(src proto.Message)
- func (m *Metrics) XXX_Size() int
- func (m *Metrics) XXX_Unmarshal(b []byte) error
- type Reporter
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthMetrics = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMetrics = fmt.Errorf("proto: integer overflow") )
Functions ¶
func FinishReportAndFlushUserAction ¶ added in v1.5.0
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
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"` ActivationCode string `protobuf:"bytes,13,opt,name=activation_code,json=activationCode,proto3" json:"activation_code,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Metrics) Descriptor ¶
func (*Metrics) GetActivationCode ¶ added in v1.9.0
func (*Metrics) GetArchivedCommits ¶ added in v1.3.5
func (*Metrics) GetCancelledCommits ¶ added in v1.3.5
func (*Metrics) GetClusterID ¶ added in v1.3.5
func (*Metrics) GetCommits ¶ added in v1.3.5
func (*Metrics) GetPipelines ¶ added in v1.3.5
func (*Metrics) GetVersion ¶ added in v1.3.5
func (*Metrics) ProtoMessage ¶
func (*Metrics) ProtoMessage()
func (*Metrics) XXX_DiscardUnknown ¶ added in v1.7.12
func (m *Metrics) XXX_DiscardUnknown()
func (*Metrics) XXX_Marshal ¶ added in v1.7.12
func (*Metrics) XXX_Unmarshal ¶ added in v1.7.12
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, env *serviceenv.ServiceEnv) *Reporter
NewReporter creates a new reporter and kicks off the loop to report cluster metrics