Add GetTaskStatusesWithLimit(limit)

api/director_task_status.go

@@ -7,6 +7,7 @@ import (
 	"github.com/cloudfoundry-community/gogobosh/net"
 )
 
+// GetTaskStatuses returns a list of most recent task statuses
 func (repo BoshDirectorRepository) GetTaskStatuses() (tasks []models.TaskStatus, apiResponse net.ApiResponse) {
 	taskResponses := []taskStatusResponse{}
 
@@ -23,6 +24,24 @@ func (repo BoshDirectorRepository) GetTaskStatuses() (tasks []models.TaskStatus,
 	return
 }
 
+// GetTaskStatusesWithLimit returns a max of 'limit' task statuses
+func (repo BoshDirectorRepository) GetTaskStatusesWithLimit(limit int) (tasks []models.TaskStatus, apiResponse net.ApiResponse) {
+	taskResponses := []taskStatusResponse{}
+
+	path := fmt.Sprintf("/tasks?limit=%d", limit)
+	apiResponse = repo.gateway.GetResource(repo.config.TargetURL+path, repo.config.Username, repo.config.Password, &taskResponses)
+	if apiResponse.IsNotSuccessful() {
+		return
+	}
+
+	for _, resource := range taskResponses {
+		tasks = append(tasks, resource.ToModel())
+	}
+
+	return
+}
+
+// GetTaskStatus returns details of a specific task to allow polling for state change
 func (repo BoshDirectorRepository) GetTaskStatus(taskID int) (task models.TaskStatus, apiResponse net.ApiResponse) {
 	taskResponse := taskStatusResponse{}
 

example/bosh-lite-example.go

@@ -82,7 +82,15 @@ func main() {
 		fmt.Println("")
 	}
 
-	task, apiResponse := repo.GetTaskStatus(1)
+	tasks, apiResponse := repo.GetTaskStatusesWithLimit(3)
+	if apiResponse.IsNotSuccessful() {
+		fmt.Println("Could not fetch tasks")
+		return
+	} else {
+		fmt.Printf("%#v\n", tasks)
+	}
+
+	task, apiResponse := repo.GetTaskStatus(tasks[0].ID)
 	if apiResponse.IsNotSuccessful() {
 		fmt.Println("Could not fetch BOSH task 1")
 		return