(boskosClient *client.Client, projectName string, boskosRenewingTomb *tomb.Tomb)
| 132 | } |
| 133 | |
| 134 | func renewBoskosProject(boskosClient *client.Client, projectName string, boskosRenewingTomb *tomb.Tomb) { |
| 135 | defer boskosRenewingTomb.Done() |
| 136 | for { |
| 137 | select { |
| 138 | case <-time.Tick(5 * time.Minute): |
| 139 | fmt.Printf("Renewing boskosProject %q\n", projectName) |
| 140 | if err := boskosClient.UpdateOne(projectName, "busy", nil); err != nil { |
| 141 | fmt.Printf("Failed to update status for project %q with Boskos: %v\n", projectName, err) |
| 142 | } |
| 143 | case <-boskosRenewingTomb.Stopping(): |
| 144 | return |
| 145 | } |
| 146 | } |
| 147 | } |
| 148 | |
| 149 | // releaseBoskosResourcesOnNode1 releases all rented Boskos resources if there is any. |
| 150 | func releaseBoskosResourcesOnNode1() { |
no test coverage detected