collector

package

v0.0.0-...-2782659 Latest Latest Go to latest Published: Apr 9, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openshift-pipelines/pipeline-service-exporter

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewManager(cfg *rest.Config, options ctrl.Options) (ctrl.Manager, error)
func NewPipelineReferenceWaitTimeMetric() *prometheus.HistogramVec
func NewPipelineRunScheduledMetric() *prometheus.HistogramVec
func NewPodCreateToCompleteFilter() *podCreateToCompleteFilter
func NewPodCreateToCompleteMetric() *prometheus.HistogramVec
func NewPodCreateToKubeletDurationMetric() *prometheus.HistogramVec
func NewPodKubeletToContainerStartDurationMetric() *prometheus.HistogramVec
func NewTaskReferenceWaitTimeMetric() *prometheus.HistogramVec
func NewTaskRunScheduledMetric() *prometheus.HistogramVec
func SetupController(mgr ctrl.Manager) error
type ExporterFilter
- func (f *ExporterFilter) Create(event.CreateEvent) bool
- func (f *ExporterFilter) Delete(event.DeleteEvent) bool
- func (f *ExporterFilter) Generic(event.GenericEvent) bool
- func (f ExporterFilter) Update(e event.UpdateEvent) bool
type ExporterReconcile
- func (r *ExporterReconcile) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
- func (r *ExporterReconcile) ReconcileOverhead(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
- func (r *ExporterReconcile) ReconcilePipelineRunTaskRunGap(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
- func (r *ExporterReconcile) Start(ctx context.Context) error
type GapEntry
type OverheadCollector
- func NewOverheadCollector() *OverheadCollector
type PipelineRunScheduledCollector
type PipelineRunTaskRunGapCollector
- func NewPipelineRunTaskRunGapCollector() *PipelineRunTaskRunGapCollector
type PodKubeletToContainerLatencyCollector
type PollCollector
type ReconcileOverhead
type ReconcilePipelineRunTaskRunGap
type ThrottledByPVCQuotaCollector
- func NewPVCThrottledCollector() *ThrottledByPVCQuotaCollector
- func (c *ThrottledByPVCQuotaCollector) IncCollector(ns string)
- func (c *ThrottledByPVCQuotaCollector) ZeroCollector(ns string)
type WaitingOnPodCreateAttemptCollector
- func NewWaitingOnPodCreateAttemptCollector() *WaitingOnPodCreateAttemptCollector
- func (c *WaitingOnPodCreateAttemptCollector) IncCollector(ns string)
- func (c *WaitingOnPodCreateAttemptCollector) ZeroCollector(ns string)

Constants ¶

View Source

const (
	FILTER_THRESHOLD                    = "FILTER_THRESHOLD"
	DEFAULT_THRESHOLD                   = float64(300000) // 5 minutes in milliseconds
	ALERT_RATIO                         = float64(0.05)
	ENABLE_GAP_METRIC_ADDITIONAL_LABELS = "ENABLE_GAP_METRIC_ADDITIONAL_LABELS"
	NS_LABEL                            = "namespace"
	PIPELINE_NAME_LABEL                 = "pipelinename"
	TASK_NAME_LABEL                     = "taskname"
	COMPLETED_LABEL                     = "completed"
	UPCOMING_LABEL                      = "upcoming"
	STATUS_LABEL                        = "status"
	SUCCEEDED                           = "succeded"
	FAILED                              = "failed"
	THROTTLED_LABEL                     = "pipelineservice.appstudio.io/throttled"
)

Variables ¶

This section is empty.

Functions ¶

func NewManager ¶

func NewManager(cfg *rest.Config, options ctrl.Options) (ctrl.Manager, error)

func NewPipelineReferenceWaitTimeMetric ¶

func NewPipelineReferenceWaitTimeMetric() *prometheus.HistogramVec

func NewPipelineRunScheduledMetric ¶

func NewPipelineRunScheduledMetric() *prometheus.HistogramVec

func NewPodCreateToCompleteFilter ¶

func NewPodCreateToCompleteFilter() *podCreateToCompleteFilter

func NewPodCreateToCompleteMetric ¶

func NewPodCreateToCompleteMetric() *prometheus.HistogramVec

func NewPodCreateToKubeletDurationMetric ¶

func NewPodCreateToKubeletDurationMetric() *prometheus.HistogramVec

func NewPodKubeletToContainerStartDurationMetric ¶

func NewPodKubeletToContainerStartDurationMetric() *prometheus.HistogramVec

func NewTaskReferenceWaitTimeMetric ¶

func NewTaskReferenceWaitTimeMetric() *prometheus.HistogramVec

func NewTaskRunScheduledMetric ¶

func NewTaskRunScheduledMetric() *prometheus.HistogramVec

func SetupController ¶

func SetupController(mgr ctrl.Manager) error

Types ¶

type ExporterFilter ¶

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

func (*ExporterFilter) Create ¶

func (f *ExporterFilter) Create(event.CreateEvent) bool

func (*ExporterFilter) Delete ¶

func (f *ExporterFilter) Delete(event.DeleteEvent) bool

func (*ExporterFilter) Generic ¶

func (f *ExporterFilter) Generic(event.GenericEvent) bool

func (ExporterFilter) Update ¶

func (f ExporterFilter) Update(e event.UpdateEvent) bool

type ExporterReconcile ¶

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

func (*ExporterReconcile) Reconcile ¶

func (r *ExporterReconcile) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*ExporterReconcile) ReconcileOverhead ¶

func (r *ExporterReconcile) ReconcileOverhead(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*ExporterReconcile) ReconcilePipelineRunTaskRunGap ¶

func (r *ExporterReconcile) ReconcilePipelineRunTaskRunGap(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*ExporterReconcile) Start ¶

func (r *ExporterReconcile) Start(ctx context.Context) error

Start - we do a long running runnable to reset the pvc metric in case we miss delete events, as controller relist does not duplicate delete events like it can create/update events

type GapEntry ¶

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

type OverheadCollector ¶

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

func NewOverheadCollector ¶

func NewOverheadCollector() *OverheadCollector

type PipelineRunScheduledCollector ¶

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

type PipelineRunTaskRunGapCollector ¶

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

func NewPipelineRunTaskRunGapCollector ¶

func NewPipelineRunTaskRunGapCollector() *PipelineRunTaskRunGapCollector

type PodKubeletToContainerLatencyCollector ¶

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

type PollCollector ¶

type PollCollector interface {
	IncCollector(ns string)
	ZeroCollector(ns string)
}

type ReconcileOverhead ¶

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

type ReconcilePipelineRunTaskRunGap ¶

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

type ThrottledByPVCQuotaCollector ¶

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

func NewPVCThrottledCollector ¶

func NewPVCThrottledCollector() *ThrottledByPVCQuotaCollector

func (*ThrottledByPVCQuotaCollector) IncCollector ¶

func (c *ThrottledByPVCQuotaCollector) IncCollector(ns string)

func (*ThrottledByPVCQuotaCollector) ZeroCollector ¶

func (c *ThrottledByPVCQuotaCollector) ZeroCollector(ns string)

type WaitingOnPodCreateAttemptCollector ¶

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

func NewWaitingOnPodCreateAttemptCollector ¶

func NewWaitingOnPodCreateAttemptCollector() *WaitingOnPodCreateAttemptCollector

func (*WaitingOnPodCreateAttemptCollector) IncCollector ¶

func (c *WaitingOnPodCreateAttemptCollector) IncCollector(ns string)

func (*WaitingOnPodCreateAttemptCollector) ZeroCollector ¶

func (c *WaitingOnPodCreateAttemptCollector) ZeroCollector(ns string)

Source Files ¶

View all Source files

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