forked from openshift/origin
-
Notifications
You must be signed in to change notification settings - Fork 0
/
buildconfigs.go
129 lines (113 loc) · 5.1 KB
/
buildconfigs.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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package client
import (
"fmt"
"net/url"
kapi "github.com/GoogleCloudPlatform/kubernetes/pkg/api"
"github.com/GoogleCloudPlatform/kubernetes/pkg/fields"
"github.com/GoogleCloudPlatform/kubernetes/pkg/labels"
"github.com/GoogleCloudPlatform/kubernetes/pkg/watch"
buildapi "github.com/openshift/origin/pkg/build/api"
)
// ErrTriggerIsNotAWebHook is returned when a webhook URL is requested for a trigger
// that is not a webhook type.
var ErrTriggerIsNotAWebHook = fmt.Errorf("the specified trigger is not a webhook")
// BuildConfigsNamespacer has methods to work with BuildConfig resources in a namespace
type BuildConfigsNamespacer interface {
BuildConfigs(namespace string) BuildConfigInterface
}
// BuildConfigInterface exposes methods on BuildConfig resources
type BuildConfigInterface interface {
List(label labels.Selector, field fields.Selector) (*buildapi.BuildConfigList, error)
Get(name string) (*buildapi.BuildConfig, error)
Create(config *buildapi.BuildConfig) (*buildapi.BuildConfig, error)
Update(config *buildapi.BuildConfig) (*buildapi.BuildConfig, error)
Delete(name string) error
Watch(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)
Instantiate(request *buildapi.BuildRequest) (result *buildapi.Build, err error)
WebHookURL(name string, trigger *buildapi.BuildTriggerPolicy) (*url.URL, error)
}
// buildConfigs implements BuildConfigsNamespacer interface
type buildConfigs struct {
r *Client
ns string
}
// newBuildConfigs returns a buildConfigs
func newBuildConfigs(c *Client, namespace string) *buildConfigs {
return &buildConfigs{
r: c,
ns: namespace,
}
}
// List returns a list of buildconfigs that match the label and field selectors.
func (c *buildConfigs) List(label labels.Selector, field fields.Selector) (result *buildapi.BuildConfigList, err error) {
result = &buildapi.BuildConfigList{}
err = c.r.Get().
Namespace(c.ns).
Resource("buildConfigs").
LabelsSelectorParam(label).
FieldsSelectorParam(field).
Do().
Into(result)
return
}
// Get returns information about a particular buildconfig and error if one occurs.
func (c *buildConfigs) Get(name string) (result *buildapi.BuildConfig, err error) {
result = &buildapi.BuildConfig{}
err = c.r.Get().Namespace(c.ns).Resource("buildConfigs").Name(name).Do().Into(result)
return
}
// WebHookURL returns the URL for the provided build config name and trigger policy, or ErrTriggerIsNotAWebHook
// if the trigger is not a webhook type.
func (c *buildConfigs) WebHookURL(name string, trigger *buildapi.BuildTriggerPolicy) (*url.URL, error) {
if kapi.PreV1Beta3(c.r.APIVersion()) {
switch {
case trigger.GenericWebHook != nil:
return c.r.Get().Namespace(c.ns).Resource("buildConfigHooks").Name(name).Suffix(trigger.GenericWebHook.Secret, "generic").URL(), nil
case trigger.GitHubWebHook != nil:
return c.r.Get().Namespace(c.ns).Resource("buildConfigHooks").Name(name).Suffix(trigger.GitHubWebHook.Secret, "github").URL(), nil
default:
return nil, ErrTriggerIsNotAWebHook
}
}
switch {
case trigger.GenericWebHook != nil:
return c.r.Get().Namespace(c.ns).Resource("buildConfigs").Name(name).SubResource("webhooks").Suffix(trigger.GenericWebHook.Secret, "generic").URL(), nil
case trigger.GitHubWebHook != nil:
return c.r.Get().Namespace(c.ns).Resource("buildConfigs").Name(name).SubResource("webhooks").Suffix(trigger.GitHubWebHook.Secret, "github").URL(), nil
default:
return nil, ErrTriggerIsNotAWebHook
}
}
// Create creates a new buildconfig. Returns the server's representation of the buildconfig and error if one occurs.
func (c *buildConfigs) Create(build *buildapi.BuildConfig) (result *buildapi.BuildConfig, err error) {
result = &buildapi.BuildConfig{}
err = c.r.Post().Namespace(c.ns).Resource("buildConfigs").Body(build).Do().Into(result)
return
}
// Update updates the buildconfig on server. Returns the server's representation of the buildconfig and error if one occurs.
func (c *buildConfigs) Update(build *buildapi.BuildConfig) (result *buildapi.BuildConfig, err error) {
result = &buildapi.BuildConfig{}
err = c.r.Put().Namespace(c.ns).Resource("buildConfigs").Name(build.Name).Body(build).Do().Into(result)
return
}
// Delete deletes a BuildConfig, returns error if one occurs.
func (c *buildConfigs) Delete(name string) error {
return c.r.Delete().Namespace(c.ns).Resource("buildConfigs").Name(name).Do().Error()
}
// Watch returns a watch.Interface that watches the requested buildConfigs.
func (c *buildConfigs) Watch(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error) {
return c.r.Get().
Prefix("watch").
Namespace(c.ns).
Resource("buildConfigs").
Param("resourceVersion", resourceVersion).
LabelsSelectorParam(label).
FieldsSelectorParam(field).
Watch()
}
// Instantiate instantiates a new build from build config returning new object or an error
func (c *buildConfigs) Instantiate(request *buildapi.BuildRequest) (result *buildapi.Build, err error) {
result = &buildapi.Build{}
err = c.r.Post().Namespace(c.ns).Resource("buildConfigs").Name(request.Name).SubResource("instantiate").Body(request).Do().Into(result)
return
}