Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MultiError ¶
func TruncateString ¶
Types ¶
type AsyncJobRunner ¶
type AsyncJobRunner struct {
// contains filtered or unexported fields
}
func NewAsyncJobRunner ¶
func NewAsyncJobRunner(logger log.Logger, metricsRegistry prometheus.Registerer, jobTimeout time.Duration, threadCounter *sync.WaitGroup) *AsyncJobRunner
func (*AsyncJobRunner) RunAsyncJob ¶
func (r *AsyncJobRunner) RunAsyncJob(name string, job Job)
type JobMonitor ¶
type JobMonitor struct {
// contains filtered or unexported fields
}
func NewJobMonitor ¶
func NewJobMonitor(registry *prometheus.Registry, pushGatewayURL string) *JobMonitor
Click to show internal directories.
Click to hide internal directories.