task

Documentation

Index

• type BackgroundTaskManager
  • func NewBackgroundTaskManager(metricsPrefix string) *BackgroundTaskManager
  • func (m *BackgroundTaskManager) Register(backgroundTask func(), interval time.Duration, metricName string)
  • func (m *BackgroundTaskManager) StopAll(timeout time.Duration) bool

Types

type BackgroundTaskManager

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

BackgroundTaskManager is not threadsafe, it should only be accessed from a single thread.

func NewBackgroundTaskManager

func NewBackgroundTaskManager(metricsPrefix string) *BackgroundTaskManager

func (*BackgroundTaskManager) Register

func (m *BackgroundTaskManager) Register(backgroundTask func(), interval time.Duration, metricName string)

func (*BackgroundTaskManager) StopAll

func (m *BackgroundTaskManager) StopAll(timeout time.Duration) bool