recorder

package
v0.0.0-...-99d5794 Latest Latest
Warning

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

 Go to latest Published: Oct 3, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MustParseRFC3339 

func MustParseRFC3339(s string) *metav1.Time

func ParseDuration 

func ParseDuration(duration *monitoringv1alpha1.MetricHistogramDuration, input any) (*metav1.Time, *metav1.Time, error)

ParseDuration returns from, to and error

func ParseRFC3339 

func ParseRFC3339(s string) (*metav1.Time, error)

func PipelineRunDimensions 

func PipelineRunDimensions(pipelineRun *pipelinev1beta1.PipelineRun) *v1alpha1.RunDimensions

func TaskRunDimensions 

func TaskRunDimensions(taskRun *pipelinev1beta1.TaskRun) *v1alpha1.RunDimensions

Types

type GaugeTagMapValue 

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

type GaugeValue 

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

func (*GaugeValue) Delete 

func (g *GaugeValue) Delete(run *v1alpha1.RunDimensions)

func (*GaugeValue) Keys 

func (g *GaugeValue) Keys() []*tag.Map

func (*GaugeValue) Update 

func (g *GaugeValue) Update(run *v1alpha1.RunDimensions, tagMap *tag.Map)

func (*GaugeValue) ValueFor 

func (g *GaugeValue) ValueFor(tagMap *tag.Map) (float64, error)

type GenericRunCounter 

type GenericRunCounter struct {
	Resource  string
	Monitor   string
	RunMetric *v1alpha1.Metric
	// contains filtered or unexported fields
}

func NewGenericRunCounter 

func NewGenericRunCounter(metric *v1alpha1.Metric, resource, monitorName string) *GenericRunCounter

func (*GenericRunCounter) Clean 

