forked from cloudfoundry/cli
-
Notifications
You must be signed in to change notification settings - Fork 0
/
build.go
45 lines (35 loc) · 1.02 KB
/
build.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package v3action
import (
"time"
"code.cloudfoundry.org/cli/api/cloudcontroller/ccv3"
)
type Build ccv3.Build
func (actor Actor) StagePackage(packageGUID string) (<-chan Build, <-chan Warnings, <-chan error) {
buildStream := make(chan Build)
warningsStream := make(chan Warnings)
errorStream := make(chan error)
go func() {
defer close(buildStream)
defer close(warningsStream)
defer close(errorStream)
build := ccv3.Build{Package: ccv3.Package{GUID: packageGUID}}
build, allWarnings, err := actor.CloudControllerClient.CreateBuild(build)
warningsStream <- Warnings(allWarnings)
if err != nil {
errorStream <- err
return
}
for build.State == ccv3.BuildStateStaging {
time.Sleep(actor.Config.PollingInterval())
var warnings ccv3.Warnings
build, warnings, err = actor.CloudControllerClient.GetBuild(build.GUID)
warningsStream <- Warnings(warnings)
if err != nil {
errorStream <- err
return
}
}
buildStream <- Build(build)
}()
return buildStream, warningsStream, errorStream
}