timer

type AggrFunc func([]interface{})

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

type AggrTimerTask struct {
	ScheduleTime time.Time
	Val          interface{}
}

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

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

type Task struct {
	ScheduleTime time.Time
	// contains filtered or unexported fields
}

type TaskQueue []*Task

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