metrics

Documentation

Index

• Variables
• type ExecutionRun
• type RunMetric
  • func (m *RunMetric) EndExecution(executionID string)
  • func (m *RunMetric) RunningExecutions() []ExecutionRun
  • func (m *RunMetric) StartExecution(executionID, pipeline string)

Variables

var RunMetricInstance = &RunMetric{
	executionRuns: sync.Map{},
}

Types

type ExecutionRun

type ExecutionRun struct {
	ExecutionID    string    `json:"execution_id"`
	Pipeline       string    `json:"pipeline"`
	StartTimestamp time.Time `json:"start_timestamp"`
	EndTimestamp   time.Time `json:"end_timestamp"`
}

type RunMetric

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

func (*RunMetric) EndExecution

func (m *RunMetric) EndExecution(executionID string)

func (*RunMetric) RunningExecutions

func (m *RunMetric) RunningExecutions() []ExecutionRun

func (*RunMetric) StartExecution

func (m *RunMetric) StartExecution(executionID, pipeline string)