scheduled

Documentation

Index

• type ExecutorService
  • func NewExecutorService(statsScope tally.Scope, log logging.SimpleLogging) *ExecutorService
  • func (s *ExecutorService) AddJob(jd JobDefinition)
  • func (s *ExecutorService) Run()
• type Job
• type JobDefinition
• type RuntimeStatCollector
  • func NewRuntimeStats(scope tally.Scope) *RuntimeStatCollector
  • func (r *RuntimeStatCollector) Run()

Types

type ExecutorService

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

func NewExecutorService

func NewExecutorService(
	statsScope tally.Scope,
	log logging.SimpleLogging,
) *ExecutorService

func (*ExecutorService) AddJob

func (s *ExecutorService) AddJob(jd JobDefinition)

func (*ExecutorService) Run

func (s *ExecutorService) Run()

type Job

type Job interface {
	Run()
}

type JobDefinition

type JobDefinition struct {
	Job    Job
	Period time.Duration
}

type RuntimeStatCollector

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

func NewRuntimeStats

func NewRuntimeStats(scope tally.Scope) *RuntimeStatCollector

func (*RuntimeStatCollector) Run

func (r *RuntimeStatCollector) Run()