common

Documentation

Index

• Variables
• func AddStepDuration(groupName string, stepName string, duration time.Duration)
• func ContainsEqualFold(slice []string, s string) bool
• func GetChunks(items []string, chunkSize int) [][]string
• func GetSyncMapLen(m *sync.Map) int
• func InitMetrics()
• func IntMax(a, b int) int
• func IntMin(a, b int) int
• func SetMetricRollupCompleted(ruName string)
• func SetMetricRollupFailed(ruName string)
• func SetMetricRollupInitOrRunning(ruName string)
• func SetNodesProcessedMetric(groupName string, nodesProcessed int)
• func SetTotalNodesMetric(groupName string, nodes int)
• func TotalProcessingTime(groupName string, duration time.Duration)

Variables

var (
	CRStatus = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: metricNamespace,
			Name:      "resource_status",
			Help:      "Rollup CR statistics, partitioned by name.",
		},
		[]string{

			"resource_name",
		},
	)
)

Functions

func AddStepDuration

func AddStepDuration(groupName string, stepName string, duration time.Duration)

Add rolling update step duration when the step is completed

func ContainsEqualFold

func ContainsEqualFold(slice []string, s string) bool

ContainsEqualFold returns true if a given slice 'slice' contains string 's' under unicode case-folding

func GetChunks

func GetChunks(items []string, chunkSize int) [][]string

func GetSyncMapLen

func GetSyncMapLen(m *sync.Map) int

GetSyncMapLen returns the length of a sync.Map

func InitMetrics

func InitMetrics()

func IntMax

func IntMax(a, b int) int

func IntMin

func IntMin(a, b int) int

func SetMetricRollupCompleted

func SetMetricRollupCompleted(ruName string)

func SetMetricRollupFailed

func SetMetricRollupFailed(ruName string)

func SetMetricRollupInitOrRunning

func SetMetricRollupInitOrRunning(ruName string)

func SetNodesProcessedMetric

func SetNodesProcessedMetric(groupName string, nodesProcessed int)

func SetTotalNodesMetric

func SetTotalNodesMetric(groupName string, nodes int)

func TotalProcessingTime

func TotalProcessingTime(groupName string, duration time.Duration)

observe total processing time