Documentation
¶
Index ¶
- Variables
- type JobManager
- func (m *JobManager) CancelJob(ctx context.Context, jobID string) error
- func (w *JobManager) Error() error
- func (w *JobManager) Send() chan<- interface{}
- func (w *JobManager) Start()
- func (w *JobManager) Status() workerStatus
- func (w *JobManager) Stop()
- func (w *JobManager) WaitStopped(ctx context.Context, timeout time.Duration) error
Constants ¶
This section is empty.
Variables ¶
View Source
var AttachStatsCollector = func(s sqlexec.SQLExecutor) sqlexec.SQLExecutor {
return s
}
AttachStatsCollector attaches the stats collector for the session. this function is registered in BootstrapSession in /session/session.go
View Source
var DetachStatsCollector = func(s sqlexec.SQLExecutor) sqlexec.SQLExecutor {
return s
}
DetachStatsCollector removes the stats collector for the session this function is registered in BootstrapSession in /session/session.go
View Source
var SkipTTLJobManager4Test bool
SkipTTLJobManager4Test skips the bootstrap of TTLJobManager if it's true. It's used to avoid data race in test.
Functions ¶
This section is empty.
Types ¶
type JobManager ¶
type JobManager struct {
// contains filtered or unexported fields
}
JobManager schedules and manages the ttl jobs on this instance
func NewJobManager ¶
func NewJobManager(id string, sessPool sessionPool, store kv.Storage) (manager *JobManager)
NewJobManager creates a new ttl job manager
Source Files
¶
Click to show internal directories.
Click to hide internal directories.