/
apiserver_types.go
135 lines (112 loc) · 4.88 KB
/
apiserver_types.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
130
131
132
133
134
135
/*
Copyright 2020 The Knative Authors
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package v1
import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
"knative.dev/pkg/apis"
duckv1 "knative.dev/pkg/apis/duck/v1"
"knative.dev/pkg/kmeta"
)
// +genclient
// +genreconciler
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// +k8s:defaulter-gen=true
// ApiServerSource is the Schema for the apiserversources API
type ApiServerSource struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ApiServerSourceSpec `json:"spec,omitempty"`
Status ApiServerSourceStatus `json:"status,omitempty"`
}
// Check the interfaces that ApiServerSource should be implementing.
var (
_ runtime.Object = (*ApiServerSource)(nil)
_ kmeta.OwnerRefable = (*ApiServerSource)(nil)
_ apis.Validatable = (*ApiServerSource)(nil)
_ apis.Defaultable = (*ApiServerSource)(nil)
_ apis.HasSpec = (*ApiServerSource)(nil)
_ duckv1.KRShaped = (*ApiServerSource)(nil)
)
// ApiServerSourceSpec defines the desired state of ApiServerSource
type ApiServerSourceSpec struct {
// inherits duck/v1 SourceSpec, which currently provides:
// * Sink - a reference to an object that will resolve to a domain name or
// a URI directly to use as the sink.
// * CloudEventOverrides - defines overrides to control the output format
// and modifications of the event sent to the sink.
duckv1.SourceSpec `json:",inline"`
// Resource are the resources this source will track and send related
// lifecycle events from the Kubernetes ApiServer, with an optional label
// selector to help filter.
// +required
Resources []APIVersionKindSelector `json:"resources,omitempty"`
// ResourceOwner is an additional filter to only track resources that are
// owned by a specific resource type. If ResourceOwner matches Resources[n]
// then Resources[n] is allowed to pass the ResourceOwner filter.
// +optional
ResourceOwner *APIVersionKind `json:"owner,omitempty"`
// EventMode controls the format of the event.
// `Reference` sends a dataref event type for the resource under watch.
// `Resource` send the full resource lifecycle event.
// Defaults to `Reference`
// +optional
EventMode string `json:"mode,omitempty"`
// ServiceAccountName is the name of the ServiceAccount to use to run this
// source. Defaults to default if not set.
// +optional
ServiceAccountName string `json:"serviceAccountName,omitempty"`
}
// ApiServerSourceStatus defines the observed state of ApiServerSource
type ApiServerSourceStatus struct {
// inherits duck/v1 SourceStatus, which currently provides:
// * ObservedGeneration - the 'Generation' of the Service that was last
// processed by the controller.
// * Conditions - the latest available observations of a resource's current
// state.
// * SinkURI - the current active sink URI that has been configured for the
// Source.
duckv1.SourceStatus `json:",inline"`
}
// APIVersionKind is an APIVersion and Kind tuple.
type APIVersionKind struct {
// APIVersion - the API version of the resource to watch.
APIVersion string `json:"apiVersion"`
// Kind of the resource to watch.
// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
Kind string `json:"kind"`
}
// APIVersionKindSelector is an APIVersion Kind tuple with a LabelSelector.
type APIVersionKindSelector struct {
// APIVersion - the API version of the resource to watch.
APIVersion string `json:"apiVersion"`
// Kind of the resource to watch.
// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
Kind string `json:"kind"`
// LabelSelector filters this source to objects to those resources pass the
// label selector.
// More info: http://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors
// +optional
LabelSelector *metav1.LabelSelector `json:"selector,omitempty"`
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// ApiServerSourceList contains a list of ApiServerSource
type ApiServerSourceList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ApiServerSource `json:"items"`
}
// GetStatus retrieves the status of the ApiServerSource . Implements the KRShaped interface.
func (a *ApiServerSource) GetStatus() *duckv1.Status {
return &a.Status.Status
}