Documentation ¶
Index ¶
- type Scheduler
- func (s *Scheduler) Flush()
- func (s *Scheduler) GetDump() *storages.Dump
- func (s *Scheduler) NewEvent(executionTime int64, event interface{})
- func (s *Scheduler) OnFlushComplete()
- func (s *Scheduler) RemoveEvent(executionTime int, event interface{})
- func (s *Scheduler) UpdateEvent(originalEventTime int64, event interface{}, executionTime int64)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func NewScheduler ¶
func (*Scheduler) OnFlushComplete ¶
func (s *Scheduler) OnFlushComplete()
func (*Scheduler) RemoveEvent ¶
???
func (*Scheduler) UpdateEvent ¶
???
Click to show internal directories.
Click to hide internal directories.