func (t *GenericRunCounter) Clean(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

func (*GenericRunCounter) Metric 

func (g *GenericRunCounter) Metric() *v1alpha1.Metric

func (*GenericRunCounter) MetricName 

func (t *GenericRunCounter) MetricName() string

func (*GenericRunCounter) MonitorId 

func (t *GenericRunCounter) MonitorId() string

func (*GenericRunCounter) Record 

func (t *GenericRunCounter) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

func (*GenericRunCounter) View 

func (t *GenericRunCounter) View() *view.View

type GenericRunGauge 

type GenericRunGauge struct {
	Monitor   string
	Resource  string
	RunMetric *v1alpha1.Metric
	// contains filtered or unexported fields
}

func NewGenericRunGauge 

func NewGenericRunGauge(metric *v1alpha1.Metric, resource, monitorName string) *GenericRunGauge

func (*GenericRunGauge) Clean 

func (g *GenericRunGauge) Clean(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

func (*GenericRunGauge) Metric 

func (g *GenericRunGauge) Metric() *v1alpha1.Metric

func (*GenericRunGauge) MetricName 

func (g *GenericRunGauge) MetricName() string

func (*GenericRunGauge) MonitorId 

func (g *GenericRunGauge) MonitorId() string

func (*GenericRunGauge) Record 

func (g *GenericRunGauge) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

func (*GenericRunGauge) View 

func (g *GenericRunGauge) View() *view.View

type GenericRunHistogram 

type GenericRunHistogram struct {
	Resource  string
	Monitor   string
	RunMetric *v1alpha1.Metric
	// contains filtered or unexported fields
}

func NewGenericRunHistogram 

func NewGenericRunHistogram(metric *v1alpha1.Metric, resource, monitorName string) *GenericRunHistogram

func (*GenericRunHistogram) Clean 

func (t *GenericRunHistogram) Clean(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

func (*GenericRunHistogram) Metric 

func (g *GenericRunHistogram) Metric() *v1alpha1.Metric

func (*GenericRunHistogram) MetricName 

func (g *GenericRunHistogram) MetricName() string

func (*GenericRunHistogram) MonitorId 

func (g *GenericRunHistogram) MonitorId() string

func (*GenericRunHistogram) Record 

func (g *GenericRunHistogram) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

func (*GenericRunHistogram) View 

func (g *GenericRunHistogram) View() *view.View

type PipelineCounter 

type PipelineCounter struct {
	GenericRunCounter
	PipelineFilter
}

func NewPipelineCounter 

func NewPipelineCounter(metric *v1alpha1.Metric, monitor *v1alpha1.PipelineMonitor) *PipelineCounter

func (*PipelineCounter) Record 

func (p *PipelineCounter) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type PipelineFilter 

type PipelineFilter struct {
	PipelineName string
}

func (*PipelineFilter) Filter 

func (p *PipelineFilter) Filter(run *v1alpha1.RunDimensions) bool

Filter returns true when the PipelineRun should be recorded, independent of value

type PipelineGauge 

type PipelineGauge struct {
	GenericRunGauge
	PipelineFilter
}

func NewPipelineGauge 

func NewPipelineGauge(metric *v1alpha1.Metric, monitor *v1alpha1.PipelineMonitor) *PipelineGauge

func (*PipelineGauge) Record 

func (p *PipelineGauge) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type PipelineHistogram 

type PipelineHistogram struct {
	GenericRunHistogram
	PipelineFilter
}

func NewPipelineHistogram 

func NewPipelineHistogram(metric *v1alpha1.Metric, monitor *v1alpha1.PipelineMonitor) *PipelineHistogram

func (*PipelineHistogram) Record 

func (p *PipelineHistogram) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type PipelineRunCounter 

type PipelineRunCounter struct {
	GenericRunCounter
	PipelineRunFilter
}

func NewPipelineRunCounter 

func NewPipelineRunCounter(metric *v1alpha1.Metric, monitor *v1alpha1.PipelineRunMonitor) *PipelineRunCounter

func (*PipelineRunCounter) Record 

func (t *PipelineRunCounter) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type PipelineRunFilter 

type PipelineRunFilter struct {
	Selector *metav1.LabelSelector
}

func (*PipelineRunFilter) Filter 

func (p *PipelineRunFilter) Filter(run *v1alpha1.RunDimensions) (bool, error)

Filter returns true when the PipelineRun should be recorded, independent of value

type PipelineRunGauge 

type PipelineRunGauge struct {
	GenericRunGauge
	PipelineRunFilter
}

func NewPipelineRunGauge 

func NewPipelineRunGauge(metric *v1alpha1.Metric, monitor *v1alpha1.PipelineRunMonitor) *PipelineRunGauge

func (*PipelineRunGauge) Record 

func (p *PipelineRunGauge) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type PipelineRunHistogram 

type PipelineRunHistogram struct {
	GenericRunHistogram
	PipelineRunFilter
}

func NewPipelineRunHistogram 

func NewPipelineRunHistogram(metric *v1alpha1.Metric, monitor *v1alpha1.PipelineRunMonitor) *PipelineRunHistogram

func (*PipelineRunHistogram) Record 

func (p *PipelineRunHistogram) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type TaskCounter 

type TaskCounter struct {
	GenericRunCounter
	TaskFilter
}

func NewTaskCounter 

func NewTaskCounter(metric *v1alpha1.Metric, monitor *v1alpha1.TaskMonitor) *TaskCounter

func (*TaskCounter) Record 

func (t *TaskCounter) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type TaskFilter 

type TaskFilter struct {
	TaskName string
}

func (*TaskFilter) Filter 

func (t *TaskFilter) Filter(run *v1alpha1.RunDimensions) bool

Filter returns true when the TaskRun should be recorded, independent of value

type TaskGauge 

type TaskGauge struct {
	GenericRunGauge
	TaskFilter
}

func NewTaskGauge 

func NewTaskGauge(metric *v1alpha1.Metric, monitor *v1alpha1.TaskMonitor) *TaskGauge

func (*TaskGauge) Record 

func (t *TaskGauge) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type TaskHistogram 

type TaskHistogram struct {
	GenericRunHistogram
	TaskFilter
}

func NewTaskHistogram 

func NewTaskHistogram(metric *v1alpha1.Metric, monitor *v1alpha1.TaskMonitor) *TaskHistogram

func (*TaskHistogram) Record 

func (t *TaskHistogram) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type TaskRunCounter 

type TaskRunCounter struct {
	GenericRunCounter
	TaskRunFilter
}

func NewTaskRunCounter 

func NewTaskRunCounter(metric *v1alpha1.Metric, monitor *v1alpha1.TaskRunMonitor) *TaskRunCounter

func (*TaskRunCounter) Record 

func (t *TaskRunCounter) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type TaskRunFilter 

type TaskRunFilter struct {
	Selector *metav1.LabelSelector
}

func (*TaskRunFilter) Filter 

func (t *TaskRunFilter) Filter(run *v1alpha1.RunDimensions) (bool, error)

Filter returns true when the TaskRun should be recorded, independent of value

type TaskRunGauge 

type TaskRunGauge struct {
	GenericRunGauge
	TaskRunFilter
}

func NewTaskRunGauge 

func NewTaskRunGauge(metric *v1alpha1.Metric, monitor *v1alpha1.TaskRunMonitor) *TaskRunGauge

func (*TaskRunGauge) Record 

func (t *TaskRunGauge) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

type TaskRunHistogram 

type TaskRunHistogram struct {
	GenericRunHistogram
	TaskRunFilter
}

func NewTaskRunHistogram 

func NewTaskRunHistogram(metric *v1alpha1.Metric, monitor *v1alpha1.TaskRunMonitor) *TaskRunHistogram

func (*TaskRunHistogram) Record 

func (t *TaskRunHistogram) Record(ctx context.Context, recorder stats.Recorder, run *v1alpha1.RunDimensions)

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.