starter

var (
	// AddInstanceBackoffDuration is histogram of exponential backoff duration for adding instance
	AddInstanceBackoffDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: "myshoes",
		Subsystem: "starter",
		Name:      "add_instance_backoff_duration_seconds",
		Help:      "Histogram of exponential backoff duration in seconds for adding instance",
		Buckets:   prometheus.ExponentialBuckets(1, 2, 10),
	}, []string{"job_uuid"})

	// AddInstanceRetryTotal is counter of total retries for adding instance
	AddInstanceRetryTotal = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: "myshoes",
		Subsystem: "starter",
		Name:      "add_instance_retry_total",
		Help:      "Total number of retries for adding instance",
	}, []string{"job_uuid"})
)

var (
	// CountRunning is count of running semaphore
	CountRunning atomic.Int64
	// CountWaiting is count of waiting job
	CountWaiting atomic.Int64

	// CountRescued is count of rescued job per target
	CountRescued = sync.Map{}

	// AddInstanceRetryCount is count of retry to add instance
	AddInstanceRetryCount = sync.Map{}
)

var (
	// DeletedJobMap is map for deleted jobs. key: runs_on, value: number of deleted jobs
	DeletedJobMap = sync.Map{}
)

var (
	ErrInvalidLabel = Error{/* contains filtered or unexported fields */}
)